Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 80 of 583 for timeout (0.17 seconds)

  1. 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
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 08 17:51:53 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt

        if (timeoutEarlyExit) return cause
        if (!timeout.exit()) return cause
    
        val e = InterruptedIOException("timeout")
        if (cause != null) e.initCause(cause)
        return e
      }
    
      /**
       * Stops applying the timeout before the call is entirely complete. This is used for WebSockets
       * and duplex calls where the timeout only applies to the initial setup.
       */
      fun timeoutEarlyExit() {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Jan 11 12:06:21 GMT 2026
    - 19.5K bytes
    - Click Count (0)
  3. src/test/java/org/codelibs/fess/thumbnail/impl/CommandGeneratorTest.java

        @Test
        public void test_setCommandTimeout() throws Exception {
            final long timeout = 5000L;
            generator.setCommandTimeout(timeout);
            assertTrue(true);
        }
    
        @Test
        public void test_setCommandDestroyTimeout() throws Exception {
            final long timeout = 2000L;
            generator.setCommandDestroyTimeout(timeout);
            assertTrue(true);
        }
    
        @Test
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 27.8K bytes
    - Click Count (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/HcHttpClient.java

     */
    public abstract class HcHttpClient extends AbstractCrawlerClient {
    
        /** Property name for connection timeout setting */
        public static final String CONNECTION_TIMEOUT_PROPERTY = "connectionTimeout";
    
        /** Property name for socket timeout setting */
        public static final String SO_TIMEOUT_PROPERTY = "soTimeout";
    
        /** Property name for proxy host setting */
        public static final String PROXY_HOST_PROPERTY = "proxyHost";
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Thu Jan 08 04:17:06 GMT 2026
    - 4.8K bytes
    - Click Count (0)
  5. src/test/java/jcifs/util/transport/ConnectionTimeoutExceptionTest.java

        void testThrowableConstructor() {
            // Test the constructor with a cause
            Throwable cause = new RuntimeException("Root cause of timeout");
            ConnectionTimeoutException exception = new ConnectionTimeoutException(cause);
            assertEquals("java.lang.RuntimeException: Root cause of timeout", exception.getMessage(),
                    "Message should be derived from the cause");
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 2K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

       * TimeoutException} wrapped in an {@link ExecutionException}) if the specified timeout expires.
       * If the timeout expires, not only will the output future finish, but also the input future
       * ({@code this}) will be cancelled and interrupted.
       *
       * @param timeout when to time out the future
       * @param scheduledExecutor The executor service to enforce the timeout.
       * @since 33.4.0 (but since 28.0 in the JRE flavor)
       */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 19.8K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

        }
    
        /**
         * Asserts that at least {@code timeout} has passed but the expected completion time has not.
         */
        void assertCompletionNotExpected(long timeout) {
          Preconditions.checkArgument(timeout < expectedCompletionWaitMillis);
          assertAtLeastTimePassed(stopwatch, timeout);
          assertTimeNotPassed(stopwatch, expectedCompletionWaitMillis);
        }
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 38.1K bytes
    - Click Count (0)
  8. src/test/java/jcifs/internal/smb2/lease/LeaseManagerTest.java

                assertEquals(newState, entry.getLeaseState());
            }
            // If entry doesn't exist, it was cleaned up due to timeout
        }
    
        @Test
        @DisplayName("Should use default lease break timeout when not specified")
        void testDefaultLeaseBreakTimeout() {
            String path = "/share/default-timeout.txt";
            int initialState = Smb2LeaseState.SMB2_LEASE_FULL;
            int newState = Smb2LeaseState.SMB2_LEASE_READ_HANDLE;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 21 00:16:17 GMT 2025
    - 13.2K bytes
    - Click Count (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Call.kt

      /**
       * Returns a timeout that spans the entire call: resolving DNS, connecting, writing the request
       * body, server processing, and reading the response body. If the call requires redirects or
       * retries all must complete within one timeout period.
       *
       * Configure the client's default timeout with [OkHttpClient.Builder.callTimeout].
       */
      fun timeout(): Timeout
    
      /**
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Nov 05 18:28:35 GMT 2025
    - 6.8K bytes
    - Click Count (0)
  10. src/test/java/jcifs/internal/witness/WitnessRegistrationTest.java

            // After update, should not be expired with long timeout
            assertFalse(registration.isExpired(60000));
    
            // Verify heartbeat was actually updated
            assertTrue(registration.getLastHeartbeat() > initialTime);
        }
    
        @Test
        void testExpiration() throws InterruptedException {
            // Registration should not be expired initially with long timeout
            assertFalse(registration.isExpired(60000));
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 09:06:40 GMT 2025
    - 5.1K bytes
    - Click Count (0)
Back to Top