- Sort Score
- Result 10 results
- Languages All
Results 591 - 600 of 786 for iterations (0.13 sec)
-
internal/dsync/drwmutex.go
var lockRetryMinInterval time.Duration var lockRetryBackOff func(*rand.Rand, uint) time.Duration func init() { // Check for MINIO_DSYNC_TRACE env variable, if set logging will be enabled for failed REST operations. dsyncLog = env.Get("_MINIO_DSYNC_TRACE", "0") == "1" lockRetryMinInterval = 250 * time.Millisecond if lri := env.Get("_MINIO_LOCK_RETRY_INTERVAL", ""); lri != "" { v, err := strconv.Atoi(lri) if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 15:49:49 UTC 2024 - 20.4K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
totalErrsTimeout atomic.Uint64 // Captures all timeout only errors // apiCalls should be placed first so alignment is guaranteed for atomic operations. apiCalls [storageMetricLast]uint64 apiLatencies [storageMetricLast]*lockedLastMinuteLatency diskID atomic.Pointer[string] storage *xlStorage health *diskHealthTracker healthCheck bool
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:56:26 UTC 2024 - 34.5K bytes - Viewed (0) -
guava/src/com/google/common/collect/DiscreteDomain.java
import javax.annotation.CheckForNull; /** * A descriptor for a <i>discrete</i> {@code Comparable} domain such as all {@link Integer} * instances. A discrete domain is one that supports the three basic operations: {@link #next}, * {@link #previous} and {@link #distance}, according to their specifications. The methods {@link * #minValue} and {@link #maxValue} should also be overridden for bounded types. *
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 10.3K bytes - Viewed (0) -
src/main/java/jcifs/smb1/util/MD4.java
// buffer remaining input if (i < len) System.arraycopy(input, offset + i, buffer, bufferNdx, len - i); } /** * Completes the hash computation by performing final operations such * as padding. At the return of this engineDigest, the MD engine is * reset. * * @return the array of bytes for the resulting hash value. */ public byte[] engineDigest () {
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 20:39:42 UTC 2019 - 9.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/ConcurrentHashMultisetTest.java
when(backingMap.putIfAbsent(eq(KEY), isA(AtomicInteger.class))).thenReturn(existing); // another map.get() when(backingMap.get(KEY)).thenReturn(existing); // we shouldn't see any more map operations; CHM will now just update the AtomicInteger assertEquals(12, multiset.add(KEY, 3)); assertEquals(15, existing.get()); } public void testRemove_zeroFromSome() { final int INITIAL_COUNT = 14;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 14.2K bytes - Viewed (0) -
guava/src/com/google/common/cache/AbstractCache.java
*/ void recordEviction(); /** * Returns a snapshot of this counter's values. Note that this may be an inconsistent view, as * it may be interleaved with update operations. */ CacheStats snapshot(); } /** * A thread-safe {@link StatsCounter} implementation for use by {@link Cache} implementors. * * @since 10.0 */
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jun 15 18:00:07 UTC 2021 - 9.1K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbEnumerationUtil.java
throw new SmbException(u.toString() + " directory must end with '/'"); if ( locator.getType() != SmbConstants.TYPE_SERVER ) throw new SmbException("The requested list operations is invalid: " + u.toString()); Set<FileEntry> set = new HashSet<>(); if ( tc.getDfs().isTrustedDomain(tc, locator.getServer()) ) { /*
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sat Jul 20 08:41:19 UTC 2019 - 12.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/MultipartBody.kt
/** * Either writes this request to [sink] or measures its content length. We have one method do * double-duty to make sure the counting and content are consistent, particularly when it comes * to awkward operations like measuring the encoded length of header strings, or the * length-in-digits of an encoded integer. */ @Throws(IOException::class) private fun writeOrCountBytes( sink: BufferedSink?,
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TestThread.java
/** * A helper for concurrency testing. One or more {@code TestThread} instances are instantiated in a * test with reference to the same "lock-like object", and then their interactions with that object * are choreographed via the various methods on this class. * * <p>A "lock-like object" is really any object that may be used for concurrency control. If the
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 10.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/QueuesTest.java
new LinkedBlockingDeque<Object>(), new LinkedBlockingDeque<Object>(10), new PriorityBlockingQueue<Object>(10, Ordering.arbitrary())); } /* * We need to perform operations in a thread pool, even for simple cases, because the queue might * be a SynchronousQueue. */ private ExecutorService threadPool; @Override public void setUp() { threadPool = newCachedThreadPool();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 02:42:09 UTC 2024 - 12.1K bytes - Viewed (0)