Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 417 for timeouts (0.07 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. 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)
  3. 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)
  4. 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)
  5. 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)
  6. okhttp/src/main/kotlin/okhttp3/MultipartReader.kt

          }
    
          override fun timeout(): Timeout = timeout
        }
    
        /**
         * Returns a value in [0..maxByteCount] with the number of bytes that can be read from [source] in
         * the current part. If this returns 0 the current part is exhausted; otherwise it has at least
         * one byte left to read.
         */
        private fun currentPartBytesRemaining(maxResult: Long): Long {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top