- Sort Score
- Result 10 results
- Languages All
Results 171 - 180 of 612 for Flock (0.02 sec)
-
cmd/service.go
// For each call, unfreezeServices must be called once. func freezeServices() { // Use atomics for globalServiceFreeze, so we can read without locking. // We need a lock since we are need the 2 atomic values to remain in sync. globalServiceFreezeMu.Lock() // If multiple calls, first one creates channel. globalServiceFreezeCnt++ if globalServiceFreezeCnt == 1 { globalServiceFreeze.Store(make(chan struct{})) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Feb 28 07:02:14 UTC 2024 - 3.8K bytes - Viewed (0) -
cmd/object-api-common.go
"github.com/dustin/go-humanize" ) const ( // Block size used for all internal operations version 1. // TLDR.. // Not used anymore xl.meta captures the right blockSize // so blockSizeV2 should be used for all future purposes. // this value is kept here to calculate the max API // requests based on RAM size for existing content. blockSizeV1 = 10 * humanize.MiByte // Block size used in erasure coding version 2.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 2.1K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/Striped64.java
* needed. * * A single spinlock ("busy") is used for initializing and * resizing the table, as well as populating slots with new Cells. * There is no need for a blocking lock; when the lock is not * available, threads try other slots (or the base). During these * retries, there is increased contention and reduced locality, * which is still better than alternatives. *
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jan 15 22:17:15 UTC 2025 - 11.4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Interceptor.kt
* val interceptor = Interceptor { chain: Interceptor.Chain -> * chain.proceed(chain.request()) * } * ``` */ inline operator fun invoke(crossinline block: (chain: Chain) -> Response): Interceptor = Interceptor { block(it) } } interface Chain { fun request(): Request @Throws(IOException::class) fun proceed(request: Request): Response /**Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 3.5K bytes - Viewed (0) -
cmd/untar.go
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 6K bytes - Viewed (2) -
doc/go_spec.html
and ends at the end of the innermost containing block.</li> <li>The scope of a type identifier declared inside a function begins at the identifier in the TypeSpec and ends at the end of the innermost containing block.</li> </ol> <p> An identifier declared in a block may be redeclared in an inner block. While the identifier of the inner declaration is in scope, it denotes
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Tue May 06 19:12:15 UTC 2025 - 286.2K bytes - Viewed (0) -
docs/en/docs/js/custom.js
function setupTermynal() { document.querySelectorAll(".use-termynal").forEach(node => { node.style.display = "block"; new Termynal(node, { lineDelay: 500 }); }); const progressLiteralStart = "---> 100%"; const promptLiteralStart = "$ "; const customPromptLiteralStart = "# "; const termynalActivateClass = "termy"; let termynals = []; function createTermynals() {
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Thu Jan 02 20:44:50 UTC 2025 - 5.4K bytes - Viewed (2) -
cmd/globals.go
globalAuthPluginMutex.Lock() defer globalAuthPluginMutex.Unlock() return globalAuthNPlugin } func newGlobalAuthZPluginFn() *polplugin.AuthZPlugin { globalAuthPluginMutex.Lock() defer globalAuthPluginMutex.Unlock() return globalAuthZPlugin } func setGlobalAuthNPlugin(authn *idplugin.AuthNPlugin) { globalAuthPluginMutex.Lock() globalAuthNPlugin = authn
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Sep 03 18:23:41 UTC 2024 - 16.2K bytes - Viewed (1) -
docs/smb3-features/01-smb3-lease-design.md
} } public void releaseLease(Smb2LeaseKey key) { lock.writeLock().lock(); try { LeaseEntry entry = leases.remove(key); if (entry != null) { pathToLease.remove(entry.path); } } finally { lock.writeLock().unlock(); } } private void flushCachedWrites(String path) {Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 22K bytes - Viewed (0) -
guava/src/com/google/common/base/Suppliers.java
in.defaultReadObject(); lock = new Object(); } @GwtIncompatible @J2ktIncompatible private static final long serialVersionUID = 0; } private static final class NonSerializableMemoizingSupplier<T extends @Nullable Object> implements Supplier<T> { private final Object lock = new Object();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 16.5K bytes - Viewed (0)