fileFsSizeInfo.decode(buffer1.array(), 0, 24);
            long firstCapacity = fileFsSizeInfo.getCapacity();
            long firstFree = fileFsSizeInfo.getFree();

            // When - second decode with different values
            ByteBuffer buffer2 = ByteBuffer.allocate(24);
            buffer2.order(ByteOrder.LITTLE_ENDIAN);
            buffer2.putLong(2000L);
            buffer2.putLong(1500L);

        AtomicInteger calls = new AtomicInteger();
        doAnswer(inv -> {
            int len = inv.getArgument(2);
            // First call returns len-1, second returns 1
            return calls.getAndIncrement() == 0 ? Math.max(1, len - 1) : 1;
        }).when(raf).read(any(byte[].class), anyInt(), anyInt());
        byte[] dst = new byte[4];

query.highlight.number.of.fragments=2
# Type of query highlighting.
query.highlight.type=fvh
# Tag to use before highlighted text.
query.highlight.tag.pre=<strong>
# Tag to use after highlighted text.
query.highlight.tag.post=</strong>
# Boundary characters for query highlighting.
query.highlight.boundary.chars=u0009u000Au0013u0020
# Maximum scan for query highlight boundaries.
query.highlight.boundary.max.scan=20

     */
    protected long witnessRegistrationTimeout = 300000; // 5 minutes
    /**
     * Delay in milliseconds before attempting witness reconnection
     */
    protected long witnessReconnectDelay = 1000; // 1 second
    /**
     * Flag indicating whether automatic witness service discovery is enabled
     */
    protected boolean witnessServiceDiscovery = true;

    // SMB3 Lease support

            assertEquals(1000, response.getAllocationSize());
            assertEquals(500, response.getEndOfFile());
            assertEquals(0x01, response.getFileAttributes());

            // Second read with different values
            byte[] buffer2 = new byte[60];
            SMBUtil.writeInt2(60, buffer2, 0);
            SMBUtil.writeInt2(2, buffer2, 2);
            SMBUtil.writeInt8(2000, buffer2, 40);

        if (spToken instanceof final NegTokenTarg targ) {
            if (targ.getResult() == NegTokenTarg.ACCEPT_COMPLETED && this.mechContext.isEstablished()) {
                // server sent final token
                verifyMechListMIC(targ.getMechanismListMIC());
                if (!this.disableMic || this.requireMic) {
                    mechMIC = calculateMechListMIC();
                }

success.upload_elevate_word = Uploaded an elevate word file.
success.upload_bad_word = Uploaded a bad word file.
success.upload_mapping_file = Uploaded a mapping file.
success.send_testmail=Sent a test mail.
success.job_log_delete_all=Deleted job logs.
success.changed_password=Changed your password.
success.started_data_update=Started a data update process.
success.reindex_started=Started re-indexing.

success.upload_elevate_word = Uploaded an elevate word file.
success.upload_bad_word = Uploaded a bad word file.
success.upload_mapping_file = Uploaded a mapping file.
success.send_testmail=Sent a test mail.
success.job_log_delete_all=Deleted job logs.
success.changed_password=Changed your password.
success.started_data_update=Started a data update process.
success.reindex_started=Started re-indexing.

    CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
        handleLeaseBreak(key, newState);
    });
    
    try {
        future.get(5, TimeUnit.SECONDS);  // 5 second timeout
    } catch (TimeoutException e) {
        // Force lease release if break handling times out
        releaseLease(key);
        log.warn("Lease break timeout for key: {}", key);
    }
}
```

        // Create chain of transformers
        List<Transformer> transformerChain = new ArrayList<>();
        transformerChain.add(new TestTransformer("first"));
        transformerChain.add(new TestTransformer("second"));
        transformerChain.add(new TestTransformer("third"));

        ResponseData responseData = new ResponseData();
        responseData.setUrl("http://example.com");

        ResultData currentResult = null;