void testCompleteFlow() {
        request = new Smb2SetInfoRequest(mockConfig);

        // Set all fields
        byte[] newFileId = new byte[16];
        for (int i = 0; i < 16; i++) {
            newFileId[i] = (byte) (0xFF - i);
        }
        request.setFileId(newFileId);
        request.setInfoType((byte) 0x02);
        request.setFileInfoClass((byte) 0x08);
        request.setAdditionalInformation(0xABCDEF00);

     *
     * @param request the multi-search request
     * @return a future for the multi-search response
     */
    @Override
    public ActionFuture<MultiSearchResponse> multiSearch(final MultiSearchRequest request) {
        return client.multiSearch(request);
    }

    /**
     * Executes a multi-search request asynchronously with a callback.
     *

     *
     * @param request the HTTP servlet request
     * @return the user code from request parameters, or null if not found or invalid
     */
    protected String getUserCodeFromRequest(final HttpServletRequest request) {
        final FessConfig fessConfig = ComponentUtil.getFessConfig();
        final String userCode = request.getParameter(fessConfig.getUserCodeRequestParameter());

        request.setMaxInputResponse(maxInput);

        assertNotNull(request);
    }

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

        request.setMaxOutputResponse(maxOutput);

        assertNotNull(request);
    }

        assertEquals(1024, request.size());
        assertEquals(Integer.valueOf(5000), request.getOverrideTimeout());

        verify(request, times(1)).isResponseAsync();
        verify(request, times(1)).getNext();
        verify(request, times(1)).split();
        verify(request, times(1)).allowChain(nextRequest);
        verify(request, times(1)).createCancel();
        verify(request, times(1)).size();

        return new GeoInfo(request);
    }

    /**
     * The search request type.
     */
    public enum SearchRequestType {
        /** Search request type. */
        SEARCH,
        /** Admin search request type. */
        ADMIN_SEARCH,
        /** JSON request type. */
        JSON,
        /** GSA request type. */
        GSA,
        /** Suggest request type. */
        SUGGEST;

		}
	}

	// Test for Anonymous/unsigned http request.
	// Bucket policy related functions doesn't support anonymous requests, setting policies shouldn't make a difference.
	// create unsigned HTTP request for PutBucketPolicyHandler.
	anonReq, err := newTestRequest(http.MethodGet, getPutPolicyURL("", bucketName), 0, nil)
	if err != nil {
		t.Fatalf("MinIO %s: Failed to create an anonymous request for bucket \"%s\": <ERROR> %v",

                        .status(ApiResult.Status.OK)
                        .result());
    }

    /**
     * Retrieves a specific request header setting by ID.
     *
     * @param id the ID of the request header setting to retrieve
     * @return JSON response containing the request header setting
     */
    // GET /api/admin/reqheader/setting/{id}
    @Execute

 *
 * @param context The context identifier for this request trace, helping to identify the scope or purpose
 *                of the request. May be null if no specific context is needed.
 * @param parent The parent request trace that led to this request, establishing the chain of nested
 *               operations. May be null for top-level requests.
 * @param data Additional data associated with this request trace, typically containing the actual request

	}

	globalActiveCred = creds
	testCases := []struct {
		Request *http.Request
		ErrCode APIErrorCode
	}{
		{Request: mustNewRequest(http.MethodGet, "http://127.0.0.1:9000", 0, nil, t), ErrCode: ErrAccessDenied},
		{Request: mustNewSignedRequest(http.MethodGet, "http://127.0.0.1:9000", 0, nil, t), ErrCode: ErrNone},