- Sort Score
- Num 10 results
- Language All
Results 211 - 220 of 515 for waits (0.03 seconds)
-
docs/kms/README.md
- [Understand the KES server concepts](https://github.com/minio/kes/wiki/Concepts) ## Auto Encryption Auto-Encryption is useful when MinIO administrator wants to ensure that all data stored on MinIO is encrypted at rest. ### Using `mc encrypt` (recommended)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 7.2K bytes - Click Count (0) -
cmd/global-heal.go
return } } // All versions resulted in 'ObjectNotFound/VersionNotFound' if versionNotFound == len(fivs.Versions) { return } send(healEntryDone(entry.name)) // Wait and proceed if there are active requests waitForLowHTTPReq() } // How to resolve partial results. resolver := metadataResolutionParams{ dirQuorum: 1, objQuorum: 1, bucket: bucket,
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Apr 04 13:49:12 GMT 2025 - 16.2K bytes - Click Count (0) -
CONTRIBUTING.md
own the intellectual property, then you'll need to sign an [individual CLA][]. Please include your GitHub username. - If you work for a company that wants to allow you to contribute your work, then you'll need to sign a [corporate CLA][]. You generally only need to submit a CLA once, so if you've already submitted
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Dec 15 18:43:50 GMT 2025 - 4K bytes - Click Count (0) -
docs/fr/docs/deployment/https.md
* Le cryptage de la connexion se fait au niveau du protocole TCP. * C'est une couche en dessous de HTTP. * Donc, le certificat et le traitement du cryptage sont faits avant HTTP. * TCP ne connaît pas les "domaines", seulement les adresses IP. * L'information sur le domaine spécifique demandé se trouve dans les données HTTP.Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Tue Aug 06 04:48:30 GMT 2024 - 4.1K bytes - Click Count (0) -
cmd/local-locker.go
} // If we have too many waiting, reject this at once. if l.waitMutex.Load() > lockMutexWaitLimit { l.locksOverloaded.Add(1) return false, nil } // Wait for mutex defer l.getMutex()() if ctx.Err() != nil { return false, ctx.Err() } if !l.canTakeLock(args.Resources...) { // Not all locks can be taken on resources, // reject it completely.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 12K bytes - Click Count (0) -
fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java
settingsBuilder.put("http.cors.allow-origin", "*"); settingsBuilder.put("discovery.type", "single-node"); }).build(newConfigs().clusterName(clusterName).numOfNode(1)); // wait for yellow status runner.ensureYellow(); System.setProperty(FesenClient.HTTP_ADDRESS, "localhost:" + runner.node().settings().get("http.port", "9201")); super.setUp(); // logging
Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Sat Sep 06 04:15:37 GMT 2025 - 7.7K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/CallServerInterceptor.kt
try { exchange.writeRequestHeaders(request) if (hasRequestBody) { // If there's a "Expect: 100-continue" header on the request, wait for a "HTTP/1.1 100 // Continue" response before transmitting the request body. If we don't get that, return // what we did get (such as a 4xx response) without ever transmitting the request body.Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Oct 30 13:46:58 GMT 2025 - 7.6K bytes - Click Count (0) -
internal/cachevalue/cache.go
if t.updating.TryLock() { go func() { defer t.updating.Unlock() t.update(context.Background()) }() } return *v, nil } // Get lock. Either we get it or we wait for it. t.updating.Lock() defer t.updating.Unlock() if time.Since(time.UnixMilli(t.lastUpdateMs.Load())) < ttl { // There is a new value, release lock and return it. if v = t.val.Load(); v != nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri May 24 12:50:46 GMT 2024 - 4.4K bytes - Click Count (0) -
internal/http/dial_linux.go
// Number of probes. // ~ cat /proc/sys/net/ipv4/tcp_keepalive_probes (defaults to 9, we reduce it to 5) _ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, syscall.TCP_KEEPCNT, 5) // Wait time after successful probe in seconds. // ~ cat /proc/sys/net/ipv4/tcp_keepalive_intvl (defaults to 75 secs, we reduce it to 15 secs) _ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, syscall.TCP_KEEPINTVL, 15) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Jul 23 10:53:03 GMT 2024 - 5K bytes - Click Count (0) -
src/test/java/jcifs/tests/persistent/HandleReconnectorTest.java
// Create an expired handle HandleInfo expiredHandle = new HandleInfo("/test/file.txt", new HandleGuid(), new byte[16], HandleType.DURABLE_V2, 100, // 100ms timeout null); // Wait for expiration Thread.sleep(150); CompletableFuture<HandleInfo> future = reconnector.reconnectHandle(expiredHandle, new IOException("Network error"));Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 21 04:51:33 GMT 2025 - 5.6K bytes - Click Count (0)