Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 211 - 220 of 515 for waits (0.03 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top