Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 453 for timed_out (0.05 sec)

  1. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

      /**
       * @since 28.0
       */
      @Override
      public final void awaitRunning(Duration timeout) throws TimeoutException {
        Service.super.awaitRunning(timeout);
      }
    
      /**
       * @since 15.0
       */
      @Override
      public final void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException {
        delegate.awaitRunning(timeout, unit);
      }
    
      /**
       * @since 15.0
       */
      @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.8K bytes
    - Viewed (0)
  2. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Apr 12 15:07:59 UTC 2025
    - 3.5K bytes
    - Viewed (0)
  3. 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(
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 6K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/ForwardingFluentFuture.java

      public V get() throws InterruptedException, ExecutionException {
        return delegate.get();
      }
    
      @Override
      @ParametricNullness
      public V get(long timeout, TimeUnit unit)
          throws InterruptedException, ExecutionException, TimeoutException {
        return delegate.get(timeout, unit);
      }
    
      @Override
      public String toString() {
        return delegate.toString();
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  5. mockwebserver/src/test/java/mockwebserver3/CustomDispatcherTest.kt

    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.atomic.AtomicInteger
    import mockwebserver3.junit5.StartStop
    import org.junit.jupiter.api.Test
    import org.junit.jupiter.api.Timeout
    
    @Timeout(30)
    class CustomDispatcherTest {
      @StartStop private val mockWebServer = MockWebServer()
    
      @Test
      fun simpleDispatch() {
        val requestsMade = mutableListOf<RecordedRequest>()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 3.2K bytes
    - Viewed (0)
  6. cmd/lock-rest-server.go

    type lockRESTServer struct {
    	ll *localLocker
    }
    
    // RefreshHandler - refresh the current lock
    func (l *lockRESTServer) RefreshHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) {
    	// Add a timeout similar to what we expect upstream.
    	ctx, cancel := context.WithTimeout(context.Background(), dsync.DefaultTimeouts.RefreshCall)
    	defer cancel()
    
    	resp := lockRPCRefresh.NewResponse()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jan 31 19:54:34 UTC 2025
    - 6.3K bytes
    - Viewed (0)
  7. guava-testlib/src/com/google/common/testing/GcFinalization.java

        // This class can make no hard guarantees.  The methods in this class are inherently flaky, but
        // we try hard to make them robust in practice.  We could additionally try to add in a system
        // load timeout multiplier.  Or we could try to use a CPU time bound instead of wall clock time
        // bound.  But these ideas are harder to implement.  We do not try to detect or handle a
        // user-specified -XX:+DisableExplicitGC.
        //
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 11.5K bytes
    - Viewed (0)
  8. src/main/java/jcifs/util/transport/Response.java

         */
        void error();
    
        /**
         * Gets the expiration time for this response.
         *
         * @return the message timeout
         */
        Long getExpiration();
    
        /**
         * Sets the expiration time for this response.
         *
         * @param exp the message timeout to set
         */
        void setExpiration(Long exp);
    
        /**
         * Resets this response to its initial state.
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 3.2K bytes
    - Viewed (0)
  9. android/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)
  10. src/test/java/jcifs/internal/CommonServerMessageBlockRequestTest.java

            boolean async = request.isResponseAsync();
            int size = request.size();
            Integer timeout = request.getOverrideTimeout();
            boolean canChain = request.allowChain(nextRequest);
    
            // Then
            assertTrue(async);
            assertEquals(100, size);
            assertEquals(3000, timeout);
            assertTrue(canChain);
            verify(request).isResponseAsync();
            verify(request).size();
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 12.1K bytes
    - Viewed (0)
Back to top