Search Options

Results per page
Sort
Preferred Languages
Advance

Results 181 - 190 of 417 for timeouts (0.19 sec)

  1. android/guava-testlib/src/com/google/common/testing/GcFinalization.java

        // This class can make no hard guarantees.  The methods in this class are inherently flaky, but
        // we try hard to make them robust in practice.  We could additionally try to add in a system
        // load timeout multiplier.  Or we could try to use a CPU time bound instead of wall clock time
        // bound.  But these ideas are harder to implement.  We do not try to detect or handle a
        // user-specified -XX:+DisableExplicitGC.
        //
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  2. istioctl/pkg/multixds/gather.go

    	}
    
    	responses := []*discovery.DiscoveryResponse{}
    	xdsOpts := clioptions.CentralControlPlaneOptions{
    		XDSSAN:  makeSan(istioNamespace, kubeClient.Revision()),
    		CertDir: centralOpts.CertDir,
    		Timeout: centralOpts.Timeout,
    	}
    	dialOpts, err := xds.DialOptions(xdsOpts, istioNamespace, tokenServiceAccount, kubeClient)
    	if err != nil {
    		return nil, err
    	}
    
    	for _, pod := range pods {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  3. internal/http/dial_linux.go

    				// ~ cat /proc/sys/net/ipv4/tcp_keepalive_intvl (defaults to 75 secs, we reduce it to 15 secs)
    				_ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, syscall.TCP_KEEPINTVL, 15)
    			}
    
    			// Set tcp user timeout in addition to the keep-alive - tcp-keepalive is not enough to close a socket
    			// with dead end because tcp-keepalive is not fired when there is data in the socket buffer.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5K bytes
    - Viewed (0)
  4. .teamcity/src/main/kotlin/configurations/SmokeTests.kt

            // Smoke tests is usually heavy and the build time is twice on EC2 agents
            requiresNotEc2Agent()
        }
    
        applyTestDefaults(
            model,
            this,
            ":smoke-test:$task",
            timeout = 120,
            extraParameters = listOf(
                stage.getBuildScanCustomValueParam(),
                buildScanTagParam("SmokeTests"),
                "-PtestJavaVersion=${testJava.version.major}",
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Wed Sep 25 07:23:49 UTC 2024
    - 1.2K bytes
    - Viewed (0)
  5. cmd/xl-storage-disk-id-check.go

    		dctx, dcancel := context.WithCancel(ctx)
    		started := time.Now()
    		go func() {
    			timeout := time.NewTimer(globalDriveConfig.GetMaxTimeout())
    			select {
    			case <-dctx.Done():
    				if !timeout.Stop() {
    					<-timeout.C
    				}
    			case <-timeout.C:
    				spent := time.Since(started)
    				goOffline(fmt.Errorf("unable to write+read for %v", spent.Round(time.Millisecond)), spent)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ListeningExecutorService.java

       * cast:
       *
       * <pre>
       *   {@code @SuppressWarnings("unchecked") // guaranteed by invokeAll contract}
       *   {@code List<ListenableFuture<T>> futures = (List) executor.invokeAll(tasks, timeout, unit);}
       * </pre>
       *
       * @return a list of {@code ListenableFuture} instances representing the tasks, in the same
       *     sequential order as produced by the iterator for the given task list. If the operation did
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sun Jun 20 10:45:35 UTC 2021
    - 4.2K bytes
    - Viewed (0)
  7. internal/config/identity/openid/openid.go

    // GetDefaultExpiration - returns the expiration seconds expected.
    func GetDefaultExpiration(dsecs string) (time.Duration, error) {
    	timeout := env.Get(config.EnvMinioStsDuration, "")
    	defaultExpiryDuration, err := time.ParseDuration(timeout)
    	if err != nil {
    		defaultExpiryDuration = time.Hour
    	}
    	if timeout == "" && dsecs != "" {
    		expirySecs, err := strconv.ParseInt(dsecs, 10, 64)
    		if err != nil {
    			return 0, auth.ErrInvalidDuration
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 10 20:16:44 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt

    import org.junit.jupiter.api.Disabled
    import org.junit.jupiter.api.Tag
    import org.junit.jupiter.api.Timeout
    import org.junit.jupiter.api.extension.RegisterExtension
    import org.junit.jupiter.params.ParameterizedTest
    import org.junit.jupiter.params.provider.ArgumentsSource
    
    /** Test how HTTP/2 interacts with HTTP features.  */
    @Timeout(60)
    @Flaky
    @Tag("Slow")
    class HttpOverHttp2Test {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 75.3K bytes
    - Viewed (0)
  9. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockWebServer.kt

      fun takeRequest(): RecordedRequest {
        return delegate.takeRequest().unwrap()
      }
    
      @Throws(InterruptedException::class)
      fun takeRequest(
        timeout: Long,
        unit: TimeUnit,
      ): RecordedRequest? {
        return delegate.takeRequest(timeout, unit)?.unwrap()
      }
    
      @JvmName("-deprecated_requestCount")
      @Deprecated(
        message = "moved to val",
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  10. .github/workflows/mint/minio-erasure.yaml

        MINIO_ROOT_PASSWORD: "minio123"
        MINIO_KMS_SECRET_KEY: "my-minio-key:OSMM+vkKUTCvQs9YL/CVMIMt43HFhkUpqJxTmGl6rYw="
      healthcheck:
        test: ["CMD", "mc", "ready", "local"]
        interval: 5s
        timeout: 5s
        retries: 5
    
    # starts 4 docker containers running minio server instances.
    # using nginx reverse proxy, load balancing, you can access
    # it through port 9000.
    services:
      minio1:
        <<: *minio-common
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Nov 03 21:18:18 UTC 2023
    - 1.2K bytes
    - Viewed (0)
Back to top