- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 167 for blocked (0.6 sec)
-
src/cmd/trace/gstate.go
// and orthogonal to syscallEnd; both must be called if the syscall blocked. This sets up an instant // to emit a flow event from, indicating explicitly that this goroutine was unblocked by the system. func (gs *gState[R]) blockedSyscallEnd(ts trace.Time, stack trace.Stack, ctx *traceContext) { name := "exit blocked syscall" gs.setStartCause(ts, name, trace.SyscallP, stack)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 11.9K bytes - Viewed (0) -
src/crypto/tls/quic.go
defer c.handshakeMutex.Lock() // Send on blockedc to notify the QUICConn that the handshake is blocked. // Exported methods of QUICConn wait for the handshake to become blocked // before returning to the user. select { case c.quic.blockedc <- struct{}{}: case <-c.quic.cancelc: return c.sendAlertLocked(alertCloseNotify) } // The QUICConn reads from signalc to notify us that the handshake may
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 17:23:54 UTC 2024 - 15.1K bytes - Viewed (0) -
src/runtime/time.go
if !t.isChan || t.blocked == 0 { badTimer() } t.blocked-- if t.blocked == 0 && t.state&timerHeaped != 0 && t.state&timerZombie == 0 { // Last goroutine that was blocked on this timer. // Mark for removal from heap but do not clear t.when, // so that we know what time it is still meant to trigger. t.state |= timerZombie t.ts.zombies.Add(1) } t.unlock()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 29 14:36:24 UTC 2024 - 37.5K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/text/unicode/norm/composition.go
// is safe. if ii.combinesBackward() { cccB := b[k-1].ccc cccC := ii.ccc blocked := false // b[i] blocked by starter or greater or equal CCC? if cccB == 0 { s = k - 1 } else { blocked = s != k-1 && cccB >= cccC } if !blocked { combined := combine(rb.runeAt(s), rb.runeAt(i)) if combined != 0 { rb.assignRune(s, combined) continue
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 13:01:26 UTC 2024 - 14.1K bytes - Viewed (0) -
src/net/net.go
listed in /etc/resolv.conf, or it can use a cgo-based resolver that calls C library routines such as getaddrinfo and getnameinfo. On Unix the pure Go resolver is preferred over the cgo resolver, because a blocked DNS request consumes only a goroutine, while a blocked C call consumes an operating system thread. When cgo is available, the cgo-based resolver is used instead under a variety of conditions: on systems that do not let programs make direct DNS requests (OS X),
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 26.8K bytes - Viewed (0) -
src/runtime/netpoll.go
pd := pollcache.alloc() lock(&pd.lock) wg := pd.wg.Load() if wg != pdNil && wg != pdReady { throw("runtime: blocked write on free polldesc") } rg := pd.rg.Load() if rg != pdNil && rg != pdReady { throw("runtime: blocked read on free polldesc") } pd.fd = fd if pd.fdseq.Load() == 0 { // The value 0 is special in setEventErr, so don't use it. pd.fdseq.Store(1) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 19:57:43 UTC 2024 - 20.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher_test.go
// May sure that the watch will not be blocked on Stop. for i := 0; i < maxRetriesToProduceTheRaceCondition; i++ { w = newCacheWatcher(0, filter, forget, storage.APIObjectVersioner{}, time.Now(), false, schema.GroupResource{Resource: "pods"}, "") go w.Stop() select { case <-done: case <-time.After(time.Second): t.Fatal("stop is blocked when the timer is fired concurrently") } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 22.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
private static final long SMALL_TIMEOUT_MILLIS = 10; /** How long to wait when determining that a thread is blocked if we expect it to be blocked. */ private static final long EXPECTED_HANG_DELAY_MILLIS = 75; /** * How long to wait when determining that a thread is blocked if we DON'T expect it to be blocked. */ private static final long UNEXPECTED_HANG_DELAY_MILLIS = 10000; /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 25.8K bytes - Viewed (0) -
src/internal/trace/oldtrace.go
// blocked. blocked := false it.events.All()(func(nev *oldtrace.Event) bool { if nev.G != ev.G { return true } // After an EvGoSysCall, the next event on the same G will either be // EvGoSysBlock to denote a blocking syscall, or some other event // (or the end of the trace) if the syscall didn't block. if nev.Type == oldtrace.EvGoSysBlock {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 17.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
private static final long SMALL_TIMEOUT_MILLIS = 10; /** How long to wait when determining that a thread is blocked if we expect it to be blocked. */ private static final long EXPECTED_HANG_DELAY_MILLIS = 75; /** * How long to wait when determining that a thread is blocked if we DON'T expect it to be blocked. */ private static final long UNEXPECTED_HANG_DELAY_MILLIS = 10000; /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 27.1K bytes - Viewed (0)