- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 110 for frame (0.13 sec)
-
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
while (buffer.size != 1024L) source.read(buffer, 1024) stream1.close(ErrorCode.CANCEL, null) val frame1 = peer.takeFrame() assertThat(frame1.type).isEqualTo(Http2.TYPE_HEADERS) val frame2 = peer.takeFrame() assertThat(frame2.type).isEqualTo(Http2.TYPE_RST_STREAM) val frame3 = peer.takeFrame() assertThat(frame3.type).isEqualTo(Http2.TYPE_RST_STREAM) assertThat(connection.readBytes.acknowledged).isEqualTo(0L)
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) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketWriter.kt
import okhttp3.internal.ws.WebSocketProtocol.validateCloseCode import okio.Buffer import okio.BufferedSink import okio.ByteString /** * An [RFC 6455][rfc_6455]-compatible WebSocket frame writer. * * This class is not thread safe. * * [rfc_6455]: http://tools.ietf.org/html/rfc6455 */ class WebSocketWriter( private val isClient: Boolean, val sink: BufferedSink, val random: Random,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketWriterTest.kt
payload.writeByte('0'.code) } serverWriter.writeMessageFrame(OPCODE_BINARY, payload.snapshot()) // Write directly to the unbuffered sink. This ensures it will become single frame. assertData("827e") // 'e' == 4-byte follow-up length. assertData(format("%04X", payload.completeSegmentByteCount())) assertData(payload.readByteString()) } @Test fun serverMessageLengthLong() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/ConnectionShutdownException.kt
* limitations under the License. */ package okhttp3.internal.http2 import java.io.IOException /** * Thrown when an HTTP/2 connection is shutdown (either explicitly or if the peer has sent a GOAWAY * frame) and an attempt is made to use the connection. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 875 bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketReaderTest.kt
assertThat(expected.message) .isEqualTo("Client-sent frames must be masked.") } } @Test fun serverSentFramesMustNotBeMasked() { data.write("8180".decodeHex()) assertFailsWith<ProtocolException> { clientReader.processNextFrame() }.also { expected -> assertThat(expected.message) .isEqualTo("Server-sent frames must not be masked.") } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 14.4K bytes - Viewed (0) -
internal/grid/connection.go
const fin = true var frame ws.Frame if s.ClientSide() { // We do not need to copy the payload, since we own it. payload := p frame = ws.NewFrame(op, fin, payload) frame = ws.MaskFrameInPlace(frame) } else { frame = ws.NewFrame(op, fin, p) } return ww.writeFrame(w, frame) } // writeFrame writes frame binary representation into w.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
docs/contribute/debug_logging.md
``` $ adb shell setprop log.tag.okhttp.Http2 DEBUG $ adb shell setprop log.tag.okhttp.TaskRunner DEBUG $ adb logcat '*:E' 'okhttp.Http2:D' 'okhttp.TaskRunner:D' ``` ### HTTP/2 Frame Logging This logs inbound (`<<`) and outbound (`>>`) frames for HTTP/2 connections. ``` [2020-01-01 00:00:00] >> CONNECTION 505249202a20485454502f322e300d0a0d0a534d0d0a0d0a [2020-01-01 00:00:00] >> 0x00000000 6 SETTINGS
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 16:35:36 GMT 2022 - 2.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/ErrorCode.kt
/** Not an error! */ NO_ERROR(0), PROTOCOL_ERROR(1), INTERNAL_ERROR(2), FLOW_CONTROL_ERROR(3), SETTINGS_TIMEOUT(4), STREAM_CLOSED(5), FRAME_SIZE_ERROR(6), REFUSED_STREAM(7), CANCEL(8), COMPRESSION_ERROR(9), CONNECT_ERROR(0xa), ENHANCE_YOUR_CALM(0xb), INADEQUATE_SECURITY(0xc), HTTP_1_1_REQUIRED(0xd), ;
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
assertThat(webSocket.close(1000, null)).isFalse() } /** * There's no read timeout when reading the first byte of a new frame. But as soon as we start * reading a frame we enable the read timeout. In this test we have the server returning the first * byte of a frame but no more frames. */ @Test fun readTimeoutAppliesWithinFrames() { webServer.dispatcher = object : Dispatcher() {
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) -
okhttp/src/test/java/okhttp3/internal/http2/SettingsTest.kt
settings[Settings.MAX_CONCURRENT_STREAMS] = 75 assertThat(settings.getMaxConcurrentStreams()).isEqualTo(75) settings.clear() assertThat(settings.getMaxFrameSize(16384)).isEqualTo(16384) settings[Settings.MAX_FRAME_SIZE] = 16777215 assertThat(settings.getMaxFrameSize(16384)).isEqualTo(16777215) assertThat(settings.getMaxHeaderListSize(-1)).isEqualTo(-1) settings[Settings.MAX_HEADER_LIST_SIZE] = 16777215
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.7K bytes - Viewed (0)