- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 345 for sleep (0.13 sec)
-
mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt
* response is ready. */ @Test fun dispatchBlocksWaitingForEnqueue() { Thread { try { Thread.sleep(1000) } catch (ignored: InterruptedException) { } server.enqueue( MockResponse.Builder() .body("enqueued in the background") .build(), ) }.start()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 23.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/config/exbhv/ScheduledJobBhv.java
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 2.2K bytes - Viewed (0) -
src/test/java/jcifs/tests/TimeoutTest.java
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 12.4K bytes - Viewed (0) -
cmd/bootstrap-peer-server.go
} mu.Unlock() }(clnt) } wg.Wait() select { case <-ctx.Done(): return ctx.Err() default: // Sleep and stagger to avoid blocked CPU and thundering // herd upon start up sequence. time.Sleep(25*time.Millisecond + time.Duration(rand.Int63n(int64(100*time.Millisecond)))) retries++ // after 20 retries start logging that servers are not reachable yet
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 7.5K bytes - Viewed (0) -
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)