Search Options

Results per page
Sort
Preferred Languages
Advance

Results 261 - 270 of 417 for timeouts (0.12 sec)

  1. cmd/bucket-quota.go

    	sys.Init(newObjectLayerFn())
    
    	dui, err := bucketStorageCache.GetWithCtx(ctx)
    	timedout := OperationTimedOut{}
    	if err != nil && !errors.Is(err, context.DeadlineExceeded) && !errors.As(err, &timedout) {
    		if len(dui.BucketsUsage) > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/FuturesGetChecked.java

          Future<V> future, Class<X> exceptionClass, long timeout, TimeUnit unit) throws X {
        // TODO(cpovirk): benchmark a version of this method that accepts a GetCheckedTypeValidator
        bestGetCheckedTypeValidator().validateClass(exceptionClass);
        try {
          return future.get(timeout, unit);
        } catch (InterruptedException e) {
          currentThread().interrupt();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 22 17:40:56 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/KotlinSourceModernTest.kt

            override fun cancel() = TODO()
    
            override fun isExecuted(): Boolean = TODO()
    
            override fun isCanceled(): Boolean = TODO()
    
            override fun timeout(): Timeout = TODO()
    
            override fun clone(): Call = TODO()
          }
      }
    
      @Test
      fun callback() {
        val callback =
          object : Callback {
            override fun onFailure(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 14:21:25 UTC 2024
    - 46.5K bytes
    - Viewed (0)
  4. src/main/java/jcifs/internal/smb1/net/NetServerEnum2.java

            this.name = "\\PIPE\\LANMAN";
    
            this.maxParameterCount = 8;
            this.maxDataCount = 16384;
            this.maxSetupCount = (byte) 0x00;
            this.setupCount = 0;
            this.timeout = 5000;
        }
    
    
        @Override
        public void reset ( int key, String lastN ) {
            super.reset();
            this.lastName = lastN;
        }
    
    
        @Override
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 4K bytes
    - Viewed (0)
  5. .teamcity/src/main/kotlin/util/AdHocPerformanceScenario.kt

        val id = "Util_Performance_AdHocPerformanceScenario${os.asName()}${arch.asName()}"
        name = "AdHoc Performance Scenario - ${os.asName()} ${arch.asName()}"
        id(id)
    
        applyPerformanceTestSettings(os = os, arch = arch, timeout = 420)
        artifactRules = individualPerformanceTestArtifactRules
    
        params {
            text(
                "performance.baselines",
                "",
                display = ParameterDisplay.PROMPT,
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Thu Oct 03 06:45:18 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  6. istioctl/pkg/xds/client.go

    	err = adscConn.Run()
    	if err != nil {
    		return nil, fmt.Errorf("ADSC: failed running %v", err)
    	}
    
    	err = adscConn.Send(dr)
    	if err != nil {
    		return nil, err
    	}
    	response, err := adscConn.WaitVersion(opts.Timeout, dr.TypeUrl, "")
    	return response, err
    }
    
    // DialOptions constructs gRPC dial options from command line configuration
    func DialOptions(opts clioptions.CentralControlPlaneOptions,
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Dec 19 22:42:42 UTC 2023
    - 3.7K bytes
    - Viewed (0)
  7. .teamcity/src/main/kotlin/common/extensions.kt

     */
    const val hiddenArtifactDestination = ".teamcity/gradle-logs"
    
    fun BuildType.applyDefaultSettings(os: Os = Os.LINUX, arch: Arch = Arch.AMD64, buildJvm: Jvm = BuildToolBuildJvm, timeout: Int = 30) {
        artifactRules = """
            *.psoutput => $hiddenArtifactDestination
            *.threaddump => $hiddenArtifactDestination
            build/report-* => $hiddenArtifactDestination
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Thu Oct 10 03:25:26 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/ConnectionReuseTest.kt

    import org.bouncycastle.tls.TlsFatalAlert
    import org.junit.jupiter.api.BeforeEach
    import org.junit.jupiter.api.Tag
    import org.junit.jupiter.api.Test
    import org.junit.jupiter.api.Timeout
    import org.junit.jupiter.api.extension.RegisterExtension
    
    @Timeout(30)
    @Tag("Slowish")
    class ConnectionReuseTest {
      @RegisterExtension
      val platform: PlatformRule = PlatformRule()
    
      @RegisterExtension
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/cache/Cache.java

       * value. Otherwise, a call that passes one {@code loader} may return the result of another call
       * with a differently behaving {@code loader}. For example, a call that requests a short timeout
       * for an RPC may wait for a similar call that requests a long timeout, or a call by an
       * unprivileged user may return a resource accessible only to a privileged user making a similar
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sun Aug 07 02:38:22 UTC 2022
    - 8.3K bytes
    - Viewed (0)
  10. manifests/charts/base/files/crd-all.gen.yaml

                                description: TCP connection timeout.
                                type: string
                                x-kubernetes-validations:
                                - message: must be a valid duration greater than 1ms
                                  rule: duration(self) >= duration('1ms')
                              idleTimeout:
                                description: The idle timeout for TCP connections.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Nov 01 16:23:52 UTC 2024
    - 805K bytes
    - Viewed (0)
Back to top