- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 704 for Blocked (0.41 sec)
-
platforms/core-runtime/internal-instrumentation-api/src/main/java/org/gradle/internal/instrumentation/api/annotations/ToBeReplacedByLazyProperty.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 22 09:58:15 UTC 2024 - 1.2K bytes - Viewed (0) -
src/context/context_test.go
} pc.mu.Unlock() // parent and children should all be finished. check := func(ctx Context, name string) { select { case <-ctx.Done(): default: t.Errorf("<-%s.Done() blocked, but shouldn't have", name) } if e := ctx.Err(); e != Canceled { t.Errorf("%s.Err() == %v want %v", name, e, Canceled) } } check(parent, "parent") check(cancelChild, "cancelChild")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 19 19:13:01 UTC 2023 - 7.7K bytes - Viewed (0) -
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) -
subprojects/core/src/main/java/org/gradle/util/internal/DisconnectableInputStream.java
import java.util.concurrent.locks.ReentrantLock; /** * An {@code InputStream} which reads from the source {@code InputStream}. In addition, when the {@code InputStream} is * closed, all threads blocked reading from the stream will receive an end-of-stream. */ public class DisconnectableInputStream extends BulkReadInputStream { private final Lock lock = new ReentrantLock();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 07 08:18:46 UTC 2021 - 6.5K bytes - Viewed (0) -
src/os/signal/signal_linux_test.go
"syscall" "testing" "time" ) const prSetKeepCaps = 8 // This test validates that syscall.AllThreadsSyscall() can reliably // reach all 'm' (threads) of the nocgo runtime even when one thread // is blocked waiting to receive signals from the kernel. This monitors // for a regression vs. the fix for #43149. func TestAllThreadsSyscallSignals(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 28 18:17:57 UTC 2021 - 1.1K 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)