setField(transport, "negotiated", nego);

            byte[] input = new byte[] { 10, 20, 30, 40 };
            byte[] hash1 = transport.calculatePreauthHash(input, 0, input.length, null);
            assertNotNull(hash1);
            assertEquals(64, hash1.length, "SHA-512 size");

            byte[] hash2 = transport.calculatePreauthHash(new byte[] { 50 }, 0, 1, hash1);
            assertNotNull(hash2);

    void testSetSecurityFlags() {
        request = new Smb2CreateRequest(mockConfig, "test.txt");

        request.setSecurityFlags((byte) 0x01);
        // Verify through writeBytesWireFormat
        byte[] buffer = new byte[1024];
        request.writeBytesWireFormat(buffer, 0);
        assertEquals((byte) 0x01, buffer[2]);
    }

    @Test
    @DisplayName("Test oplock level setter")
    void testSetRequestedOplockLevel() {

            // Test with different fileId patterns
            byte[] zeroFileId = new byte[16];
            Smb2CloseResponse zeroIdResponse = new Smb2CloseResponse(mockConfig, zeroFileId, testFileName);
            assertArrayEquals(zeroFileId, zeroIdResponse.getFileId());

            byte[] maxFileId = new byte[16];
            Arrays.fill(maxFileId, (byte) 0xFF);

            // Test all known constants
            byte[] classes = { FileSystemInformation.SMB_INFO_ALLOCATION, FileSystemInformation.FS_SIZE_INFO,
                    FileSystemInformation.FS_FULL_SIZE_INFO, (byte) 0, (byte) 1, (byte) 127, (byte) -128 };

            for (byte fsClass : classes) {
                TestAllocInfo allocInfo = new TestAllocInfo(1024L, 512L, fsClass);

	r := NewReader([]byte(data))
	if got, want := r.Len(), 11; got != want {
		t.Errorf("r.Len(): got %d, want %d", got, want)
	}
	if n, err := r.Read(make([]byte, 10)); err != nil || n != 10 {
		t.Errorf("Read failed: read %d %v", n, err)
	}
	if got, want := r.Len(), 1; got != want {
		t.Errorf("r.Len(): got %d, want %d", got, want)
	}
	if n, err := r.Read(make([]byte, 1)); err != nil || n != 1 {

    private int readSize;
    private boolean async;
    private int treeId;
    private long mid, asyncId, sessionId;
    private byte errorContextCount;
    private byte[] errorData;

    private boolean retainPayload;
    private byte[] rawPayload;

    private ServerMessageBlock2 next;

    /**
     * Constructor for SMB2 message block with configuration.
     *
     * @param config the configuration object

        assertEquals(0, dst[2], "Third byte should be 0 (no FID)");
        assertEquals(0, dst[3], "Fourth byte should be 0 (no FID)");
    }

    @Test
    public void testReadSetupWireFormat() {
        // Test the readSetupWireFormat method
        TransWaitNamedPipe pipe = new TransWaitNamedPipe("\\\\pipe\\testPipe");
        byte[] buffer = new byte[10];

        // The implementation always returns 0

     * Gets the flags as an integer value
     * @return flags
     */
    public int getFlags() {
        return SMBUtil.readInt4(this.getRaw(), 0);
    }

    private static byte[] encode(final int flags) {
        final byte[] raw = new byte[4];
        SMBUtil.writeInt4(flags, raw, 0);
        return raw;
    }

@Beta
public interface PrimitiveSink {
  /**
   * Puts a byte into this sink.
   *
   * @param b a byte
   * @return this instance
   */
  @CanIgnoreReturnValue
  PrimitiveSink putByte(byte b);

  /**
   * Puts an array of bytes into this sink.
   *
   * @param bytes a byte array
   * @return this instance
   */
  @CanIgnoreReturnValue
  PrimitiveSink putBytes(byte[] bytes);

  /**

func (x *xlMetaInlineData) replace(key string, value []byte) {
	in := x.afterVersion()
	sz, buf, _ := msgp.ReadMapHeaderBytes(in)
	keys := make([][]byte, 0, sz+1)
	vals := make([][]byte, 0, sz+1)

	// Version plus header...
	plSize := 1 + msgp.MapHeaderSize
	replaced := false
	for range sz {
		var found, foundVal []byte
		var err error
		found, buf, err = msgp.ReadMapKeyZC(buf)