private int status = STATUS_SUCCESS;
    private int maxReadWriteSize;
    private int preferredSendSize;
    private int maxReceiveSize;
    private int maxFragmentedSize;

    /**
     * Create SMB Direct Negotiate Response
     */
    public SmbDirectNegotiateResponse() {
        // Initialize with defaults
        this.minVersion = SmbDirectNegotiateRequest.MIN_VERSION;

        assertEquals(5, negotiationDifferentSizes.getResponseRaw().length);
    }

    @Test
    @DisplayName("Test multiple instances do not interfere")
    void testMultipleInstances() {
        // Create another instance with different data
        SmbNegotiationRequest anotherRequest = mock(SmbNegotiationRequest.class);
        SmbNegotiationResponse anotherResponse = mock(SmbNegotiationResponse.class);

    @Execute
    public JsonResponse<ApiResult> post$setting(final String dictId, final CreateBody body) {
        body.dictId = dictId;
        validateApi(body, messages -> {});
        body.crudMode = CrudMode.CREATE;
        final SynonymItem entity = createSynonymItem(this, body, () -> {
            throwValidationErrorApi(messages -> messages.addErrorsCrudFailedToCreateInstance(GLOBAL));
            return null;

        assertTrue(result.contains("3 docs")); // Verify the job executes
    }

    // Test handling of processing exception
    public void test_execute_withProcessingException() {
        // Create a mock that returns 0 to simulate processing error
        SearchEngineClient errorClient = new SearchEngineClient() {
            @Override
            public long updateByQuery(String index,

    }

    @Test
    public void test_AllHttpMethodFactories() {
        // ## Test that all factory methods create requests with correct methods ##

        // ## Act & Assert ##
        assertEquals(Method.GET, Curl.get("http://test.com").method());
        assertEquals(Method.POST, Curl.post("http://test.com").method());

import jcifs.internal.smb2.rdma.RdmaChannelInfo;
import jcifs.internal.util.SMBUtil;

/**
 * SMB2 Read request message.
 *
 * This command is used to read data from a file that has been
 * previously opened with a Create request.
 *
 * @author mbechler
 */
public class Smb2ReadRequest extends ServerMessageBlock2Request<Smb2ReadResponse> implements RequestWithFileId {

    /**
     * Flag to indicate unbuffered read operation

                }
            }
        }
    }

    @Override
    public void close() {
        stop();
    }

    /**
     * Helper method to create a complete mock service address
     *
     * @return formatted address string for RPC connections
     */
    public String getServiceAddress() {
        try {

            // Verify that results are reasonable relative to each other
            assertTrue("Result for 7 days should be greater than 1 day", result7 > result1);
            assertTrue("Result for 1 day should be greater than 0 days", result1 > result0);

            // Verify that the differences are approximately correct
            long diff1 = result1 - result0;

        assertEquals(threadCount * operationsPerThread, transformer.getGetDataCallCount());
    }

    /**
     * Test transformer chain
     */
    public void test_transformerChain() {
        // Create chain of transformers
        List<Transformer> transformerChain = new ArrayList<>();
        transformerChain.add(new TestTransformer("first"));
        transformerChain.add(new TestTransformer("second"));

    /**
     * Create a circuit breaker with default settings
     *
     * @param name circuit breaker name for logging
     */
    public SmbCircuitBreaker(String name) {
        this(name, 5, 3, 60000, 3, false, false, 100);
    }

    /**
     * Create a circuit breaker with custom settings
     *