Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 365 for timeouts (0.05 sec)

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

          lastUnit = unit;
          return null;
        }
    
        // No need to test these methods as they are handled by WrappingExecutorServiceTest
        @Override
        public boolean awaitTermination(long timeout, TimeUnit unit) {
          throw new UnsupportedOperationException();
        }
    
        @Override
        public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
            throws InterruptedException {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/cache/CacheInterceptor.kt

              }
    
              sink.copyTo(cacheBody.buffer, sink.size - bytesRead, bytesRead)
              cacheBody.emitCompleteSegments()
              return bytesRead
            }
    
            override fun timeout(): Timeout = source.timeout()
    
            @Throws(IOException::class)
            override fun close() {
              if (!cacheRequestClosed &&
                !discard(ExchangeCodec.DISCARD_STREAM_TIMEOUT_MILLIS, MILLISECONDS)
              ) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Fri Mar 22 07:09:21 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  3. src/main/java/jcifs/util/transport/Response.java

    
        /**
         * Set error status
         */
        void error ();
    
    
        /**
         * 
         * @return the message timeout
         */
        Long getExpiration ();
    
    
        /**
         * 
         * @param exp
         *            message timeout
         */
        void setExpiration ( Long exp );
    
    
        /**
         * 
         */
        public void reset ();
    
    
        /**
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 2.3K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

         * @throws CancellationException {@inheritDoc}
         */
        @CanIgnoreReturnValue
        @Override
        public V get(long timeout, TimeUnit unit)
            throws InterruptedException, TimeoutException, ExecutionException {
          return sync.get(unit.toNanos(timeout));
        }
    
        /*
         * Improve the documentation of when InterruptedException is thrown. Our
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/UncheckedThrowingFuture.java

        } catch (ExecutionException e) {
          rethrow(e);
        }
        throw new AssertionError("Unreachable");
      }
    
      @Override
      public V get(long timeout, TimeUnit unit)
          throws InterruptedException, ExecutionException, TimeoutException {
        try {
          super.get(timeout, unit);
        } catch (ExecutionException e) {
          rethrow(e);
        }
        throw new AssertionError("Unreachable");
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 12 20:02:10 UTC 2018
    - 3.2K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb1/smb1/SmbComTransaction.java

                ",maxDataCount=" + maxDataCount +
                ",maxSetupCount=" + (int)maxSetupCount +
                ",flags=0x" + Hexdump.toHexString( flags, 2 ) +
                ",timeout=" + timeout +
                ",parameterCount=" + parameterCount +
                ",parameterOffset=" + parameterOffset +
                ",parameterDisplacement=" + parameterDisplacement +
                ",dataCount=" + dataCount +
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 10.5K bytes
    - Viewed (0)
  7. src/main/java/jcifs/netbios/NameServiceClientImpl.java

            }
            return this.nextNameTrnId;
        }
    
    
        void ensureOpen ( int timeout ) throws IOException {
            this.closeTimeout = 0;
            if ( this.transportContext.getConfig().getNetbiosSoTimeout() != 0 ) {
                this.closeTimeout = Math.max(this.transportContext.getConfig().getNetbiosSoTimeout(), timeout);
            }
            // If socket is still good, the new closeTimeout will
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Aug 14 14:26:22 UTC 2022
    - 38.2K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/connection/RetryTlsHandshake.kt

      return when {
        // If there was a protocol problem, don't recover.
        e is ProtocolException -> false
    
        // If there was an interruption or timeout (SocketTimeoutException), don't recover.
        // For the socket connect timeout case we do not try the same host with a different
        // ConnectionSpec: we assume it is unreachable.
        e is InterruptedIOException -> false
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 07 16:05:34 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  9. okcurl/src/main/kotlin/okhttp3/curl/Main.kt

      val connectTimeout: Int by option(
        "--connect-timeout",
        help = "Maximum time allowed for connection (seconds)",
      ).int().default(DEFAULT_TIMEOUT)
    
      val readTimeout: Int by option("--read-timeout", help = "Maximum time allowed for reading data (seconds)").int().default(DEFAULT_TIMEOUT)
    
      val callTimeout: Int by option(
        "--call-timeout",
        help = "Maximum time allowed for the entire call (seconds)",
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/DirectExecutorService.java

      public boolean isTerminated() {
        synchronized (lock) {
          return shutdown && runningTasks == 0;
        }
      }
    
      @Override
      public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
        long nanos = unit.toNanos(timeout);
        synchronized (lock) {
          while (true) {
            if (shutdown && runningTasks == 0) {
              return true;
            } else if (nanos <= 0) {
              return false;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 3.5K bytes
    - Viewed (0)
Back to top