- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 573 for Blocked (0.74 sec)
-
pkg/util/iptables/monitor_test.go
} return nil } func waitForBlocked(mfe *monitorFakeExec) error { return utilwait.PollImmediate(100*time.Millisecond, time.Second, func() (bool, error) { blocked := mfe.getWasBlocked() return blocked, nil })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 08 15:21:59 UTC 2023 - 9.3K bytes - Viewed (0) -
src/runtime/sigqueue.go
// variable. It can be in three states: // * sigReceiving means that signal_recv is blocked on sig.Note and there are // no new pending signals. // * sigSending means that sig.mask *may* contain new pending signals, // signal_recv can't be blocked in this state. // * sigIdle means that there are no new pending signals and signal_recv is not // blocked. // // Transitions between states are done atomically with CAS. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 7.6K bytes - Viewed (0) -
src/cmd/trace/goroutinegen.go
} if from == trace.GoNotExist && to == trace.GoRunnable { // Goroutine was created. gs.created(ev.Time(), ev.Goroutine(), ev.Stack()) } if from == trace.GoSyscall && to != trace.GoRunning { // Exiting blocked syscall. gs.syscallEnd(ev.Time(), true, ctx) gs.blockedSyscallEnd(ev.Time(), ev.Stack(), ctx) } else if from == trace.GoSyscall { // Check if we're exiting a syscall in a non-blocking way.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 4.6K 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) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/ConditionalExecutionQueue.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 1.5K 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) -
platforms/core-runtime/base-services/src/integTest/groovy/org/gradle/internal/work/ProjectLockStatisticsIntegrationTest.groovy
configurations { foo } dependencies { foo project(':') } task blocked { def foo = configurations.foo doLast { println foo.files } } } """ when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 24 06:54:47 UTC 2023 - 1.8K bytes - Viewed (0) -
internal/grid/README.md
Returning any error will also cancel the stream remotely. CAREFUL: When utilizing two-way communication, it is important to ensure that the remote handler is not blocked on a send. If the remote handler is blocked on a send, and the client is trying to send without the remote receiving, the operation would become deadlocked if the channels are full. ### Typed handlers
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 9.4K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sync/semaphore/semaphore.go
if next == nil { break // No more waiters blocked. } w := next.Value.(waiter) if s.size-s.cur < w.n { // Not enough tokens for the next waiter. We could keep going (to try to // find a waiter with a smaller request), but under load that could cause // starvation for large requests; instead, we leave all remaining waiters // blocked. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 02:38:00 UTC 2024 - 4.3K bytes - Viewed (0)