Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for Sleeps (0.04 sec)

  1. src/test/java/jcifs/smb/SmbFileIntegrationTest.java

                    if (attempt < 10) {
                        Thread.sleep(500); // First 10 attempts: 0.5 second intervals
                    } else if (attempt < 30) {
                        Thread.sleep(1000); // Next 20 attempts: 1 second intervals
                    } else {
                        Thread.sleep(2000); // Remaining attempts: 2 second intervals
                    }
                }
            }
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 56K bytes
    - Viewed (0)
  2. cmd/batch-handlers.go

    						humanize.Ordinal(attempts), res.UploadID, tgtBucket, tgtObject, aerr))
    				attempts++
    				time.Sleep(time.Second)
    			}
    		}
    	}()
    
    	var (
    		hr    *hash.Reader
    		pInfo PartInfo
    	)
    
    	for i := range partsCount {
    		gopts := minio.GetObjectOptions{
    			VersionID:  srcObjInfo.VersionID,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.5K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt

        override fun writeTo(sink: BufferedSink) {
          try {
            var i = 0
            while (i < contentLength()) {
              sink.write(chunk!!)
              sink.flush()
              Thread.sleep(100)
              i += chunk.size
            }
          } catch (e: IOException) {
            ioe = e
          } catch (e: InterruptedException) {
            throw RuntimeException(e)
          }
        }
      }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 60.4K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

      private fun waitForConnectionShutdown(connection: RealConnection?) {
        if (connection!!.isHealthy(false)) {
          Thread.sleep(100L)
        }
        if (connection.isHealthy(false)) {
          Thread.sleep(2000L)
        }
        if (connection.isHealthy(false)) {
          throw TimeoutException("connection didn't shutdown within timeout")
        }
      }
    
      /**
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 73.4K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt

          }
    
        /**
         * Sets the interval between HTTP/2 and web socket pings initiated by this client. Use this to
         * automatically send ping frames until either the connection fails or it is closed. This keeps
         * the connection alive and may detect connectivity failures.
         *
         * If the server does not respond to each ping with a pong within `interval`, this client will
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 51.7K bytes
    - Viewed (0)
  6. 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
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 75.3K bytes
    - Viewed (0)
  7. docs/changelogs/changelog_3x.md

        `HandshakeCertificates` holds the TLS certificates required for a TLS handshake. On the server
        it keeps your `HeldCertificate` and its chain. On the client it keeps the root certificates
        that are trusted to sign a server's certificate chain. `HandshakeCertificates` also works with
        mutual TLS where these roles are reversed.
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Feb 06 14:55:54 UTC 2022
    - 50.8K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/cache/CacheLoadingTest.java

          Object oldValue = ref.get();
          if (oldValue == null) {
            expectedComputations++;
          }
          ref = new WeakReference<>(cache.getUnchecked(1));
          oldValue = null;
          Thread.sleep(i);
          System.gc();
        }
        assertEquals(expectedComputations, countingLoader.getCount());
    
        for (int i = 0; i < iterations; i++) {
          // The entry should get garbage collected and recomputed.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 85.7K bytes
    - Viewed (0)
  9. cmd/peer-rest-server.go

    		if err != nil {
    			logger.LogIf(GlobalContext, "signalservice", err)
    			execAt = time.Now().Add(restartUpdateDelay)
    		}
    		if d := time.Until(execAt); d > 0 {
    			time.Sleep(d)
    		}
    	}
    	signal := serviceSignal(si)
    	switch signal {
    	case serviceRestart, serviceStop:
    		dryRun := vars.Get("dry-run") == "true" // This is only supported for `restart/stop`
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 53.4K bytes
    - Viewed (0)
  10. cmd/test-utils_test.go

    	t := time.Now()
    	for _, pool := range pools.serverPools {
    		for _, sets := range pool.erasureDisks {
    			for _, s := range sets {
    				if !s.IsLocal() {
    					for !s.IsOnline() {
    						time.Sleep(100 * time.Millisecond)
    						if time.Since(t) > 10*time.Second {
    							return nil, nil, errors.New("timeout waiting for disk to come online")
    						}
    					}
    				}
    			}
    		}
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
Back to top