Search Options

Results per page
Sort
Preferred Languages
Advance

Results 271 - 280 of 417 for timeouts (0.07 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        private final AbstractFuture<?> future;
        private final long timeout;
        private final TimeUnit unit;
        private Exception exception;
        private volatile long startTime;
        private long timeSpentBlocked;
    
        TimedWaiterThread(AbstractFuture<?> future, long timeout, TimeUnit unit) {
          this.future = future;
          this.timeout = timeout;
          this.unit = unit;
        }
    
        @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 47.1K bytes
    - Viewed (0)
  2. tensorflow/c/eager/c_api_experimental.cc

            "Coordination service is not enabled.");
        return;
      }
      absl::Duration timeout;
      if (timeout_in_ms > 0) {
        timeout = absl::Milliseconds(timeout_in_ms);
      } else {
        // Block until the key-value is set or the worker shuts down.
        timeout = absl::InfiniteDuration();
      }
      auto status_or_value = coord_agent->GetKeyValue(key, timeout);
      status->status = status_or_value.status();
      if (!status_or_value.ok()) return;
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 35.9K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. .teamcity/src/main/kotlin/configurations/DocsTest.kt

        applyTestDefaults(
            model,
            this,
            "docs:docsTest${if (testSplitType == EXCLUDE) " docs:checkSamples" else ""}",
            os = os,
            arch = os.defaultArch,
            timeout = 60,
            extraParameters = buildScanTagParam(docsTestType.docsTestName) +
                " -PenableConfigurationCacheForDocsTests=${docsTestType.ccEnabled}" +
                " -PtestJavaVersion=${testJava.version.major}" +
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Wed Sep 25 07:23:49 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  8. 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)
  9. common/scripts/kind_provisioner.sh

      kubectl --kubeconfig="$KUBECONFIG" wait --for condition=ready -n kube-system pod -l k8s-app=calico-kube-controllers --timeout 90s
    }
    
    function install_metallb() {
      KUBECONFIG="${1}"
      kubectl --kubeconfig="$KUBECONFIG" apply -f "${COMMON_SCRIPTS}/metallb-native.yaml"
      kubectl --kubeconfig="$KUBECONFIG" wait -n metallb-system pod --timeout=120s -l app=metallb --for=condition=Ready
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Aug 21 04:47:23 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  10. 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)
Back to top