- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 175 for IMMEDIATE (0.16 sec)
-
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) -
pkg/scheduler/framework/plugins/volumebinding/binder.go
return podVolumeClaims, err } // Prebound PVCs are treated as unbound immediate binding if delayBindingMode && pvc.Spec.VolumeName == "" { // Scheduler path podVolumeClaims.unboundClaimsDelayBinding = append(podVolumeClaims.unboundClaimsDelayBinding, pvc) } else { // !delayBindingMode || pvc.Spec.VolumeName != "" // Immediate binding should have already been bound
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 14:55:34 UTC 2024 - 42.6K 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) -
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) -
platforms/core-configuration/graph-serialization/src/main/kotlin/org/gradle/internal/serialize/graph/Codec.kt
val sharedIdentities: ReadIdentities override val isolate: ReadIsolate val classLoader: ClassLoader fun beanStateReaderFor(beanType: Class<*>): BeanStateReader /** * When in immediate mode, [read] calls are NOT suspending. * Useful for bridging with non-suspending serialization protocols such as [java.io.Serializable]. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 23:09:56 UTC 2024 - 7.9K bytes - Viewed (0) -
cmd/bitrot-streaming.go
// sequent of operations: // 1) pipe.Write() // 2) pipe.Close() // Now pipe.Close() can return before the data is read on the other end of the pipe and written to the disk // Hence an immediate Read() on the file can return incorrect data. if b.canClose != nil { b.canClose.Wait() } // Recycle the buffer. if b.byteBuf != nil { globalBytePoolCap.Load().Put(b.byteBuf) b.byteBuf = nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/util/filesystem/watcher.go
// errorHandler() is invoked (if non-nil) whenever an error occurs initializing or watching the specified path. // // If path is a directory, only the directory and immediate children are watched. // // If path does not exist or cannot be watched, an error is passed to errorHandler() and eventHandler() is called at pollInterval. //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 14 23:09:15 UTC 2024 - 5.7K bytes - Viewed (0)