when(mockInputStream.read(any(byte[].class), anyInt(), anyInt())).thenReturn(2) // First read returns 2 bytes
                .thenReturn(2) // Second read returns 2 bytes
                .thenReturn(1); // Third read returns 1 byte

        byte[] buffer = new byte[10];
        int bytesRead = SessionServicePacket.readn(mockInputStream, buffer, 0, 5);

        assertEquals(5, bytesRead);

        do {
            if ((n = readn(in, sbuf, 0, 4)) < 4) {
                return null;
            }
        } while (sbuf[0] == (byte) 0x85); /* Dodge NetBIOS keep-alive */
        n = readn(in, sbuf, 4, 32);
        /* read smb header */
        if (n < 32) {
            return null;
        }
        if (LogStream.level >= 4) {
            log.println("New data read: " + this);

    static LogStream log = LogStream.getInstance();

    /**
     * Reads exactly len bytes from the input stream into the buffer.
     *
     * @param in the input stream to read from
     * @param b the buffer to read into
     * @param off the offset in the buffer to start writing
     * @param len the number of bytes to read
     * @return the number of bytes actually read
     * @throws IOException if an I/O error occurs
     */

    /**
     * Read bytes from the input stream into a buffer
     *
     * @param in the input stream to read from
     * @param b the buffer to read into
     * @param off the offset in the buffer to start writing
     * @param len the number of bytes to read
     * @return number of bytes read
     * @throws IOException if an I/O error occurs
     */

        int read3 = response.readBytesWireFormat(buffer, 0);

        // Then - all reads should return same result
        assertEquals(4, read1);
        assertEquals(4, read2);
        assertEquals(4, read3);
    }

    @Test
    @DisplayName("Should validate structure size before processing")
    void testStructureSizeValidation() {
        // Given various invalid structure sizes

            SMBUtil.writeInt2(4, buffer, 0);

            // When
            int read1 = response1.readBytesWireFormat(buffer, 0);
            int read2 = response2.readBytesWireFormat(buffer, 0);

            // Then
            assertEquals(4, read1);
            assertEquals(4, read2);
        }
    }

    @Nested
    @DisplayName("Edge case tests")
    class EdgeCaseTests {

            ChannelUtil.read(channel, buffer);
            return buffer.array();
        } finally {
            CloseableUtil.close(is);
        }
    }

    /**
     * Reads text from a file using the default encoding.
     *
     * @param path
     *            The file path. Must not be {@literal null} or empty.
     * @return The text read from the file.
     */

        // Test user boost
        item.setUserBoost(2.0f);
        assertEquals(2.0f, item.getUserBoost(), 0.001f);

        // Test readings
        String[][] newReadings = { { "read1", "read2" }, { "read3" } };
        item.setReadings(newReadings);
        assertArrayEquals(newReadings, item.getReadings());

        // Test fields
        String[] fields = { "field1", "field2" };

    }

    /**
     * Reads bytes from the file into the specified byte array.
     *
     * @param b the byte array to read data into
     * @return the number of bytes read, or -1 if end of file is reached
     * @throws SmbException if an I/O error occurs
     */
    public int read(final byte b[]) throws SmbException {
        return read(b, 0, b.length);
    }

    /**

    }

    /**
     * Calculate average read latency in microseconds
     *
     * @return average read latency
     */
    public double getAverageReadLatencyMicros() {
        long reads = rdmaReads.get();
        if (reads == 0) {
            return 0.0;
        }
        return totalReadTime.get() / (double) reads / 1000.0; // Convert to microseconds
    }

    /**