Search Options

Results per page
Sort
Preferred Languages
Advance

Results 241 - 250 of 377 for timeouts (0.09 sec)

  1. 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)
  2. 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)
  3. 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)
  4. .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)
  5. 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)
  6. 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)
  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. 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)
  9. cmd/prepare-storage.go

    func isServerResolvable(endpoint Endpoint, timeout time.Duration) error {
    	serverURL := &url.URL{
    		Scheme: endpoint.Scheme,
    		Host:   endpoint.Host,
    		Path:   pathJoin(healthCheckPathPrefix, healthCheckLivenessPath),
    	}
    
    	httpClient := &http.Client{
    		Transport: globalInternodeTransport,
    	}
    
    	ctx, cancel := context.WithTimeout(GlobalContext, timeout)
    	defer cancel()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  10. internal/event/target/kafka.go

    			return errors.New("batch should be enabled only if queue dir is enabled")
    		}
    	}
    	if k.BatchCommitTimeout > 0 {
    		if k.QueueDir == "" || k.BatchSize <= 1 {
    			return errors.New("batch commit timeout should be set only if queue dir is enabled and batch size > 1")
    		}
    	}
    	return nil
    }
    
    // KafkaTarget - Kafka target.
    type KafkaTarget struct {
    	initOnce once.Init
    
    	id         event.TargetID
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
Back to top