- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,765 for Pong (0.03 sec)
-
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
// At 0ms the server sends 3 unexpected pongs. The client accepts 'em and ignores em. server.webSocket!!.pong("pong 1".encodeUtf8()) client.processNextFrame() server.webSocket!!.pong("pong 2".encodeUtf8()) client.processNextFrame() taskFaker.runTasks() server.webSocket!!.pong("pong 3".encodeUtf8()) client.processNextFrame()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Apr 11 01:59:58 UTC 2024 - 18.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketReaderTest.kt
} @Test fun clientTwoFrameHelloWithPongs() { data.write("010348656c".decodeHex()) // Hel data.write("8a00".decodeHex()) // Pong data.write("8a00".decodeHex()) // Pong data.write("8a00".decodeHex()) // Pong data.write("8a00".decodeHex()) // Pong data.write("80026c6f".decodeHex()) // lo clientReader.processNextFrame() callback.assertPong(EMPTY) callback.assertPong(EMPTY)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 14.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/HeadersJvmTest.kt
.add("ping: pong ") // Value whitespace is trimmed. .add("kit:kat") // Space after colon is not required. .build() assertThat(headers.values("foo")).containsExactly("bar", "baz", "bak") assertThat(headers.values("key")).containsExactly("value") assertThat(headers.values("ping")).containsExactly("pong") assertThat(headers.values("kit")).containsExactly("kat") }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
peer.acceptFrame() // DEGRADED PING peer.acceptFrame() // AWAIT PING peer.sendFrame().ping(true, Http2Connection.DEGRADED_PING, 1) // DEGRADED PONG peer.sendFrame().ping(true, Http2Connection.AWAIT_PING, 0) // AWAIT PONG peer.play() // Play it back. val connection = connect(peer) val stream = connection.newStream(headerEntries("b", "banana"), false)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 75.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
private val pingIntervalMillis: Long, /** * For clients this is initially null, and will be assigned to the agreed-upon extensions. For * servers it should be the agreed-upon extensions immediately. */ private var extensions: WebSocketExtensions?, /** If compression is negotiated, outbound messages of this size and larger will be compressed. */ private var minimumDeflateSize: Long, private val webSocketCloseTimeout: Long,
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 01 14:21:25 UTC 2024 - 22.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketRecorder.kt
} fun assertPing(payload: ByteString) { assertThat(nextEvent()).isEqualTo(Ping(payload)) } fun assertPong(payload: ByteString) { assertThat(nextEvent()).isEqualTo(Pong(payload)) } fun assertClosing( code: Int, reason: String, ) { assertThat(nextEvent()).isEqualTo(Closing(code, reason)) } fun assertClosed( code: Int,
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 6.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
* To differentiate the two cases we ping the server when a stream times out. If the overall * connection is fine the ping will receive a pong; otherwise it won't. * * The deadline to respond to this ping attempts to limit the cost of being wrong. If it is too * long, streams created while we await the pong will reuse broken connections and inevitably * fail. If it is too short, slow connections will be marked as failed and extra TCP and TLS
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0) -
internal/grid/connection.go
return } // Single calls do not support pinging. if v, ok := c.inStream.Load(m.MuxID); ok { pong := v.ping(m.Seq) pong.T = ping.T gridLogIf(ctx, c.queueMsg(m, &pong)) } else { pong := pongMsg{NotFound: true, T: ping.T} gridLogIf(ctx, c.queueMsg(m, &pong)) } return } func (c *Connection) handleDisconnectClientMux(m message) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 46.7K bytes - Viewed (0) -
internal/grid/muxclient.go
case m.outBlock <- struct{}{}: default: gridLogIf(m.ctx, errors.New("output unblocked overflow")) } } func (m *muxClient) pong(msg pongMsg) { if msg.NotFound || msg.Err != nil { err := errors.New("remote terminated call") if msg.Err != nil { err = fmt.Errorf("remove pong failed: %v", &msg.Err) } m.addResponse(Response{Err: err}) return } atomic.StoreInt64(&m.LastPong, time.Now().UnixNano())
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketWriter.kt
class WebSocketWriter( private val isClient: Boolean, val sink: BufferedSink, val random: Random, private val perMessageDeflate: Boolean, private val noContextTakeover: Boolean, private val minimumDeflateSize: Long, ) : Closeable { /** This holds outbound data for compression and masking. */ private val messageBuffer = Buffer() /** The [Buffer] of [sink]. Write to this and then flush/emit [sink]. */
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.9K bytes - Viewed (0)