Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 422 for _timeout (0.17 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 7.4K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

      @Override
      public final void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException {
        delegate.awaitRunning(timeout, unit);
      }
    
      /**
       * @since 15.0
       */
      @Override
      public final void awaitTerminated() {
        delegate.awaitTerminated();
      }
    
      /**
       * @since 15.0
       */
      @Override
      public final void awaitTerminated(long timeout, TimeUnit unit) throws TimeoutException {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  3. android/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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jan 30 16:59:10 UTC 2025
    - 13.7K bytes
    - Viewed (0)
  4. samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/TunnelingUnixSocket.java

        super.connect(new UnixSocketAddress(path), 0);
      }
    
      @Override public void connect(SocketAddress endpoint, int timeout) throws IOException {
        this.inetSocketAddress = (InetSocketAddress) endpoint;
        super.connect(new UnixSocketAddress(path), timeout);
      }
    
      @Override public InetAddress getInetAddress() {
        return inetSocketAddress.getAddress();
      }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Feb 12 16:33:52 UTC 2019
    - 1.9K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/Platform.java

        return future.blockingGet();
      }
    
      static <V extends @Nullable Object> V get(AbstractFuture<V> future, long timeout, TimeUnit unit)
          throws InterruptedException, ExecutionException, TimeoutException {
        return future.blockingGet(timeout, unit);
      }
    
      private Platform() {}
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/ListenableFutureTask.java

      }
    
      @CanIgnoreReturnValue
      @Override
      @ParametricNullness
      public V get(long timeout, TimeUnit unit)
          throws TimeoutException, InterruptedException, ExecutionException {
    
        long timeoutNanos = unit.toNanos(timeout);
        if (timeoutNanos <= OverflowAvoidingLockSupport.MAX_NANOSECONDS_THRESHOLD) {
          return super.get(timeout, unit);
        }
        // Waiting 68 years should be enough for any program.
        return super.get(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  7. src/test/java/jcifs/internal/smb1/com/SmbComLockingAndXTest.java

            // set fields via reflection
            setField(cmd, "fid", 0x1234);
            setField(cmd, "typeOfLock", (byte) 0x05);
            setField(cmd, "newOpLockLevel", (byte) 0x01);
            setField(cmd, "timeout", 3000L);
            // arrays of one lock and one unlock range
            LockingAndXRange lock = new LockingAndXRange(false);
            lock.encode(new byte[20], 0); // initialise fields by encoding to set pid etc (though not needed)
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  8. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  9. src/test/java/jcifs/internal/smb2/ServerMessageBlock2RequestTest.java

                testRequest.setOverrideTimeout(timeout);
                assertEquals(timeout, testRequest.getOverrideTimeout());
            }
    
            @Test
            @DisplayName("setOverrideTimeout should handle null value")
            void testSetOverrideTimeoutNull() {
                testRequest.setOverrideTimeout(5000);
                testRequest.setOverrideTimeout(null);
                assertNull(testRequest.getOverrideTimeout());
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 15.7K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb1/smb1/SmbComTransaction.java

                    + ",maxParameterCount=" + maxParameterCount + ",maxDataCount=" + maxDataCount + ",maxSetupCount=" + (int) maxSetupCount
                    + ",flags=0x" + Hexdump.toHexString(flags, 2) + ",timeout=" + timeout + ",parameterCount=" + parameterCount
                    + ",parameterOffset=" + parameterOffset + ",parameterDisplacement=" + parameterDisplacement + ",dataCount=" + dataCount
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 10.4K bytes
    - Viewed (0)
Back to top