- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 821 for buffered (0.7 sec)
-
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/CancelTest.kt
this.connectionType = mode.second if (connectionType == H2) { platform.assumeHttp2Support() } // Sockets on some platforms can have large buffers that mean writes do not block when // required. These socket factories explicitly set the buffer sizes on sockets created. server = MockWebServer() server.serverSocketFactory = object : DelegatingServerSocketFactory(ServerSocketFactory.getDefault()) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 9.8K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestUtilJvm.kt
* Use this method to create a degenerate Okio Buffer where each byte is in a separate segment of * the internal list. */ @JvmStatic fun fragmentBuffer(buffer: Buffer): Buffer { // Write each byte into a new buffer, then clone it so that the segments are shared. // Shared segments cannot be compacted so we'll get a long chain of short segments. val result = Buffer() while (!buffer.exhausted()) { val box = Buffer()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 4.3K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketWriterTest.kt
// Create a payload which will overflow the normal payload byte size. val payload = Buffer() while (payload.completeSegmentByteCount() <= PAYLOAD_BYTE_MAX) { payload.writeByte('0'.code) } serverWriter.writeMessageFrame(OPCODE_BINARY, payload.snapshot()) // Write directly to the unbuffered sink. This ensures it will become single frame. assertData("827e") // 'e' == 4-byte follow-up length.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 9.3K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb1/trans2/Trans2QueryPathInformationResponseTest.java
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 11.9K bytes - Viewed (0) -
guava/src/com/google/common/io/CharStreams.java
to.append(buf); total += buf.remaining(); Java8Compatibility.clear(buf); } return total; } // TODO(lukes): consider allowing callers to pass in a buffer to use, some callers would be able // to reuse buffers, others would be able to size them more appropriately than the constant // defaults /** * Copies all characters between the {@link Reader} and {@link StringBuilder} objects. Does not
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 30 17:25:01 UTC 2025 - 10.9K bytes - Viewed (0) -
src/test/java/jcifs/dcerpc/ndr/NdrBufferTest.java
assertEquals((byte) 0xEF, buffer[0]); // Little-endian assertEquals((byte) 0xCD, buffer[1]); assertEquals((byte) 0xAB, buffer[2]); assertEquals((byte) 0x89, buffer[3]); assertEquals((byte) 0x67, buffer[4]); assertEquals((byte) 0x45, buffer[5]); assertEquals((byte) 0x23, buffer[6]); assertEquals((byte) 0x01, buffer[7]); ndrBuffer.setIndex(0);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 14.3K bytes - Viewed (0) -
src/test/java/jcifs/internal/fscc/FileSystemInformationTest.java
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 18.1K bytes - Viewed (0) -
src/test/java/jcifs/internal/dtyp/SecurityDescriptorTest.java
buffer[offset + 2] = 0x00; buffer[offset + 3] = 0x00; buffer[offset + 4] = 0x00; buffer[offset + 5] = 0x00; buffer[offset + 6] = 0x00; buffer[offset + 7] = 0x01; // Sub-authority SMBUtil.writeInt4(0, buffer, offset + 8); } private void prepareDaclHeader(byte[] buffer, int offset, int aceCount) { buffer[offset] = 0x02; // revision
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 18.6K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/Smb2EncryptionContextTest.java
// For GCM, last 4 bytes should contain incrementing counter ByteBuffer buffer1 = ByteBuffer.wrap(nonce1, 12, 4).order(java.nio.ByteOrder.LITTLE_ENDIAN); ByteBuffer buffer2 = ByteBuffer.wrap(nonce2, 12, 4).order(java.nio.ByteOrder.LITTLE_ENDIAN); int counter1 = buffer1.getInt(); int counter2 = buffer2.getInt(); assertEquals(counter1 + 1, counter2, "Counter should increment between nonces");
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 44.1K bytes - Viewed (0) -
src/test/java/jcifs/smb/MIENameTest.java
return buf; }, StringIndexOutOfBoundsException.class)); } @ParameterizedTest(name = "{0}") @MethodSource("invalidBuffers") @DisplayName("Invalid buffers throw appropriate exceptions") void invalidInputsThrow(String name, Object bufferSupplierOrBytes, Class<? extends Throwable> expected) { // Arrange byte[] buf;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 8.6K bytes - Viewed (0)