// Given
        when(mockTreeHandle.isSMB2()).thenReturn(true);
        when(mockTreeHandle.getSendBufferSize()).thenReturn(65536);
        when(mockFileHandle.isValid()).thenReturn(false, true);
        when(mockFileHandle.getFileId()).thenReturn(new byte[16]);
        when(mockFileHandle.acquire()).thenReturn(mockFileHandle);

        doNothing().when(messageBlock).setMid(mid);
        doNothing().when(messageBlock).setCommand(command);
        doNothing().when(messageBlock).setUid(uid);
        doNothing().when(messageBlock).setSessionId(sessionId);
        doNothing().when(messageBlock).setExtendedSecurity(true);
        doNothing().when(messageBlock).setDigest(digest);
        doNothing().when(messageBlock).setResponse(response);

        when(response1.getNextResponse()).thenReturn(response2);
        when(response2.getNextResponse()).thenReturn(response3);
        when(response3.getNextResponse()).thenReturn(null);

        when(response1.isAsync()).thenReturn(false);
        when(response2.isAsync()).thenReturn(true);
        when(response3.isAsync()).thenReturn(false);

        // When - test chain navigation and properties

            when(mockNdrBuffer.dec_ndr_short()).thenReturn((int) (short) 0, (int) (short) 0);
            when(mockNdrBuffer.dec_ndr_long()).thenReturn(0); // Null referent pointer

            // When: Decoding the unicode string
            unicodeString.decode(mockNdrBuffer);

            // Then: Verify the decoding sequence and values
            verify(mockNdrBuffer).align(4);

        when(pipe.ensureTreeConnected()).thenReturn(tree);
        when(tree.acquire()).thenReturn(tree);
        when(tree.isSMB2()).thenReturn(true);
        when(pipe.openUnshared(anyString(), anyInt(), anyInt(), anyInt(), anyInt(), anyInt())).thenReturn(fileHandle);
        when(fileHandle.acquire()).thenReturn(fileHandle);
        when(fileHandle.getTree()).thenReturn(tree);

        long asyncId = 67890L;

        // When
        Smb2CancelRequest request = new Smb2CancelRequest(mockConfig, mid, asyncId);

        // Then
        assertEquals(SMB2_CANCEL, request.getCommand());
        assertEquals(mid, request.getMid());
        assertEquals(asyncId, request.getAsyncId());
        assertTrue((request.getFlags() & SMB2_FLAGS_ASYNC_COMMAND) != 0, "Async flag should be set when asyncId is non-zero");
    }

    @Test

    void testConstructorInitialization() {
        // Given
        int offset = 0;
        int length = TEST_DATA.length;

        // When
        transCallNamedPipe = new TransCallNamedPipe(mockConfig, TEST_PIPE_NAME, TEST_DATA, offset, length);

        // Then
        assertNotNull(transCallNamedPipe);
        assertEquals(SmbComTransaction.SMB_COM_TRANSACTION, transCallNamedPipe.getCommand());

            // When
            int result = response.writeBytesWireFormat(dst, 0);

            // Then
            assertEquals(0, result);
        }

        @Test
        @DisplayName("Should return 0 with null array")
        void testWriteBytesWireFormatWithNullArray() {
            // Given
            byte[] dst = null;

            // When

        SmbPipeInputStream stream = newStreamWithMinimalStubs(true);

        when(handle.ensureOpen()).thenReturn(fd);
        when(fd.getTree()).thenReturn(tree);
        when(tree.isSMB2()).thenReturn(true);
        when(tree.getConfig()).thenReturn(config);
        when(config.getTransactionBufferSize()).thenReturn(65535);
        when(tree.send(any(Smb2IoctlRequest.class), eq(RequestParam.NO_RETRY))).thenThrow(new SmbException("boom"));

    void getFlags_allFalse() {
        when(gssContext.getCredDelegState()).thenReturn(false);
        when(gssContext.getMutualAuthState()).thenReturn(false);
        when(gssContext.getReplayDetState()).thenReturn(false);
        when(gssContext.getSequenceDetState()).thenReturn(false);
        when(gssContext.getAnonymityState()).thenReturn(false);
        when(gssContext.getConfState()).thenReturn(false);