- Sort Score
- Result 10 results
- Languages All
Results 251 - 260 of 377 for timeouts (0.1 sec)
-
guava/src/com/google/common/util/concurrent/Futures.java
return applyTransformation(input.get()); } @Override public O get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException { return applyTransformation(input.get(timeout, unit)); } private O applyTransformation(I input) throws ExecutionException { try {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 64.4K bytes - Viewed (0) -
internal/rest/client.go
"github.com/minio/minio/internal/logger" "github.com/minio/minio/internal/mcontext" xnet "github.com/minio/pkg/v3/net" ) const logSubsys = "internodes" // DefaultTimeout - default REST timeout is 10 seconds. const DefaultTimeout = 10 * time.Second const ( offline = iota online closed ) // NetworkError - error type in case of errors related to http/transport
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 26 12:55:01 UTC 2024 - 14.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CookiesTest.kt
import okhttp3.java.net.cookiejar.JavaNetCookieJar import org.junit.jupiter.api.BeforeEach import org.junit.jupiter.api.Test import org.junit.jupiter.api.Timeout import org.junit.jupiter.api.extension.RegisterExtension /** Derived from Android's CookiesTest. */ @Timeout(30) class CookiesTest { @RegisterExtension val clientTestRule = OkHttpClientTestRule() private lateinit var server: MockWebServer
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 13K bytes - Viewed (0) -
cmd/data-usage-cache.go
// By default, empty data usage cache *d = dataUsageCache{} load := func(name string, timeout time.Duration) (bool, error) { // Abandon if more than time.Minute, so we don't hold up scanner. // drive timeout by default is 2 minutes, we do not need to wait longer. ctx, cancel := context.WithTimeout(ctx, timeout) defer cancel()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 22 15:30:50 UTC 2024 - 34.7K bytes - Viewed (0) -
buildscripts/verify-healing-empty-erasure-set.sh
"${MINIO[@]}" --address ":$((start_port + 3))" $args >"${WORK_DIR}/dist-minio-server3.log" 2>&1 & pid3=$! disown $pid3 export MC_HOST_myminio="http://minio:minio123@127.0.0.1:$((start_port + 1))" timeout 15m /tmp/mc ready myminio || fail # Wait for all drives to be online and formatted while [ $(/tmp/mc admin info --json myminio | jq '.info.servers[].drives[].state | select(. != "ok")' | wc -l) -gt 0 ]; do sleep 1; done
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 3.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/base/SuppliersTest.java
final AtomicReference<Throwable> thrown = new AtomicReference<>(null); final int numThreads = 3; final Thread[] threads = new Thread[numThreads]; final long timeout = SECONDS.toNanos(60); final Supplier<Boolean> supplier = new Supplier<Boolean>() { boolean isWaiting(Thread thread) { switch (thread.getState()) { case BLOCKED:
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:26:48 UTC 2024 - 17.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/base/SuppliersTest.java
final AtomicReference<Throwable> thrown = new AtomicReference<>(null); final int numThreads = 3; final Thread[] threads = new Thread[numThreads]; final long timeout = SECONDS.toNanos(60); final Supplier<Boolean> supplier = new Supplier<Boolean>() { boolean isWaiting(Thread thread) { switch (thread.getState()) { case BLOCKED:
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:26:48 UTC 2024 - 17.9K bytes - Viewed (0) -
.github/workflows/iam-integrations.yaml
ETCD_ADVERTISE_CLIENT_URLS: "http://0.0.0.0:2379" ports: - "2379:2379" options: >- --health-cmd "etcdctl endpoint health" --health-interval 10s --health-timeout 5s --health-retries 5 openid: image: quay.io/minio/dex ports: - "5556:5556" env: DEX_LDAP_SERVER: "openldap:389" openid2:
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 17 16:45:46 UTC 2024 - 5.3K bytes - Viewed (0) -
internal/config/subnet/subnet.go
configLock.RLock() r.Header.Set(xhttp.SubnetAPIKey, c.APIKey) configLock.RUnlock() r.Header.Set(xhttp.MinioDeploymentID, xhttp.GlobalDeploymentID) client := &http.Client{ Timeout: 10 * time.Second, Transport: c.transport, } resp, err := client.Do(r) if err != nil { return "", err } defer xhttp.DrainBody(resp.Body)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Feb 27 16:35:36 UTC 2023 - 2.9K bytes - Viewed (0) -
.teamcity/src/main/kotlin/util/RerunFlakyTest.kt
val testTaskParameterName = "testTask" val testNameParameterName = "testName" val testTaskOptionsParameterName = "testTaskOptions" val daemon = true applyDefaultSettings(os, arch, buildJvm = BuildToolBuildJvm, timeout = 0) // Show all failed tests here, since that is what we are interested in failureConditions.supportTestRetry = false
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Tue Sep 24 06:22:49 UTC 2024 - 4.6K bytes - Viewed (0)