Search Options

Results per page
Sort
Preferred Languages
Advance

Results 251 - 260 of 377 for timeouts (0.1 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. .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)
  9. 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)
  10. .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)
Back to top