- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 62 for IMMEDIATE (0.21 sec)
-
pkg/test/loadbalancersim/timer/queue.go
q.mutex.Unlock() q.timer.Stop() } func (q *Queue) resetTimer() { // Below is a separate function to limit the scope of the lock. // We don't want to lock when we modify the timer in case it causes // an immediate callback, which would reacquire the lock. needReset, resetDuration := func() (bool, time.Duration) { q.mutex.Lock() defer q.mutex.Unlock() if q.stopping {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 19:13:32 UTC 2023 - 3.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/DispatcherTest.java
assertThat(dispatchedSubscribers).containsExactly(i1, i2, i3, s1, s1, s1, s1, s2, s2, s2, s2); } public void testImmediateDispatcher() { dispatcher = Dispatcher.immediate(); dispatcher.dispatch(1, integerSubscribers.iterator()); assertThat(dispatchedSubscribers) .containsExactly(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Apr 27 15:41:25 UTC 2022 - 5.6K bytes - Viewed (0) -
src/net/http/cgi/cgi_main.go
func childCGIProcess() { if os.Getenv("REQUEST_METHOD") == "" { // Not in a CGI environment; skipping test. return } switch os.Getenv("REQUEST_URI") { case "/immediate-disconnect": os.Exit(0) case "/no-content-type": fmt.Printf("Content-Length: 6\n\nHello\n") os.Exit(0) case "/empty-headers": fmt.Printf("\nHello") os.Exit(0) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 3.1K bytes - Viewed (0) -
pkg/queue/instance_test.go
select { case <-time.After(200 * time.Millisecond): t.Error("close stop, method exit timeout.") case <-signal: t.Log("queue return.") } } func TestClosed(t *testing.T) { t.Run("immediate close", func(t *testing.T) { stop := make(chan struct{}) q := NewQueue(0) go q.Run(stop) close(stop) if err := WaitForClose(q, 10*time.Second); err != nil { t.Error(err) } })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jul 21 16:30:36 UTC 2023 - 3.4K bytes - Viewed (0) -
platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/registry/FileWatcherUpdater.java
* * <dt>watched directories</dt> * <dd>On OSs with non-hierarchical file system events (currently Linux only) we don't watch whole * hierarchies, but need to individually watch each directory and its immediate children. * See {@link org.gradle.internal.watch.registry.impl.NonHierarchicalFileWatcherUpdater}.</dd> * * <dt>probed hierarchies</dt>
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jan 25 15:08:33 UTC 2024 - 5.1K bytes - Viewed (0) -
src/cmd/link/doc.go
-asan Link with C/C++ address sanitizer support. -aslr Enable ASLR for buildmode=c-shared on windows (default true). -bindnow Mark a dynamically linked ELF object for immediate function binding (default false). -buildid id Record id as Go toolchain build id. -buildmode mode Set build mode (default exe). -c Dump call graphs. -compressdwarf
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 15 16:11:52 UTC 2024 - 4K bytes - Viewed (0) -
src/internal/chacha8rand/chacha8.go
func (s *State) Init64(seed [4]uint64) { s.seed = seed block(&s.seed, &s.buf, 0) s.c = 0 s.i = 0 s.n = chunk } // Refill refills the state with more random values. // After a call to Refill, an immediate call to Next will succeed // (unless multiple goroutines are incorrectly sharing a state). func (s *State) Refill() { s.c += ctrInc if s.c == ctrMax { // Reseed with generated uint64s for forward secrecy.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 13 21:47:29 UTC 2024 - 4.4K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt
* is exhausted. * * See [SocketPolicy] for reasons why this can cause test flakiness and how to avoid it. */ object DisconnectAtEnd : SocketPolicy /** * Request immediate close of connection without even reading the request. Use to simulate buggy * SSL servers closing connections in response to unrecognized TLS extensions. */ object DisconnectAtStart : SocketPolicy /**
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 4.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/webhook/webhook.go
// or apierrors.SuggestsClientDelay() returns true, then the function advises a retry. // Otherwise it returns false for an immediate fail. func DefaultShouldRetry(err error) bool { // these errors indicate a transient error that should be retried.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 20 19:02:55 UTC 2023 - 6.3K bytes - Viewed (0) -
src/net/http/http.go
// maxInt64 is the effective "infinite" value for the Server and // Transport's byte-limiting readers. const maxInt64 = 1<<63 - 1 // aLongTimeAgo is a non-zero time, far in the past, used for // immediate cancellation of network operations. var aLongTimeAgo = time.Unix(1, 0) // omitBundledHTTP2 is set by omithttp2.go when the nethttpomithttp2 // build tag is set. That means h2_bundle.go isn't compiled in and we
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 5.1K bytes - Viewed (0)