- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 7,665 for writePing (0.2 sec)
-
okhttp/src/test/java/okhttp3/internal/ws/WebSocketWriterTest.kt
clientWriter.writePing("Hello".encodeUtf8()) assertData("898560b420bb28d14cd70f") } @Test fun serverEmptyPong() { serverWriter.writePong(EMPTY) assertData("8a00") } @Test fun clientEmptyPong() { clientWriter.writePong(EMPTY) assertData("8a8060b420bb") } @Test fun serverPongWithPayload() { serverWriter.writePong("Hello".encodeUtf8()) assertData("8a0548656c6c6f")
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
@Throws(InterruptedException::class) fun writePingAndAwaitPong() { writePing() awaitPong() } /** For testing: sends a ping to be awaited with [awaitPong]. */ @Throws(InterruptedException::class) fun writePing() { this.withLock { awaitPingsSent++ } // 0x4f 0x4b 0x6f 0x6b is "OKok". writePing(false, AWAIT_PING, 0x4f4b6f6b) } /** For testing: awaits a pong. */
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/main/kotlin/okhttp3/internal/ws/WebSocketWriter.kt
/** Send a ping with the supplied [payload]. */ @Throws(IOException::class) fun writePing(payload: ByteString) { writeControlFrame(OPCODE_CONTROL_PING, payload) } /** Send a pong with the supplied [payload]. */ @Throws(IOException::class) fun writePong(payload: ByteString) { writeControlFrame(OPCODE_CONTROL_PONG, payload) } /**
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
"${pingIntervalMillis}ms (after ${failedPing - 1} successful ping/pongs)", ), isWriter = true, ) return } try { writer.writePing(ByteString.EMPTY) } catch (e: IOException) { failWebSocket(e = e, isWriter = true) } } fun failWebSocket( e: Exception, response: Response? = null,
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 22.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
connection.withLock { if (!connection.isHealthy(System.nanoTime())) { throw ConnectionShutdownException() } } connection.writePing() connection.shutdown(ErrorCode.PROTOCOL_ERROR) assertThat(connection.openStreamCount()).isEqualTo(1) connection.awaitPong() // Prevent the peer from exiting prematurely.
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) -
android/guava/src/com/google/common/io/LittleEndianDataOutputStream.java
* little-endian byte order. * * @throws IOException if an I/O error occurs */ @Override public void writeLong(long v) throws IOException { byte[] bytes = Longs.toByteArray(Long.reverseBytes(v)); write(bytes, 0, bytes.length); } /** * Writes a {@code short} as specified by {@link DataOutputStream#writeShort(int)}, except using
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed May 17 14:35:11 GMT 2023 - 5.2K bytes - Viewed (0) -
android/guava/src/com/google/common/io/ByteArrayDataOutput.java
void writeBoolean(boolean v); @Override void writeByte(int v); @Override void writeShort(int v); @Override void writeChar(int v); @Override void writeInt(int v); @Override void writeLong(long v); @Override void writeFloat(float v); @Override void writeDouble(double v); @Override void writeChars(String s); @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 28 20:13:02 GMT 2023 - 2K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/FakeDns.kt
nextAddress += count return (from until nextAddress) .map { return@map InetAddress.getByAddress( Buffer().writeLong(0L).writeLong(it).readByteArray(), ) } }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/ByteStreamsTest.java
} public void testNewDataOutput_writeInt() { ByteArrayDataOutput out = ByteStreams.newDataOutput(); out.writeInt(0x12345678); out.writeInt(0x76543210); assertThat(out.toByteArray()).isEqualTo(bytes); } public void testNewDataOutput_sized() { ByteArrayDataOutput out = ByteStreams.newDataOutput(4); out.writeInt(0x12345678); out.writeInt(0x76543210);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 21.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/LittleEndianDataOutputStreamTest.java
out.writeByte(100); out.writeByte(-100); out.writeByte((byte) 200); out.writeChar('a'); out.writeShort((short) -30000); out.writeShort((short) 50000); out.writeInt(0xCAFEBABE); out.writeLong(0xDEADBEEFCAFEBABEL); out.writeUTF("Herby Derby"); out.writeFloat(Float.intBitsToFloat(0xCAFEBABE)); out.writeDouble(Double.longBitsToDouble(0xDEADBEEFCAFEBABEL));
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 4.7K bytes - Viewed (0)