Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 444 for timeout (0.08 sec)

  1. okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt

         * all must complete within one timeout period.
         *
         * The default value is 0 which imposes no timeout.
         */
        fun callTimeout(
          timeout: Long,
          unit: TimeUnit,
        ) = apply {
          callTimeout = checkDuration("timeout", timeout, unit)
        }
    
        /**
         * Sets the default timeout for complete calls. A value of 0 means no timeout, otherwise values
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 04:21:33 UTC 2024
    - 52K bytes
    - Viewed (0)
  2. internal/lsync/lrwmutex.go

    }
    
    // GetLock tries to get a write lock on lm before the timeout occurs.
    func (lm *LRWMutex) GetLock(ctx context.Context, id string, source string, timeout time.Duration) (locked bool) {
    	const isWriteLock = true
    	return lm.lockLoop(ctx, id, source, timeout, isWriteLock)
    }
    
    // RLock holds a read lock on lm.
    //
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 4.8K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/collect/ForwardingBlockingDeque.java

        delegate().putLast(e);
      }
    
      @Override
      public boolean offerFirst(E e, long timeout, TimeUnit unit) throws InterruptedException {
        return delegate().offerFirst(e, timeout, unit);
      }
    
      @Override
      public boolean offerLast(E e, long timeout, TimeUnit unit) throws InterruptedException {
        return delegate().offerLast(e, timeout, unit);
      }
    
      @Override
      public E takeFirst() throws InterruptedException {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Mar 13 14:30:51 UTC 2023
    - 4.4K bytes
    - Viewed (0)
  4. src/main/java/jcifs/util/transport/Transport.java

         * @param request
         * @param response
         * @param params
         * @param timeout
         * @return
         * @throws IOException
         */
        protected <T extends Response> long doSend ( Request request, T response, Set<RequestParam> params, long timeout ) throws IOException {
            long firstKey = prepareRequests(request, response, params, timeout);
            doSend(request);
            return firstKey;
        }
    
    
        /**
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 01 18:12:21 UTC 2020
    - 24.1K bytes
    - Viewed (0)
  5. cmd/dynamic-timeouts_test.go

    	timeout := newDynamicTimeout(time.Minute, time.Second)
    
    	initial := timeout.Timeout()
    
    	for i := 0; i < dynamicTimeoutLogSize; i++ {
    		timeout.LogFailure()
    	}
    
    	adjusted := timeout.Timeout()
    
    	for i := 0; i < dynamicTimeoutLogSize; i++ {
    		timeout.LogFailure()
    	}
    
    	adjustedAgain := timeout.Timeout()
    
    	if initial >= adjusted || adjusted >= adjustedAgain {
    		t.Errorf("Failure to increase timeout multiple times")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 14 10:08:40 UTC 2022
    - 5.4K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

      }
    
      /**
       * Sets the delegate of `timeout` to [Timeout.NONE] and resets its underlying timeout
       * to the default configuration. Use this to avoid unexpected sharing of timeouts between pooled
       * connections.
       */
      private fun detachTimeout(timeout: ForwardingTimeout) {
        val oldDelegate = timeout.delegate
        timeout.setDelegate(Timeout.NONE)
        oldDelegate.clearDeadline()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/http/RealInterceptorChain.kt

      override fun withConnectTimeout(
        timeout: Int,
        unit: TimeUnit,
      ): Interceptor.Chain {
        check(exchange == null) { "Timeouts can't be adjusted in a network interceptor" }
    
        return copy(connectTimeoutMillis = checkDuration("connectTimeout", timeout.toLong(), unit))
      }
    
      override fun readTimeoutMillis(): Int = readTimeoutMillis
    
      override fun withReadTimeout(
        timeout: Int,
        unit: TimeUnit,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/Queues.java

      public static <E> int drain(
          BlockingQueue<E> q, Collection<? super E> buffer, int numElements, Duration timeout)
          throws InterruptedException {
        // TODO(b/126049426): Consider using saturateToNanos(timeout) instead.
        return drain(q, buffer, numElements, timeout.toNanos(), NANOSECONDS);
      }
    
      /**
       * Drains the queue as {@link BlockingQueue#drainTo(Collection, int)}, but if the requested {@code
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 26 14:11:14 UTC 2024
    - 18.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. src/main/java/org/codelibs/fess/suggest/settings/SuggestSettingsBuilder.java

            timeoutSettings.scrollTimeout = timeout;
            return this;
        }
    
        public SuggestSettingsBuilder searchTimeout(final String timeout) {
            timeoutSettings.searchTimeout = timeout;
            return this;
        }
    
        public SuggestSettingsBuilder indexTimeout(final String timeout) {
            timeoutSettings.indexTimeout = timeout;
            return this;
        }
    
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 2.5K bytes
    - Viewed (0)
Back to top