Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 444 for timeout (0.12 sec)

  1. src/test/java/jcifs/tests/OplockTests.java

                    try {
                        tree.send(create2);
                    }
                    catch ( Exception e ) {
                        // timeout is expected for now as we do not ack the break
                        if ( ! ( e.getCause() instanceof RequestTimeoutException ) ) {
                            throw e;
                        }
                    }
                }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Thu Jan 05 13:09:03 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  2. istioctl/pkg/util/handlers/handlers.go

    	sortBy := func(pods []*corev1.Pod) sort.Interface { return podutils.ByLogging(pods) }
    	timeout := 2 * time.Second
    	if getFirstPodFunc == nil {
    		getFirstPodFunc = polymorphichelpers.GetFirstPod
    	}
    	pod, _, err := getFirstPodFunc(client, namespace, selector, timeout, sortBy)
    	if err != nil {
    		return "", "", fmt.Errorf("no pods match %q", resname)
    	}
    	return pod.Name, namespace, nil
    }
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  3. common-protos/k8s.io/api/admissionregistration/v1beta1/generated.proto

      // +optional
      optional string sideEffects = 6;
    
      // TimeoutSeconds specifies the timeout for this webhook. After the timeout passes,
      // the webhook call will be ignored or the API call will fail based on the
      // failure policy.
      // The timeout value must be between 1 and 30 seconds.
      // Default to 30 seconds.
      // +optional
      optional int32 timeoutSeconds = 7;
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 22.6K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/AbstractService.java

        try {
          checkCurrentState(RUNNING);
        } finally {
          monitor.leave();
        }
      }
    
      @Override
      public final void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException {
        if (monitor.enterWhenUninterruptibly(hasReachedRunning, timeout, unit)) {
          try {
            checkCurrentState(RUNNING);
          } finally {
            monitor.leave();
          }
        } else {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.4K bytes
    - Viewed (0)
  5. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

        private var editCount = 0
    
        override fun poll(): T = delegate.poll()
    
        override fun poll(
          timeout: Long,
          unit: TimeUnit,
        ): T? {
          taskRunner.lock.withLock {
            val waitUntil = nanoTime + unit.toNanos(timeout)
            while (true) {
              val result = poll()
              if (result != null) return result
              if (nanoTime >= waitUntil) return null
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 29 00:33:04 UTC 2024
    - 12.6K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/FastFallbackTest.kt

    import okhttp3.internal.http2.ErrorCode
    import okhttp3.testing.Flaky
    import org.junit.jupiter.api.AfterEach
    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
    import org.junitpioneer.jupiter.RetryingTest
    import org.opentest4j.TestAbortedException
    
    /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  7. 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)
  8. okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt

              // No client for CONNECT tunnels:
              client = null,
              carrier = this,
              source = source,
              sink = sink,
            )
          source.timeout().timeout(readTimeoutMillis.toLong(), TimeUnit.MILLISECONDS)
          sink.timeout().timeout(writeTimeoutMillis.toLong(), TimeUnit.MILLISECONDS)
          tunnelCodec.writeRequest(nextRequest.headers, requestLine)
          tunnelCodec.finishRequest()
          val response =
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  9. 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)
  10. .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)
Back to top