- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 704 for Blocked (0.26 sec)
-
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) -
src/runtime/cgo/gcc_netbsd.c
// a bit baroque to remove a signal stack here only to add one // in minit, but it's a simple change that keeps NetBSD // working like other OS's. At this point all signals are // blocked, so there is no race. memset(&ss, 0, sizeof ss); ss.ss_flags = SS_DISABLE; sigaltstack(&ss, nil); crosscall1(ts.fn, setg_gcc, ts.g); return nil;
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Aug 15 03:55:51 UTC 2023 - 1.7K bytes - Viewed (0) -
src/cmd/go/internal/lockedfile/internal/filelock/filelock_test.go
t.Fatalf("%s unexpectedly did not block", desc) return nil case <-time.After(quiescent): t.Logf("%s is blocked (as expected)", desc) return func(t *testing.T) { t.Helper() select { case <-time.After(probablyStillBlocked): t.Fatalf("%s is unexpectedly still blocked", desc) case <-done: } } } } func TestLockExcludesLock(t *testing.T) { t.Parallel()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 06 22:37:50 UTC 2023 - 4K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/TrackingHttpHandler.java
*/ WaitPrecondition getWaitPrecondition(); /** * Releases any blocked requests, in preparation for shutdown. */ void cancelBlockedRequests(); /** * Asserts that this handler has been completed successfully. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 1.9K bytes - Viewed (0) -
src/crypto/rand/rand_plan9.go
seeded sync.Once seedErr error key [32]byte } func (r *reader) Read(b []byte) (n int, err error) { r.seeded.Do(func() { t := time.AfterFunc(time.Minute, func() { println("crypto/rand: blocked for 60 seconds waiting to read random data from the kernel") }) defer t.Stop() entropy, err := os.Open(randomDevice) if err != nil { r.seedErr = err return } defer entropy.Close()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 13 18:57:38 UTC 2024 - 1.8K bytes - Viewed (0) -
subprojects/core/src/testFixtures/groovy/org/gradle/util/internal/MultithreadedTestRule.java
setState(State.Blocking, State.Blocked); waitForState(State.Unblocked, State.Failed); } catch (InterruptedException e) { throw UncheckedException.throwAsUncheckedException(e); } } public void expectUnblocks(Closure action) { try { waitForState(State.Blocked);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 23.3K 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)