- Sort Score
- Num 10 results
- Language All
Results 471 - 480 of 699 for takeIf (0.18 seconds)
-
cmd/erasure-server-pool-decom.go
} z.poolMetaMutex.Unlock() } wk.Take() go func(setIdx int) { defer wk.Give() // We will perpetually retry listing if it fails, since we cannot // possibly give up in this matter for !contextCanceled(ctx) { err := set.listObjectsToDecommission(ctx, bi, func(entry metaCacheEntry) { wk.Take() go decommissionEntry(entry) }, )
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 42.2K bytes - Click Count (1) -
docs/changelogs/changelog_2x.md
timing out, and that was a lousy policy. If establishing a connection, reading the next byte from a connection, or writing the next byte to a connection takes more than 10 seconds to complete, youβll need to adjust the timeouts manually. * **OkHttp now rejects request headers that contain invalid characters.** ThisCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 26.6K bytes - Click Count (0) -
guava/src/com/google/common/cache/CacheBuilder.java
* value, you should always choose it explicitly. * * <p>The current implementation uses the concurrency level to create a fixed number of hashtable * segments, each governed by its own write lock. The segment lock is taken once for each explicit * write, and twice for each cache loading computation (once prior to loading the new value, and * once after loading completes). Much internal cache management is performed at the segment
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 13:13:59 GMT 2026 - 51.7K bytes - Click Count (0) -
android/guava/src/com/google/common/net/InternetDomainName.java
import org.jspecify.annotations.Nullable; /** * An immutable well-formed internet domain name, such as {@code com} or {@code foo.co.uk}. Only * syntactic analysis is performed; no DNS lookups or other network interactions take place. Thus * there is no guarantee that the domain actually exists on the internet. * * <p>One common use of this class is to determine whether a given string is likely to represent anCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 03 21:21:59 GMT 2026 - 26.2K bytes - Click Count (0) -
cmd/batch-expire.go
select { case <-ctx.Done(): return default: } if i > 0 { if wait := globalBatchConfig.ExpirationWait(); wait > 0 { time.Sleep(wait) } } i++ wk.Take() go func(toExpire []expireObjInfo) { defer wk.Give() toExpireAll := make([]expireObjInfo, 0, len(toExpire)) toDel := make([]ObjectToDelete, 0, len(toExpire)) oiCache := newObjInfoCache()Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Apr 22 11:16:32 GMT 2025 - 23K bytes - Click Count (0) -
android/guava/src/com/google/common/graph/Graphs.java
/** * Determines whether an edge has already been used during traversal. In the directed case a cycle * is always detected before reusing an edge, so no special logic is required. In the undirected * case, we must take care not to "backtrack" over an edge (i.e. going from A to B and then going * from B to A). */ private static boolean canTraverseWithoutReusingEdge(
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Mar 11 01:10:31 GMT 2026 - 24.4K bytes - Click Count (0) -
docs/en/docs/deployment/concepts.md
* Running on startup * Restarts * Replication (the number of processes running) * Memory * Previous steps before starting Understanding these ideas and how to apply them should give you the intuition necessary to take any decisions when configuring and tweaking your deployments. π€
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 05 18:13:19 GMT 2026 - 18.5K bytes - Click Count (1) -
android/guava-tests/test/com/google/common/primitives/IntsTest.java
.isEqualTo(0xFFEEDDCC); } public void testByteArrayRoundTrips() { Random r = new Random(5); byte[] b = new byte[Ints.BYTES]; // total overkill, but, it takes 0.1 sec so why not... for (int i = 0; i < 10000; i++) { int num = r.nextInt(); assertThat(Ints.fromByteArray(Ints.toByteArray(num))).isEqualTo(num); r.nextBytes(b);
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Mar 08 01:43:32 GMT 2026 - 29.4K bytes - Click Count (0) -
cmd/iam-object-store.go
if took > maxDurationSecondsForLog { // Log if we took a lot of time to load. logger.Info("IAM expired STS purge took %.2fs", took) } // Store the newly populated map in the iam cache. This takes care of // removing stale entries from the existing map. cache.iamSTSAccountsMap = stsAccountsFromStore stsAccPoliciesFromStore.Range(func(k string, v MappedPolicy) bool { cache.iamSTSPolicyMap.Store(k, v)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 26.6K bytes - Click Count (0) -
docs/ko/docs/deployment/docker.md
μ΄λ `docker compose`λ₯Ό μ¬μ©ν λ κ½€ λμ λ μ μμ΅λλ€. μ’ λ κΈ°μ μ μΈ μμΈ λ΄μ©μ Docker Compose FAQ μΉμ μ μ°Έκ³ νμΈμ: [Why do my services take 10 seconds to recreate or stop?](https://docs.docker.com/compose/faq/#why-do-my-services-take-10-seconds-to-recreate-or-stop). #### λλ ν°λ¦¬ ꡬ쑰 { #directory-structure } μ΄μ λ€μκ³Ό κ°μ λλ ν°λ¦¬ κ΅¬μ‘°κ° λμ΄μΌ ν©λλ€: ``` . βββ app βΒ Β βββ __init__.pyCreated: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Fri Mar 20 14:06:26 GMT 2026 - 32.6K bytes - Click Count (0)