byte[] buffer = { 0x00, 0x00, // status = 0 (Success)
                0x12, 0x34, // converter = 0x3412
                0x02, 0x00, // numEntries = 2
                0x05, 0x00 // totalAvailableEntries = 5
        };

        int bytesRead = response.readParametersWireFormat(buffer, 0, buffer.length);

        assertEquals(8, bytesRead, "Should read 8 bytes for parameters.");

            assertEquals(5120L, SMBUtil.readInt8(buffer, offset + 8));
            assertEquals(8192, SMBUtil.readInt4(buffer, offset + 16));

            offset += CHUNK_SIZE;
            assertEquals(12288L, SMBUtil.readInt8(buffer, offset));
            assertEquals(13312L, SMBUtil.readInt8(buffer, offset + 8));
            assertEquals(16384, SMBUtil.readInt4(buffer, offset + 16));
        }

        // Verify by writing to buffer and checking the fileIndex position
        byte[] buffer = new byte[1024];
        request.writeBytesWireFormat(buffer, Smb2Constants.SMB2_HEADER_LENGTH);

        // FileIndex is at offset 4 in the request structure
        int readIndex = (buffer[Smb2Constants.SMB2_HEADER_LENGTH + 4] & 0xFF) | ((buffer[Smb2Constants.SMB2_HEADER_LENGTH + 5] & 0xFF) << 8)

        // Test encoding
        byte[] buffer = new byte[200];
        int bytesEncoded = request.encode(buffer, 0);

        // Verify proper encoding
        assertEquals(14 + nameBytes.length, bytesEncoded);
        assertEquals(30000L, SMBUtil.readInt8(buffer, 0));
        assertEquals(nameBytes.length, SMBUtil.readInt4(buffer, 8));
        assertEquals(0x1, buffer[12]); // Timeout specified

        // Verify pipe name

package okhttp3.logging.internal

import java.io.EOFException
import okio.Buffer

/**
 * Returns true if the body in question probably contains human readable text. Uses a small
 * sample of code points to detect unicode control characters commonly used in binary file
 * signatures.
 */
fun Buffer.isProbablyUtf8(): Boolean {
  try {
    val prefix = Buffer()
    val byteCount = size.coerceAtMost(64)
    copyTo(prefix, 0, byteCount)

            int bytesDecoded = buffer.decode(testBuffer, 0, testBuffer.length);

            assertEquals(8, bytesDecoded);
            assertEquals(0, buffer.getPathConsumed());
            assertEquals(0, buffer.getNumReferrals());
            assertEquals(0, buffer.getTflags());
            assertNotNull(buffer.getReferrals());
            assertEquals(0, buffer.getReferrals().length);
        }

        @Test

            assertEquals(2, buffer[0]); // cipher count (little endian)
            assertEquals(0, buffer[1]);
            assertEquals(1, buffer[2]); // AES128_CCM (little endian)
            assertEquals(0, buffer[3]);
            assertEquals(2, buffer[4]); // AES128_GCM (little endian)
            assertEquals(0, buffer[5]);
        }

        @Test

	v := ActiveWorkerStat{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	en := msgp.NewWriter(msgp.Nowhere)
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		v.EncodeMsg(en)
	}
	en.Flush()
}

func BenchmarkDecodeActiveWorkerStat(b *testing.B) {
	v := ActiveWorkerStat{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))

        // Prepare buffer with offset
        long expectedValue = 0xAAAABBBBCCCCDDDDL;
        byte[] buffer = new byte[20];
        int offset = 7;
        SMBUtil.writeInt8(expectedValue, buffer, offset);

        // Decode from offset
        int bytesRead = fileInfo.decode(buffer, offset, buffer.length - offset);

        assertEquals(8, bytesRead);

    void testReadSetupWireFormat() {
        netShareEnum = new NetShareEnum(realConfig);
        byte[] buffer = new byte[100];

        int result = netShareEnum.readSetupWireFormat(buffer, 0, 100);
        assertEquals(0, result);

        // Test with different parameters
        result = netShareEnum.readSetupWireFormat(buffer, 10, 50);
        assertEquals(0, result);

        // Test with zero length