- Sort Score
- Num 10 results
- Language All
Results 301 - 310 of 360 for Sleeps (0.22 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/bucket-replication.go
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 118.2K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
// Service b startup takes at least 353 millis, but starting the timer is delayed by at least // 150 milliseconds. so in a perfect world the timing would be 353-150=203ms, but since either // of our sleep calls can be arbitrarily delayed we should just assert that there is a time // recorded. assertThat(startupTimes.get(b)).isNotNull(); } public void testServiceStartStop() {Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 17:49:12 GMT 2025 - 25.5K bytes - Click Count (0) -
cmd/erasure-server-pool-decom.go
} return } if configRetriableErrors(err) { decomLogIf(ctx, fmt.Errorf("Unable to resume decommission of pools %v: %w: retrying..", pools, err)) time.Sleep(time.Second + time.Duration(r.Float64()*float64(5*time.Second))) continue } decomLogIf(ctx, fmt.Errorf("Unable to resume decommission of pool %v: %w", pools, err)) return } } }()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 42.2K bytes - Click Count (1) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java
} final long minSleep = retryInterval + retryCount * 1000L; final long maxSleep = retryInterval + retryCount * 2000L; ThreadUtil.sleep(RandomUtils.nextLong(minSleep, maxSleep)); retryCount++; } } } /** * Destroys the client and closes connections. */ @PreDestroyCreated: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Sun Nov 23 02:01:26 GMT 2025 - 26.2K bytes - Click Count (0) -
cmd/iam.go
logger.Info("Waiting for AuthN to be initialized.. (retrying in %s)", retryInterval) } if !authZInit { logger.Info("Waiting for AuthZ to be initialized.. (retrying in %s)", retryInterval) } time.Sleep(retryInterval) continue } break } // Initialize IAM store sys.Lock() sys.initStore(objAPI, etcdClient) // Initialize RoleARNs
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Oct 15 17:00:45 GMT 2025 - 76.5K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/thumbnail/ThumbnailManager.java
} else { final long interval = fessConfig.getThumbnailGeneratorIntervalAsInteger().longValue(); if (interval > 0) { ThreadUtil.sleep(interval); } } } else { logger.warn("Thumbnail generator is not available: name={}", generatorName); }Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 27K bytes - Click Count (0) -
docs/en/docs/help-fastapi.md
Those two tasks are what **consume time the most**. That's the main work of maintaining FastAPI. If you can help me with that, **you are helping me maintain FastAPI** and making sure it keeps **advancing faster and better**. 🚀 ## Join the chat { #join-the-chat }
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sun Aug 31 10:49:48 GMT 2025 - 14K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java
} else if (behavior == 1) { // return null computeNullCount.incrementAndGet(); return null; } else if (behavior == 2) { // slight delay before returning Thread.sleep(5); computeCount.incrementAndGet(); return key; } else { computeCount.incrementAndGet(); return key; } } };
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Sep 30 22:03:28 GMT 2025 - 25.4K bytes - Click Count (0) -
guava/src/com/google/common/collect/CompactHashSet.java
* elements.length) are all {@code null}. */ @VisibleForTesting transient @Nullable Object @Nullable [] elements; /** * Keeps track of metadata like the number of hash table bits and modifications of this data * structure (to make it possible to throw ConcurrentModificationException in the iterator). NoteCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Jul 08 18:32:10 GMT 2025 - 24.7K bytes - Click Count (0) -
cmd/admin-heal-ops.go
} hsp = madmin.HealStopSuccess{ ClientToken: clientToken, ClientAddress: he.clientAddress, StartTime: he.startTime, } he.stop() for !he.hasEnded() { time.Sleep(1 * time.Second) } ahs.Lock() defer ahs.Unlock() // Heal sequence explicitly stopped, remove it. delete(ahs.healSeqMap, path) } b, err := json.Marshal(&hsp)Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 25.4K bytes - Click Count (0)