- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 97 for pickers (0.15 sec)
-
internal/dsync/drwmutex.go
func (dm *DRWMutex) lockBlocking(ctx context.Context, lockLossCallback func(), id, source string, isReadLock bool, opts Options) (locked bool) { restClnts, _ := dm.clnt.GetLockers() // Create lock array to capture the successful lockers locks := make([]string, len(restClnts)) // Add total timeout ctx, cancel := context.WithTimeout(ctx, opts.Timeout) defer cancel() // Tolerance is not set, defaults to half of the locker clients.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
cmd/prepare-storage.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 11.1K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/FreshValueGenerator.java
@Override public String toString() { return string; } }; } @Generates Ticker generateTicker() { return new Ticker() { @Override public long read() { return 0; } final String string = paramString(Ticker.class, generateInt()); @Override public String toString() { return string; } };
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 28.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/platform/android/ConscryptSocketAdapter.kt
sslSocket: SSLSocket, hostname: String?, protocols: List<Protocol>, ) { // No TLS extensions if the socket class is custom. if (matchesSocket(sslSocket)) { // Enable session tickets. Conscrypt.setUseSessionTickets(sslSocket, true) // Enable ALPN. val names = Platform.alpnProtocolNames(protocols) Conscrypt.setApplicationProtocols(sslSocket, names.toTypedArray()) } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheBuilderSpecTest.java
assertEquals("valueStrength", a.valueStrength, b.valueStrength); assertEquals("statsCounterSupplier", a.statsCounterSupplier, b.statsCounterSupplier); assertEquals("ticker", a.ticker, b.ticker); assertEquals("recordStats", a.isRecordingStats(), b.isRecordingStats()); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 19.2K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor.go
bucketsThrottle map[BucketOptions]*bucketThrottle bucketsMeasurement map[BucketOptions]*bucketMeasurement // Buckets with objects in flight bucketMovingAvgTicker *time.Ticker // Ticker for calculating moving averages ctx context.Context // Context for generate NodeCount uint64 } // NewMonitor returns a monitor with defaults.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 6K bytes - Viewed (0) -
cni/pkg/install/install_test.go
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 11.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/platform/ConscryptPlatform.kt
override fun configureTlsExtensions( sslSocket: SSLSocket, hostname: String?, protocols: List<@JvmSuppressWildcards Protocol>, ) { if (Conscrypt.isConscrypt(sslSocket)) { // Enable session tickets. Conscrypt.setUseSessionTickets(sslSocket, true) // Enable ALPN. val names = alpnProtocolNames(protocols) Conscrypt.setApplicationProtocols(sslSocket, names.toTypedArray()) } else {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/platform/android/AndroidSocketAdapter.kt
sslSocket: SSLSocket, hostname: String?, protocols: List<Protocol>, ) { // No TLS extensions if the socket class is custom. if (matchesSocket(sslSocket)) { try { // Enable session tickets. setUseSessionTickets.invoke(sslSocket, true) // Assume platform support on 24+ if (hostname != null && Build.VERSION.SDK_INT <= 23) { // This is SSLParameters.setServerNames() in API 24+.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.6K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/ArbitraryInstances.java
.put(com.google.common.base.Optional.class, com.google.common.base.Optional.absent()) .put(Predicate.class, Predicates.alwaysTrue()) .put(Equivalence.class, Equivalence.equals()) .put(Ticker.class, Ticker.systemTicker()) .put(Stopwatch.class, Stopwatch.createUnstarted()) // io types .put(InputStream.class, new ByteArrayInputStream(new byte[0]))
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 21K bytes - Viewed (1)