- Sort Score
- Result 10 results
- Languages All
Results 271 - 280 of 326 for isDeep (0.09 sec)
-
helm-releases/minio-2.0.0.tgz
in the event of a failed command. {{- if .Values.configPathmc }} MC_CONFIG_DIR="{{ .Values.configPathmc }}" MC="/usr/bin/mc --insecure --config-dir ${MC_CONFIG_DIR}" {{- else }} MC="/usr/bin/mc --insecure" {{- end }} # 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. ACCESS=$(cat /config/rootUser) ; SECRET=$(cat /config/rootPassword) ; set +e ;...
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 26 07:36:46 UTC 2021 - 13.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
val request1ReceivedAt = System.currentTimeMillis() assertThat(server.takeRequest().headers["If-None-Match"]).isNull() // Hit that stored response. It's different, but Vary says it doesn't matter. Thread.sleep(10) // Make sure the timestamps are unique. val cacheHit = executeSynchronously( "/", "Accept-Language", "en-US", "Accept-Charset", "UTF-8", )
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 142.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
} /** * The stopwatch gathers events and presents them as strings. R0.6 means a delay of 0.6 seconds * caused by the (R)ateLimiter U1.0 means the (U)ser caused the stopwatch to sleep for a second. */ static class FakeStopwatch extends SleepingStopwatch { long instant = 0L; final List<String> events = Lists.newArrayList(); @Override public long readMicros() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 14:28:19 UTC 2024 - 21.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
} /** * The stopwatch gathers events and presents them as strings. R0.6 means a delay of 0.6 seconds * caused by the (R)ateLimiter U1.0 means the (U)ser caused the stopwatch to sleep for a second. */ static class FakeStopwatch extends SleepingStopwatch { long instant = 0L; final List<String> events = Lists.newArrayList(); @Override public long readMicros() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 14:28:19 UTC 2024 - 21.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/URLConnectionTest.kt
assertThat(server.takeRequest().sequenceNumber).isEqualTo(0) // Give the server time to enact the socket policy if it's one that could happen after the // client has received the response. Thread.sleep(500) val response2 = getResponse(newRequest("/b")) response1.body.source().timeout().timeout(100, TimeUnit.MILLISECONDS) assertContent("This comes after a busted connection", response2)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 131.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/Crawler.java
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:20:39 UTC 2024 - 24K bytes - Viewed (0) -
cmd/signature-v4-utils_test.go
} _, err = globalIAMSys.PolicyDBSet(ctx, ucreds.AccessKey, "consoleAdmin", regUser, false) if err != nil { t.Fatalf("unable to attach policy to credential, %s", err) } time.Sleep(4 * time.Second) policies, err := globalIAMSys.PolicyDBGet(ucreds.AccessKey) if err != nil { t.Fatalf("unable to get policy to credential, %s", err) } if len(policies) == 0 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Apr 05 21:26:41 UTC 2024 - 14.3K bytes - Viewed (0) -
cmd/erasure-sets.go
func (s *erasureSets) monitorAndConnectEndpoints(ctx context.Context, monitorInterval time.Duration) { r := rand.New(rand.NewSource(time.Now().UnixNano())) time.Sleep(time.Duration(r.Float64() * float64(time.Second))) // Pre-emptively connect the disks if possible. s.connectDisks(false) monitor := time.NewTimer(monitorInterval) defer monitor.Stop() for {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 27 10:41:37 UTC 2024 - 37K bytes - Viewed (0) -
misc/go_android_exec/main.go
// it to be ready. adb wait-for-device is not enough, we have to // wait for sys.boot_completed. if err := adb("wait-for-device", "exec-out", "while [[ -z $(getprop sys.boot_completed) ]]; do sleep 1; done;"); err != nil { return 0, err } // Done once per make.bash. if err := adbCopyGoroot(); err != nil { return 0, err }
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Mon Aug 21 17:46:57 UTC 2023 - 15.3K bytes - Viewed (0) -
helm-releases/minio-3.5.0.tgz
in the event of a failed command. {{- if .Values.configPathmc }} MC_CONFIG_DIR="{{ .Values.configPathmc }}" MC="/usr/bin/mc --insecure --config-dir ${MC_CONFIG_DIR}" {{- else }} MC="/usr/bin/mc --insecure" {{- end }} # 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. ACCESS=$(cat /config/rootUser) ; SECRET=$(cat /config/rootPassword) ; set +e ;...
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Feb 02 00:16:41 UTC 2022 - 15.2K bytes - Viewed (0)