* @param off offset in the buffer
     * @param length maximum length to receive
     * @return number of bytes received
     * @throws IOException if an I/O error occurs
     */
    int recv(byte[] buf, int off, int length) throws IOException;

    /**
     * Send data to the pipe
     *
     * @param buf buffer containing data to send
     * @param off offset in the buffer

        assertEquals(0, ndrBuffer.index);
        assertEquals(0, ndrBuffer.length);
        assertSame(ndrBuffer, ndrBuffer.deferred);
        assertSame(buffer, ndrBuffer.buf);

        // Test with a different start offset
        NdrBuffer offsetBuffer = new NdrBuffer(buffer, 10);
        assertEquals(10, offsetBuffer.start);
        assertEquals(10, offsetBuffer.index);
        assertEquals(0, offsetBuffer.length);
    }

    @Test

				done <- true
			}(j, ft)
			n++
		}
	}
	for ; n > 0; n-- {
		<-done
	}
}

func equalTimeAndZone(t1, t2 time.Time) bool {
	name1, offset1 := t1.Zone()
	name2, offset2 := t2.Zone()
	return t1.Equal(t2) && name1 == name2 && offset1 == offset2
}

func readTestFile(t *testing.T, zt ZipTest, ft ZipTestFile, f *File, raw []byte) {
	if f.Name != ft.Name {
		t.Errorf("name=%q, want %q", f.Name, ft.Name)

auto;width:91.66666667%}.col-sm-12{flex:0 0 auto;width:100%}.offset-sm-0{margin-left:0}.offset-sm-1{margin-left:8.33333333%}.offset-sm-2{margin-left:16.66666667%}.offset-sm-3{margin-left:25%}.offset-sm-4{margin-left:33.33333333%}.offset-sm-5{margin-left:41.66666667%}.offset-sm-6{margin-left:50%}.offset-sm-7{margin-left:58.33333333%}.offset-sm-8{margin-left:66.66666667%}.offset-sm-9{margin-left:75%}.offset-sm-10{margin-left:83.33333333%}.offset-sm-11{margin-left:91.66666667%}.g-sm-0,.gx-sm-0{--bs-gut...

    void testDecodeWithNonZeroBufferIndex() throws SMBProtocolDecodingException {
        // Prepare test data with offset
        int offset = 10;
        byte[] buffer = new byte[34]; // 10 offset + 16 header + 8 data
        int bufferIndex = offset;

        // Set up test values
        int namedPipeState = 0x02;
        int readDataAvailable = 256;
        int numberOfMessages = 5;

    private String readString(byte[] buffer, int offset, int maxLength) {
        int length = 0;
        for (int i = offset; i < offset + maxLength && i < buffer.length; i++) {
            if (buffer[i] == 0) {
                break;
            }
            length++;
        }
        return new String(buffer, offset, length);
    }

    }

    /**
     * Decode from byte array
     *
     * @param data source data
     * @param offset starting offset
     * @return decoded response
     */
    public static SmbDirectNegotiateResponse decode(byte[] data, int offset) {
        if (data.length - offset < 32) {
            throw new IllegalArgumentException("Invalid SMB Direct Negotiate Response length");
        }

		t.Errorf("ReadRune: got %d, %d, %v; want 0, 0, io.EOF", ch, size, err)
	}

	if offset, err := (&Reader{}).Seek(11, io.SeekStart); offset != 11 || err != nil {
		t.Errorf("Seek: got %d, %v; want 11, nil", offset, err)
	}

	if s := (&Reader{}).Size(); s != 0 {
		t.Errorf("Size: got %d, want 0", s)
	}

	if (&Reader{}).UnreadByte() == nil {

     * @param offset the starting position in the array
     * @param length the number of hex digits to convert
     * @return the integer value of the hex digits
     */
    public static int hex_to_bin(final char[] arr, final int offset, final int length) {
        int value = 0;
        int ai, count;

        count = 0;
        for (ai = offset; ai < arr.length && count < length; ai++) {

        @Test
        @DisplayName("Should handle maximum offset")
        void testWriteBytesAtMaxOffset() {
            byte[] buffer = new byte[1000];
            int offset = buffer.length - 4;

            int bytesWritten = echoRequest.writeBytesWireFormat(buffer, offset);

            assertEquals(4, bytesWritten);
            assertEquals(4, SMBUtil.readInt2(buffer, offset));
        }
    }

    @Nested