}

    @Test
    @DisplayName("Should get path consumed")
    void testGetPathConsumed() {
        // Given
        int pathConsumed = 10;
        when(mockReferralData.getPathConsumed()).thenReturn(pathConsumed);

        // When
        int result = mockReferralData.getPathConsumed();

        // Then
        assertEquals(pathConsumed, result);
        verify(mockReferralData).getPathConsumed();

        this.timeoutSpecified = true;
        this.timeout = timeout;
    }

    /**
     * {@inheritDoc}
     *
     * @see jcifs.Encodable#encode(byte[], int)
     */
    @Override
    public int encode(final byte[] dst, int dstIndex) {
        final int start = dstIndex;
        SMBUtil.writeInt8(this.timeout, dst, dstIndex);
        dstIndex += 8;
        SMBUtil.writeInt4(this.nameBytes.length, dst, dstIndex);

     * {@code decode_out}.
     */
    private static class TestMessage extends DcerpcMessage {
        int decodedValue = 0;

        TestMessage() {
            /* nothing */
        }

        @Override
        public int getOpnum() {
            return 0x1234;
        }

        @Override
        public void encode_in(NdrBuffer buf) throws NdrException {

        final int boundarySize = boundary.length;
        final int limitSize = getBoundaryLimitSize();
        if (boundarySize > getBoundaryLimitSize()) {
            throwTooLongBoundarySizeException(contentType, boundarySize, limitSize);
        }
    }

    protected int getBoundaryLimitSize() {

    }

    @Test
    void constructor_shouldThrowSmbExceptionOnRpcError() throws IOException {
        // Arrange
        String server = "testServer";
        int access = 123;
        int errorCode = 12345;

        doAnswer(invocation -> {
            MsrpcLsarOpenPolicy2 rpc = invocation.getArgument(0);
            rpc.retval = errorCode; // Simulate RPC error
            return null;

    }

    class Hoge {
        private int i;

        private String s;

        /**
         * @param i
         *            the i to set
         */
        public void setI(final int i) {
            this.i = i;
        }

        /**
         * @return the i
         */
        public int getI() {
            return i;
        }

        /**

    }

    /**
     * Gets the return code.
     *
     * @return the return code
     */
    public int getReturnCode() {
        return returnCode;
    }

    /**
     * Sets the return code.
     *
     * @param returnCode the return code
     */
    public void setReturnCode(int returnCode) {
        this.returnCode = returnCode;
    }

    /**
     * Gets the recommended heartbeat interval.

    }

    /**
     * Gets the return code.
     *
     * @return the return code
     */
    public int getReturnCode() {
        return returnCode;
    }

    /**
     * Sets the return code.
     *
     * @param returnCode the return code
     */
    public void setReturnCode(int returnCode) {
        this.returnCode = returnCode;
    }

    /**
     * Gets the context handle.
     *

    /**
     * SMB 3.0 persistent handle - survives server reboot
     */
    PERSISTENT(3);

    private final int value;

    HandleType(int value) {
        this.value = value;
    }

    /**
     * Get the numeric value of this handle type
     * @return the numeric value
     */
    public int getValue() {
        return value;
    }

    /**
     * Get HandleType from numeric value

    }

    private void establishAdditionalChannels() {
        int currentChannels = channels.size();
        int targetChannels = Math.min(maxChannels, Math.min(localInterfaces.size(), remoteInterfaces.size()));

        for (int i = currentChannels; i < targetChannels; i++) {
            try {
                establishChannel(i);
            } catch (Exception e) {