Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 332 for timeouts (0.09 sec)

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

        FUTURE(Timeout.SMALL, Timeout.MAX),
        SMALL(Timeout.SMALL),
        FINITE(Timeout.MIN, Timeout.MINUS_SMALL, Timeout.ZERO, Timeout.SMALL),
        INFINITE(Timeout.LARGE, Timeout.MAX);
    
        final ImmutableList<Timeout> timeouts;
    
        TimeoutsToUse(Timeout... timeouts) {
          this.timeouts = ImmutableList.copyOf(timeouts);
        }
      }
    
      /** Possible outcomes of calling any of the methods under test. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:18:12 UTC 2024
    - 27.1K bytes
    - Viewed (0)
  2. internal/dsync/drwmutex.go

    	drwMutexInfinite = 1<<63 - 1
    )
    
    // Timeouts are timeouts for specific operations.
    type Timeouts struct {
    	// Acquire - tolerance limit to wait for lock acquisition before.
    	Acquire time.Duration
    
    	// RefreshCall - timeout for the refresh call
    	RefreshCall time.Duration
    
    	// UnlockCall - timeout for the unlock call
    	UnlockCall time.Duration
    
    	// ForceUnlockCall - timeout for the force unlock call
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/http/RealInterceptorChain.kt

        check(exchange == null) { "Timeouts can't be adjusted in a network interceptor" }
    
        return copy(readTimeoutMillis = checkDuration("readTimeout", timeout.toLong(), unit))
      }
    
      override fun writeTimeoutMillis(): Int = writeTimeoutMillis
    
      override fun withWriteTimeout(
        timeout: Int,
        unit: TimeUnit,
      ): Interceptor.Chain {
        check(exchange == null) { "Timeouts can't be adjusted in a network interceptor" }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

        FUTURE(Timeout.SMALL, Timeout.MAX),
        SMALL(Timeout.SMALL),
        FINITE(Timeout.MIN, Timeout.MINUS_SMALL, Timeout.ZERO, Timeout.SMALL),
        INFINITE(Timeout.LARGE, Timeout.MAX);
    
        final ImmutableList<Timeout> timeouts;
    
        TimeoutsToUse(Timeout... timeouts) {
          this.timeouts = ImmutableList.copyOf(timeouts);
        }
      }
    
      /** Possible outcomes of calling any of the methods under test. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 27.1K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/Uninterruptibles.java

          Future<V> future, long timeout, TimeUnit unit) throws ExecutionException, TimeoutException {
        boolean interrupted = false;
        try {
          long remainingNanos = unit.toNanos(timeout);
          long end = System.nanoTime() + remainingNanos;
    
          while (true) {
            try {
              // Future treats negative timeouts just like zero.
              return future.get(remainingNanos, NANOSECONDS);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 19.1K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

          Future<V> future, long timeout, TimeUnit unit) throws ExecutionException, TimeoutException {
        boolean interrupted = false;
        try {
          long remainingNanos = unit.toNanos(timeout);
          long end = System.nanoTime() + remainingNanos;
    
          while (true) {
            try {
              // Future treats negative timeouts just like zero.
              return future.get(remainingNanos, NANOSECONDS);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  7. internal/dsync/dsync_test.go

    	var clnts []NetLocker
    	for i := 0; i < len(nodes); i++ {
    		clnts = append(clnts, newClient(nodes[i].URL))
    	}
    
    	ds = &Dsync{
    		GetLockers: func() ([]NetLocker, string) { return clnts, uuid.New().String() },
    		Timeouts: Timeouts{
    			Acquire:         testDrwMutexAcquireTimeout,
    			RefreshCall:     testDrwMutexRefreshCallTimeout,
    			UnlockCall:      testDrwMutexUnlockCallTimeout,
    			ForceUnlockCall: testDrwMutexForceUnlockCallTimeout,
    		},
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 14:35:19 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  8. cmd/metrics-v3-system-network.go

    )
    
    var (
    	internodeErrorsTotalMD = NewCounterMD(internodeErrorsTotal,
    		"Total number of failed internode calls")
    	internodeDialedErrorsTotalMD = NewCounterMD(internodeDialErrorsTotal,
    		"Total number of internode TCP dial timeouts and errors")
    	internodeDialAvgTimeNanosMD = NewGaugeMD(internodeDialAvgTimeNanos,
    		"Average dial time of internode TCP calls in nanoseconds")
    	internodeSentBytesTotalMD = NewCounterMD(internodeSentBytesTotal,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 10 09:15:15 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt

          throw InterruptedIOException()
        }
      }
    
      /**
       * The Okio timeout watchdog will call [timedOut] if the timeout is reached. In that case we close
       * the stream (asynchronously) which will notify the waiting thread.
       */
      internal inner class StreamTimeout : AsyncTimeout() {
        override fun timedOut() {
          closeLater(ErrorCode.CANCEL)
          connection.sendDegradedPingLater()
        }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  10. okhttp-sse/src/main/kotlin/okhttp3/sse/internal/RealEventSource.kt

              IllegalStateException("Invalid content-type: ${body.contentType()}"),
              response,
            )
            return
          }
    
          // This is a long-lived response. Cancel full-call timeouts.
          call?.timeout()?.cancel()
    
          // Replace the body with a stripped one so the callbacks can't see real data.
          val response = response.stripBody()
    
          val reader = ServerSentEventReader(body.source(), this)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.2K bytes
    - Viewed (0)
Back to top