- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 32 for Graves (0.24 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt
opcode = b0 and B0_MASK_OPCODE isFinalFrame = b0 and B0_FLAG_FIN != 0 isControlFrame = b0 and OPCODE_FLAG_CONTROL != 0 // Control frames must be final frames (cannot contain continuations). if (isControlFrame && !isFinalFrame) { throw ProtocolException("Control frames must be final.") } val reservedFlag1 = b0 and B0_FLAG_RSV1 != 0 when (opcode) { OPCODE_TEXT, OPCODE_BINARY -> {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
*/ private fun doReadTimeout() = !connection.client || sink.closed || sink.finished /** * A source that reads the incoming data frames of a stream. Although this class uses * synchronization to safely receive incoming data frames, it is not intended for use by multiple * readers. */ inner class FramingSource internal constructor(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
docs/fr/docs/async.md
* de la donnée soit envoyée par le client à travers le réseau * de la donnée envoyée depuis votre programme soit reçue par le client à travers le réseau * le contenu d'un fichier sur le disque soit lu par le système et passé à votre programme * le contenu que votre programme a passé au système soit écrit sur le disque
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Sun Mar 31 23:52:53 GMT 2024 - 24K bytes - Viewed (0) -
docs/config/README.md
In most setups this is sufficient to heal the content after drive replacements. Setting `max_sleep` to a *lower* value and setting `max_io` to a *higher* value would make heal go faster.
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 11 21:48:54 GMT 2023 - 17.7K bytes - Viewed (0) -
Makefile
@(env bash $(PWD)/buildscripts/verify-healing-empty-erasure-set.sh) @(env bash $(PWD)/buildscripts/heal-inconsistent-versions.sh) verify-healing-with-root-disks: ## verify healing root disks @echo "Verify healing with root drives" @GORACE=history_size=7 CGO_ENABLED=1 go build -race -tags kqueue -trimpath --ldflags "$(LDFLAGS)" -o $(PWD)/minio 1>/dev/null @(env bash $(PWD)/buildscripts/verify-healing-with-root-disks.sh)
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:55:41 GMT 2024 - 10.3K bytes - Viewed (1) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
*/ fun useHttps(sslSocketFactory: SSLSocketFactory) { this.sslSocketFactory = sslSocketFactory } /** * Configure the server to not perform SSL authentication of the client. This leaves * authentication to another layer such as in an HTTP cookie or header. This is the default and * most common configuration. */ fun noClientAuth() { this.clientAuth = CLIENT_AUTH_NONE }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
import okio.Buffer import okio.BufferedSource import okio.ByteString import okio.Source import okio.Timeout /** * Reads HTTP/2 transport frames. * * This implementation assumes we do not send an increased [frame][Settings.getMaxFrameSize] to the * peer. Hence, we expect all frames to have a max length of [Http2.INITIAL_MAX_FRAME_SIZE]. */ class Http2Reader( /** Creates a frame reader with max header table size of 4096. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 19.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
} @Test fun clientCloseCancelsConnectionAfterTimeout() { client.webSocket!!.close(1000, "Hello!") taskFaker.runTasks() // Note: we don't process server frames so our client 'close' doesn't receive a server 'close'. assertThat(client.canceled).isFalse() taskFaker.advanceUntil(ns(RealWebSocket.CANCEL_AFTER_CLOSE_MILLIS - 1)) assertThat(client.canceled).isFalse()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
/** * HTTP/2 only. Send a push promise header block. * * A push promise contains all the headers that pertain to a server-initiated request, and a * `promisedStreamId` to which response frames will be delivered. Push promise frames are sent as * a part of the response to `streamId`. The `promisedStreamId` has a priority of one greater than * `streamId`. * * @param streamId client-initiated stream ID. Must be an odd number.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 11.3K 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)