- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 21 for IMMEDIATE (0.15 sec)
-
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) -
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) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/controller/controller.go
var healthCheckError error if kmsPluginCloseGracePeriod < minKMSPluginCloseGracePeriod { kmsPluginCloseGracePeriod = minKMSPluginCloseGracePeriod } // really make sure that the immediate check does not hang var cancel context.CancelFunc ctx, cancel = context.WithTimeout(ctx, kmsPluginCloseGracePeriod) defer cancel()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.5K bytes - Viewed (0) -
pkg/envoy/proxy.go
if network.AllIPv6(e.NodeIPs) { proxyLocalAddressType = "v6" } startupArgs := []string{ "-c", fname, "--drain-time-s", fmt.Sprint(int(e.DrainDuration.AsDuration().Seconds())), "--drain-strategy", "immediate", // Clients are notified as soon as the drain process starts. "--local-address-ip-version", proxyLocalAddressType, // Reduce default flush interval from 10s to 1s. The access log buffer size is 64k and each log is ~256 bytes
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 10:02:56 UTC 2024 - 6.9K bytes - Viewed (0) -
src/runtime/mwbbuf.go
func (b *wbBuf) reset() { start := uintptr(unsafe.Pointer(&b.buf[0])) b.next = start if testSmallBuf { // For testing, make the buffer smaller but more than // 1 write barrier's worth, so it tests both the // immediate flush and delayed flush cases. b.end = uintptr(unsafe.Pointer(&b.buf[wbMaxEntriesPerCall+1])) } else { b.end = start + uintptr(len(b.buf))*unsafe.Sizeof(b.buf[0]) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 8.1K bytes - Viewed (0)