/** {@link BufferedReader} */
    protected final BufferedReader reader;

    /** The line that has been read */
    protected String line = EMPTY;

    /**
     * Returns an {@link Iterable} that wraps a {@link LineIterator} for use in enhanced for-loops.
     *
     * @param reader
     *            The {@link Reader} to read strings from. Must not be {@literal null}.
     * @return An {@link Iterable} that wraps a {@link LineIterator}.

        assertTrue(region.hasAccess(RdmaAccess.LOCAL_READ), "Should have local read access");
        assertTrue(region.hasAccess(RdmaAccess.LOCAL_WRITE), "Should have local write access");
        assertFalse(region.hasAccess(RdmaAccess.REMOTE_READ), "Should not have remote read access");

        // Test cleanup
        region.close();

        response = new Trans2QueryFSInformationResponse(config, FileSystemInformation.SMB_INFO_ALLOCATION);

        byte[] buffer = new byte[10];
        int read = response.readSetupWireFormat(buffer, 0, 10);

        assertEquals(0, read);
    }

    @Test
    void testReadParametersWireFormat() {
        // Test readParametersWireFormat returns 0

        // The content of these bytes is not critical for this test, only that 6 bytes are read.
        byte[] data = { 0x01, 0x02, 0x03, 0x04, 0x05, 0x06 }; // Sample 6 bytes
        ByteArrayInputStream bais = new ByteArrayInputStream(data);
        SessionRetargetResponsePacket packet = new SessionRetargetResponsePacket();

        // Create a buffer large enough to hold the read bytes
        byte[] buffer = new byte[6];

    class IntegrationTests {

        @Test
        @DisplayName("Should handle complete read-write cycle")
        void testCompleteReadWriteCycle() throws SMBProtocolDecodingException {
            // Given
            byte[] writeBuffer = new byte[100];
            byte[] readBuffer = new byte[100];

            // Prepare valid read buffer
            SMBUtil.writeInt2(4, readBuffer, 10);

}

type firstByteRecorder struct {
	t *time.Time
	r io.Reader
}

func (f *firstByteRecorder) Read(p []byte) (n int, err error) {
	if f.t != nil || len(p) == 0 {
		return f.r.Read(p)
	}
	// Read a single byte.
	n, err = f.r.Read(p[:1])
	if n > 0 {
		t := time.Now()
		f.t = &t
	}
	return n, err
}

// Runs the speedtest on local MinIO process.

    /**
     * Lock and read operation is supported capability.
     */
    int CAP_LOCK_AND_READ = 0x0100;
    /**
     * NT find operations are supported capability.
     */
    int CAP_NT_FIND = 0x0200;
    /**
     * DFS operations are supported capability.
     */
    int CAP_DFS = 0x1000;
    /**
     * Large read operations are supported capability.
     */

            assertEquals(49, SMBUtil.readInt2(buffer, 0)); // Structure size
            assertEquals(2, buffer[2]); // Padding
            assertEquals(0x01, buffer[3]); // Read flags
            assertEquals(4096, SMBUtil.readInt4(buffer, 4)); // Read length
            assertEquals(8192L, SMBUtil.readInt8(buffer, 8)); // Offset
            assertArrayEquals(testFileId, Arrays.copyOfRange(buffer, 16, 32)); // File ID

                        }
                        w.checkException();

                        if (read <= 0) {
                            break;
                        }

                        w.write(b[i], read, fos);
                    }

                    i = i == 1 ? 0 : 1;
                    off += read;
                }

                if (log.isDebugEnabled()) {

            beg_idx = (beg_idx + 1) % pipe_buf.length;
        }
        return result;
    }

    @Override
    public int read(final byte[] b) throws IOException {
        return read(b, 0, b.length);
    }

    @Override
    public int read(final byte[] b, int off, final int len) throws IOException {
        int result = -1;
        int i;

        if (len <= 0) {
            return 0;