- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 310 for Sleep (0.12 sec)
-
internal/grid/connection.go
if debugPrint { fmt.Printf("%v Connecting to %v: %v. Retrying.\n", c.Local, toDial, err) } sleep := defaultDialTimeout + time.Duration(rng.Int63n(int64(defaultDialTimeout))) next := dialStarted.Add(sleep / 2) sleep = time.Until(next).Round(time.Millisecond) if sleep < 0 { sleep = 0 } gotState := c.State() if gotState == StateShutdown { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt
} } override fun connectTcp(): ConnectResult { check(connectState == ConnectState.READY) events += "plan $id TCP connecting..." taskFaker.sleep(tcpConnectDelayNanos) if (yieldBeforeTcpConnectReturns) { taskFaker.yield() } return when { tcpConnectThrowable != null -> {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 6.2K bytes - Viewed (0) -
cmd/background-heal-ops.go
return } const waitTick = 100 * time.Millisecond tmpMaxWait := maxWait for currentIO() >= maxIO { if tmpMaxWait > 0 { if tmpMaxWait < waitTick { time.Sleep(tmpMaxWait) return } time.Sleep(waitTick) tmpMaxWait -= waitTick } if tmpMaxWait <= 0 { return } } } func currentHTTPIO() int { httpServer := newHTTPServerFn() if httpServer == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.6K bytes - Viewed (0) -
internal/dsync/drwmutex.go
return locked } switch { case opts.RetryInterval < 0: return false case opts.RetryInterval > 0: time.Sleep(opts.RetryInterval) default: attempt++ time.Sleep(lockRetryBackOff(dm.rng, attempt)) } } } } func (dm *DRWMutex) startContinuousLockRefresh(lockLossCallback func(), id, source string, quorum int) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
docs/site-replication/run-ssec-object-replication-with-compression.sh
echo "BUG: Loading an SSE-C object to site with compression should fail. Succeeded though." exit_1 fi # Add replication site ./mc admin replicate add minio1 minio2 --insecure # sleep for replication to complete sleep 30 # List the objects from source site echo "Objects from source instance" ./mc ls minio1/test-bucket --insecure count1=$(./mc ls minio1/test-bucket/plainfile --insecure | wc -l)
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 08:43:09 GMT 2024 - 8.1K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/testdata/workloadsummary_default.txt
default reviews-v2-5b667bcbf8-twvx6 10.244.1.42 ambient-worker None HBONE default reviews-v3-5b9bd44f4-z9ms4 10.244.1.43 ambient-worker None HBONE
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 757 bytes - Viewed (0) -
maven-compat/src/main/java/org/apache/maven/artifact/repository/metadata/AbstractRepositoryMetadata.java
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TestThread.java
checkNotNull(methodName); checkNotNull(arguments); assertEquals(false, invokeMethod("hasQueuedThread", this)); sendRequest(methodName, arguments); Thread.sleep(DUE_DILIGENCE_MILLIS); assertEquals(true, invokeMethod("hasQueuedThread", this)); assertNull(responseQueue.poll()); } /**
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Apr 26 20:07:17 GMT 2023 - 10.9K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java
public void run() { taskDone = true; } }; ScheduledFuture<?> future = TestingExecutors.noOpScheduledExecutor().schedule(task, 10, TimeUnit.MILLISECONDS); Thread.sleep(20); assertFalse(taskDone); assertFalse(future.isDone()); } public void testNoOpScheduledExecutorShutdown() { ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 3.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/AbstractConfigHelper.java
protected long reloadInterval = 1000L; public void update() { CommonPoolUtil.execute(this::load); } protected void waitForNext() { if (reloadInterval > 0) { ThreadUtil.sleep(reloadInterval); } } public abstract int load(); public void setReloadInterval(final long reloadInterval) { this.reloadInterval = reloadInterval; }
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 1.2K bytes - Viewed (0)