Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 365 for timeouts (0.09 sec)

  1. 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)
  2. internal/http/transports.go

    		return tr
    	}
    }
    
    // NewHTTPTransportWithTimeout allows setting a timeout for response headers
    func (s ConnSettings) NewHTTPTransportWithTimeout(timeout time.Duration) *http.Transport {
    	tr := s.getDefaultTransport(0)
    
    	// Settings specific to this transport.
    	tr.ResponseHeaderTimeout = timeout
    	return tr
    }
    
    // NewHTTPTransportWithClientCerts returns a new http configuration used for
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb1/smb1/SmbTransport.java

                                long timeout = RESPONSE_TIMEOUT;
                                resp.expiration = System.currentTimeMillis() + timeout;
                                while( resp.hasMoreElements() ) {
                                    wait( timeout );
                                    timeout = resp.expiration - System.currentTimeMillis();
                                    if (timeout <= 0) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 31.2K bytes
    - Viewed (0)
  4. 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.2K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/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: Tue Apr 04 09:45:04 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

          assertEquals(method, lastMethodCalled);
        }
    
        public void assertMethodWithTimeout(String method, long timeout, TimeUnit unit) {
          assertLastMethodCalled(method + "Timeout");
          assertEquals(unit.toMillis(timeout), lastTimeoutInMillis);
        }
    
        @Override
        public boolean awaitTermination(long timeout, TimeUnit unit) {
          lastMethodCalled = "awaitTermination";
          return false;
        }
    
        @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/RateLimiter.java

       * specified {@code timeout}, or returns {@code false} immediately (without waiting) if the permit
       * would not have been granted before the timeout expired.
       *
       * <p>This method is equivalent to {@code tryAcquire(1, timeout)}.
       *
       * @param timeout the maximum time to wait for the permit. Negative values are treated as zero.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 21.6K bytes
    - Viewed (0)
  8. 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)
  9. src/main/java/jcifs/internal/fscc/FsctlPipeWaitRequest.java

         * 
         */
        public FsctlPipeWaitRequest ( String name, long timeout ) {
            this.nameBytes = name.getBytes(StandardCharsets.UTF_16LE);
            this.timeoutSpecified = true;
            this.timeout = timeout;
        }
    
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.Encodable#encode(byte[], int)
         */
        @Override
        public int encode ( byte[] dst, int dstIndex ) {
            int start = dstIndex;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 2.4K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

          assertEquals(method, lastMethodCalled);
        }
    
        public void assertMethodWithTimeout(String method, long timeout, TimeUnit unit) {
          assertLastMethodCalled(method + "Timeout");
          assertEquals(unit.toMillis(timeout), lastTimeoutInMillis);
        }
    
        @Override
        public boolean awaitTermination(long timeout, TimeUnit unit) {
          lastMethodCalled = "awaitTermination";
          return false;
        }
    
        @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 9.9K bytes
    - Viewed (0)
Back to top