int maxInput = 2048;

        request.setMaxInputResponse(maxInput);

        assertNotNull(request);
    }

    @Test
    @DisplayName("Test setMaxOutputResponse method")
    void testSetMaxOutputResponse() {
        setupMockConfig();
        Smb2IoctlRequest request = new Smb2IoctlRequest(mockConfig, TEST_CONTROL_CODE);
        int maxOutput = 4096;

    }

    /**
     * Gets the lease epoch from the V2 response
     * @return the epoch
     */
    public int getEpoch() {
        return epoch;
    }

    @Override
    public int decode(byte[] buffer, int bufferIndex, int len) throws SMBProtocolDecodingException {
        int start = bufferIndex;

        if (len < 52) {

    }

    @Override
    protected int writeParameterWordsWireFormat(final byte[] dst, final int dstIndex) {
        return 0;
    }

    @Override
    protected int writeBytesWireFormat(final byte[] dst, final int dstIndex) {
        return 0;
    }

    @Override
    protected int readParameterWordsWireFormat(final byte[] buffer, int bufferIndex) {
        final int start = bufferIndex;

    }

    @Override
    int writeBodyWireFormat(final byte[] dst, final int dstIndex) {
        return writeQuestionSectionWireFormat(dst, dstIndex);
    }

    @Override
    int readBodyWireFormat(final byte[] src, final int srcIndex) {
        return readQuestionSectionWireFormat(src, srcIndex);
    }

    @Override
    int writeRDataWireFormat(final byte[] dst, final int dstIndex) {
        return 0;
    }

    SmbComWriteAndXResponse() {
    }

    @Override
    int writeParameterWordsWireFormat(final byte[] dst, final int dstIndex) {
        return 0;
    }

    @Override
    int writeBytesWireFormat(final byte[] dst, final int dstIndex) {
        return 0;
    }

    @Override
    int readParameterWordsWireFormat(final byte[] buffer, final int bufferIndex) {
        count = readInt2(buffer, bufferIndex) & 0xFFFFL;

        SuggestSettings settings = suggester.settings();
        int num = 10000;

        addDocument(indexName, client, num);

        ESSourceReader reader = new ESSourceReader(client, settings, indexName);
        reader.setScrollSize(1000);
        reader.addSort(SortBuilders.fieldSort("field2"));
        int count = 0;
        int prev = -1;
        Map<String, Object> source;

     * time they are accessed. The value "never" should be used to describe
     * archived URLs.
     *
     * Please note that the value of this tag is considered a hint and not a
     * command. Even though search engine crawlers may consider this information
     * when making decisions, they may crawl pages marked "hourly" less

        int written = response.writeDataWireFormat(buffer, 0);

        assertEquals(0, written);
    }

    @Test
    void testReadSetupWireFormat() {
        // Test readSetupWireFormat returns 0
        response = new Trans2QueryFSInformationResponse(config, FileSystemInformation.SMB_INFO_ALLOCATION);

        byte[] buffer = new byte[10];

    void testHandleLeaseBreak() {
        String path = "/share/file.txt";
        int initialState = Smb2LeaseState.SMB2_LEASE_FULL;
        int newState = Smb2LeaseState.SMB2_LEASE_READ_CACHING;

        Smb2LeaseKey key = leaseManager.requestLease(path, initialState);
        leaseManager.updateLease(key, initialState);

        int initialEpoch = leaseManager.getLease(key).getEpoch();

    public static final int SEQUENCE_CHECKING = 0x10;
    /**
     * Context flag for anonymity capability
     */
    public static final int ANONYMITY = 0x08;
    /**
     * Context flag for confidentiality (encryption) capability
     */
    public static final int CONFIDENTIALITY = 0x04;
    /**
     * Context flag for integrity (signing) capability
     */
    public static final int INTEGRITY = 0x02;