- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 26 for Ping (0.26 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
payload2: Int, ) { try { writer.ping(reply, payload1, payload2) } catch (e: IOException) { failConnection(e) } } /** For testing: sends a ping and waits for a pong. */ @Throws(InterruptedException::class) fun writePingAndAwaitPong() { writePing() awaitPong() } /** For testing: sends a ping to be awaited with [awaitPong]. */
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
peer.sendFrame().ping(false, 2, 3) peer.acceptFrame() // PING peer.play() // Play it back. connect(peer) // Verify the peer received what was expected. val ping = peer.takeFrame() assertThat(ping.type).isEqualTo(Http2.TYPE_PING) assertThat(ping.streamId).isEqualTo(0) assertThat(ping.payload1).isEqualTo(2) assertThat(ping.payload2).isEqualTo(3)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
taskFaker.advanceUntil(ns(500L)) server.processNextFrame() // Ping. client.processNextFrame() // Pong. taskFaker.advanceUntil(ns(1000L)) server.processNextFrame() // Ping. client.processNextFrame() // Pong. taskFaker.advanceUntil(ns(1500L)) server.processNextFrame() // Ping. client.processNextFrame() // Pong. } @Test
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
sink.writeInt(settings[i]) } sink.flush() } } /** * Send a connection-level ping to the peer. `ack` indicates this is a reply. The data in * `payload1` and `payload2` opaque binary, and there are no rules on the content. */ @Throws(IOException::class) fun ping( ack: Boolean, payload1: Int, payload2: Int, ) { this.withLock {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 11.3K bytes - Viewed (0) -
internal/event/target/postgresql.go
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 24 17:51:07 GMT 2024 - 13.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
* Sets the interval between HTTP/2 and web socket pings initiated by this client. Use this to * automatically send ping frames until either the connection fails or it is closed. This keeps * the connection alive and may detect connectivity failures. * * If the server does not respond to each ping with a pong within `interval`, this client will
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 06 04:21:33 GMT 2024 - 52K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
assertThat(response.protocol).isEqualTo(protocol) // Confirm a single ping was sent and received, and its reply was sent and received. val logs = testLogHandler.takeAll() assertThat(countFrames(logs, "FINE: >> 0x00000000 8 PING ")) .isEqualTo(1) assertThat(countFrames(logs, "FINE: << 0x00000000 8 PING ")) .isEqualTo(1)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 75.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
val settings1 = Settings() settings1[Settings.MAX_CONCURRENT_STREAMS] = maxConcurrentStreams peer.sendFrame().settings(settings1) peer.acceptFrame() // ACK peer.sendFrame().ping(false, 2, 0) peer.acceptFrame() // PING peer.play() // Play it back. val connection = Http2Connection.Builder(true, TaskRunner.INSTANCE) .socket(peer.openSocket())
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
if peer == nil { continue } peer.Listen(ctx, mergeCh, values) } var ( emptyEventTicker <-chan time.Time keepAliveTicker <-chan time.Time ) if p := values.Get("ping"); p != "" { pingInterval, err := strconv.Atoi(p) if err != nil { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidQueryParams), r.URL) return } if pingInterval < 1 {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0)