Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 821 for buffered (0.7 sec)

  1. 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)
  2. 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)
  3. 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)
  4. src/test/java/jcifs/internal/smb1/trans2/Trans2QueryPathInformationResponseTest.java

            for (int i = 8; i < 16; i++) {
                buffer[i] = (byte) (i * 2);
            }
    
            // Mock number of links (4 bytes)
            buffer[16] = 0x01;
            buffer[17] = 0x00;
            buffer[18] = 0x00;
            buffer[19] = 0x00;
    
            // Mock delete pending and directory flags
            buffer[20] = 0x00;
            buffer[21] = 0x00;
    
            return buffer;
        }
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 11.9K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. src/test/java/jcifs/internal/fscc/FileSystemInformationTest.java

                byte[] buffer = new byte[24];
                buffer[4] = 0x04; // sectPerAlloc = 4
                buffer[8] = 0x00;
                buffer[9] = 0x20; // alloc = 8192
                buffer[16] = 0x00;
                buffer[17] = 0x04; // bytesPerSect = 1024
    
                smbInfoAllocation.decode(buffer, 0, buffer.length);
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 18.1K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. 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)
Back to top