- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 343 for sleep (0.41 sec)
-
cmd/metacache-set.go
o.objectPath(0), "", ReadOptions{}) if err != nil { time.Sleep(retryDelay250) retries++ continue } break } } retryWait := func() { retries++ if retries == 1 { time.Sleep(retryDelay) } else { time.Sleep(retryDelay250) } } // Load first part metadata...
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 19:52:52 GMT 2024 - 30.4K bytes - Viewed (0) -
helm/minio/templates/_helper_create_user.txt
# Special characters for example : ',",<,>,{,} MINIO_ACCESSKEY_SECRETKEY_TMP="/tmp/accessKey_and_secretKey_tmp" # connectToMinio # Use a check-sleep-check loop to wait for MinIO service to be available connectToMinio() { SCHEME=$1 ATTEMPTS=0 ; LIMIT=29 ; # Allow 30 attempts set -e ; # fail if we can't read the keys.
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Dec 12 23:43:32 GMT 2023 - 3.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java
assertEquals(1, service.numIterations.get()); service.stopAsync(); service.secondBarrier.await(); service.awaitTerminated(); // Sleep for a while just to ensure that our task wasn't called again. Thread.sleep(UNIT.toMillis(3 * DELAY)); assertEquals(1, service.numIterations.get()); } public void testCustomScheduler_deadlock() throws InterruptedException, BrokenBarrierException {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 22.5K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/testdata/endpoint/emptyfilter_output.yaml
healthStatus: HEALTHY loadBalancingWeight: 1 metadata: filterMetadata: envoy.transport_socket_match: tlsMode: istio istio: workload: sleep;default;sleep;latest;Kubernetes loadBalancingWeight: 1 locality: {} policy: overprovisioningFactor: 140 - clusterName: xds-grpc endpoints: - lbEndpoints: - endpoint: address:
Others - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Jul 12 02:25:59 GMT 2022 - 17.1K bytes - Viewed (0) -
docs/config/README.md
default adapts to the system speed and pauses up to '250ms' per object when the system has `max_io` number of concurrent requests. It is possible to adjust the `max_sleep` and `max_io` values thereby increasing the healing speed. The delays between each operation of the healer can be adjusted by the `mc admin config set alias/ heal max_sleep=1s` and maximum concurrent requests allowed before we start slowing things down can be configured with `mc admin config set alias/ heal max_io=30` . By default the...
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Sep 11 21:48:54 GMT 2023 - 17.7K bytes - Viewed (0) -
docs/bucket/replication/delete-replication.sh
export MINIO_ROOT_USER="minioadmin" export MINIO_ROOT_PASSWORD="minioadmin" ./minio server --address ":9001" /tmp/xl/1/{1...4}/ 2>&1 >/tmp/dc1.log & ./minio server --address ":9002" /tmp/xl/2/{1...4}/ 2>&1 >/tmp/dc2.log & sleep 3 export MC_HOST_myminio1=http://minioadmin:minioadmin@localhost:9001 export MC_HOST_myminio2=http://minioadmin:minioadmin@localhost:9002 ./mc mb myminio1/testbucket/ ./mc version enable myminio1/testbucket/
Shell Script - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 2.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 4.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt
Request.Builder() .url(server.url("/")) .build() val call = client.newCall(request) call.timeout().timeout(250, TimeUnit.MILLISECONDS) val response = call.execute() Thread.sleep(500) assertFailsWith<IOException> { response.body.source().readUtf8() }.also { expected -> assertThat(expected.message).isEqualTo("timeout") assertThat(call.isCanceled()).isTrue() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.5K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/it/CrawlTestBase.java
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 9.9K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/duplex/MockStreamHandler.kt
responseSent.countDown() } } fun exhaustResponse() = apply { actions += { stream -> stream.responseBody.close() } } fun sleep( duration: Long, unit: TimeUnit, ) = apply { actions += { Thread.sleep(unit.toMillis(duration)) } } override fun handle(stream: Stream) { val task = serviceStreamTask(stream) results.add(task) task.run() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.2K bytes - Viewed (0)