Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for truncate (0.17 sec)

  1. okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt

            val start = nextOutFrame.start
            var truncated: Boolean
            var end: Long
            if (outFramesIterator.hasNext()) {
              nextOutFrame = outFramesIterator.next()
              end = nextOutFrame.start
              truncated = false
            } else {
              end = outBytes.size.toLong()
              truncated = nextOutFrame.truncated
            }
    
            // Write a frame.
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 11 22:09:35 GMT 2024
    - 8.7K bytes
    - Viewed (0)
  2. docs/changelogs/changelog_4x.md

        and `www.squareup.com`. If a server refuses such sharing it will return HTTP 421 and OkHttp will
        automatically retry on an unshared connection.
     *  Fix: Don't crash if a TLS tunnel's response body is truncated.
     *  Fix: Don't track unusable routes beyond their usefulness. We had a bug where we could track
        certain bad routes indefinitely; now we only track the ones that could be necessary.
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 17 13:25:31 GMT 2024
    - 25.2K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/CallTest.kt

        assertThat(hostnameVerifier.calls).containsExactly("verify android.com")
      }
    
      /**
       * We had a bug where OkHttp would crash if HTTP proxies returned a truncated response.
       * https://github.com/square/okhttp/issues/5727
       */
      @Test
      fun proxyUpgradeFailsWithTruncatedResponse() {
        server.enqueue(
          MockResponse.Builder()
            .body("abc")
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 10 19:46:48 GMT 2024
    - 142.5K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt

          object : Dispatcher() {
            override fun dispatch(request: RecordedRequest): MockResponse {
              return upgradeResponse(request)
                .body(Buffer().write("81".decodeHex())) // Truncated frame.
                .removeHeader("Content-Length")
                .socketPolicy(KeepOpen)
                .build()
            }
          }
        val webSocket: WebSocket = newWebSocket()
        clientListener.assertOpen()
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Mar 31 17:16:15 GMT 2024
    - 35.2K bytes
    - Viewed (1)
  5. okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt

            |2
            |
            |CLEAN k1 1 1
            """.trimMargin(),
          )
        }
        createNewCache()
        assertThat(cache["k1"]).isNull()
    
        // The journal is not corrupt when editing after a truncated line.
        set("k1", "C", "D")
        cache.close()
        createNewCache()
        assertValue("k1", "C", "D")
      }
    
      @ParameterizedTest
      @ArgumentsSource(FileSystemParamProvider::class)
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 15 14:55:09 GMT 2024
    - 75.8K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt

        val ping = peer.takeFrame()
        assertThat(ping.type).isEqualTo(Http2.TYPE_PING)
      }
    
      /**
       * A server RST_STREAM shouldn't prevent the client from consuming the response body, even if it
       * follows a truncated request body.
       */
      @Test fun clientRequestBodyServerResponseBodyRstStream() {
        // Write the mocking script.
        peer.sendFrame().settings(Settings())
        peer.acceptFrame() // ACK
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 75.4K bytes
    - Viewed (0)
Back to top