Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for smallint (0.26 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

     * layer primitives: connections, requests, responses, and streams.
     *
     * This class supports [asynchronous canceling][cancel]. This is intended to have the smallest
     * blast radius possible. If an HTTP/2 stream is active, canceling will cancel that stream but not
     * the other streams sharing its connection. But if the TLS handshake is still in progress then
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 17.9K bytes
    - Viewed (2)
  2. okhttp/src/test/java/okhttp3/FastFallbackTest.kt

        }
      }
    
      /**
       * This test reproduces a crash where OkHttp attempted to use a deferred connection when the call
       * already had a healthy connection. It sets up a deferred connection by stalling the IPv6
       * connect, and it sets up a same-connection retry with [ErrorCode.REFUSED_STREAM].
       *
       * https://github.com/square/okhttp/pull/7190
       */
      @Test
      fun preferCallConnectionOverDeferredConnection() {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 10.3K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt

      ) {
        setUp(protocol, mockWebServer)
        assumeNotWindows()
        client =
          client.newBuilder()
            .readTimeout(Duration.ofMillis(500))
            .build()
    
        // Stalling the socket will cause TWO requests to time out!
        server.enqueue(MockResponse(socketPolicy = StallSocketAtStart))
    
        // The 3rd request should be sent to a fresh connection.
        server.enqueue(
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 11 22:09:35 GMT 2024
    - 75.3K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt

         * the server doesn't respond the web socket will be canceled.
         */
        const val CANCEL_AFTER_CLOSE_MILLIS = 60L * 1000
    
        /**
         * The smallest message that will be compressed. We use 1024 because smaller messages already
         * fit comfortably within a single ethernet packet (1500 bytes) even with framing overhead.
         *
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 01 14:21:25 GMT 2024
    - 22.1K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskLogger.kt

      fine("${queue.name} ${String.format("%-22s", message)}: ${task.name}")
    }
    
    /**
     * Returns a duration in the nearest whole-number units like "999 µs" or "  1 s ". This rounds 0.5
     * units away from 0 and 0.499 towards 0. The smallest unit this returns is "µs"; the largest unit
     * it returns is "s". For values in [-499..499] this returns "  0 µs".
     *
     * The returned string attempts to be column-aligned to 6 characters. For negative and large values
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 2.6K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/http2/Hpack.kt

          private val out: Buffer,
        ) {
          /**
           * In the scenario where the dynamic table size changes multiple times between transmission of
           * header blocks, we need to keep track of the smallest value in that interval.
           */
          private var smallestHeaderTableSizeSetting = Integer.MAX_VALUE
          private var emitDynamicTableSizeUpdate: Boolean = false
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 22.5K bytes
    - Viewed (1)
Back to top