- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 108 for pins (0.03 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
private var failed = false /** Total number of pings sent by this web socket. */ private var sentPingCount = 0 /** Total number of pings received by this web socket. */ private var receivedPingCount = 0 /** Total number of pongs received by this web socket. */ private var receivedPongCount = 0 /** True if we have sent a ping that is still awaiting a reply. */ private var awaitingPong = false
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/RealWebSocketTest.kt
// After 500ms the client automatically pings and the server pongs back. taskFaker.advanceUntil(ns(500L)) server.processNextFrame() // Ping. client.processNextFrame() // Pong. // After 1000ms the client will attempt a ping 2, but we don't process it. That'll cause the // client to fail at 1500ms when it's time to send ping 3 because pong 2 hasn't been received. taskFaker.advanceUntil(ns(1000L))
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/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]. */
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
assertThat(server.receivedPongCount()).isEqualTo(0) closeWebSockets(webSocket, server) } /** * Configure the websocket to send pings every 500 ms. Artificially prevent the server from * responding to pings. The client should give up when attempting to send its 2nd ping, at about * 1000 ms. */ @Test fun unacknowledgedPingFailsConnection() { assumeNotWindows() client =
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Mar 31 17:16:15 UTC 2024 - 35.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/base/VerifyTest.java
public String toString() { throw new AssertionFailedError(); } }; private static final String FORMAT = "I ate %s pies."; private static void checkMessage(Exception e) { assertThat(e).hasMessageThat().isEqualTo("I ate 5 pies."); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Sep 17 18:14:12 UTC 2024 - 3.2K bytes - Viewed (0) -
cmd/tier-last-day-stats_gen.go
// map header, size 2 // write "Bins" err = en.Append(0x82, 0xa4, 0x42, 0x69, 0x6e, 0x73) if err != nil { return } err = en.WriteArrayHeader(uint32(24)) if err != nil { err = msgp.WrapError(err, "Bins") return } for za0001 := range z.Bins { err = z.Bins[za0001].EncodeMsg(en) if err != nil { err = msgp.WrapError(err, "Bins", za0001) return } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Mar 21 17:21:35 UTC 2024 - 9.3K bytes - Viewed (0) -
cmd/tier-last-day-stats.go
l.UpdatedAt = t // update to the latest time index if since >= 24 { l.Bins = [24]tierStats{} return } for lastIdx != idx { lastIdx = (lastIdx + 1) % 24 l.Bins[lastIdx] = tierStats{} } } func (l *lastDayTierStats) clone() lastDayTierStats { clone := lastDayTierStats{ UpdatedAt: l.UpdatedAt, } copy(clone.Bins[:], l.Bins[:]) return clone }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 2.8K 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)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 75.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/PingSearchEngineJob.java
} } resultBuf.append("Status of ").append(ping.getClusterName()).append(" is changed to ").append(ping.getClusterStatus()) .append('.'); } else if (status == 0) { resultBuf.append(ping.getClusterName()).append(" is alive."); } else { resultBuf.append(ping.getClusterName()).append(" is not available."); }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 4.1K 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)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 75.3K bytes - Viewed (0)