*
     * @param req the HTTP servlet request
     * @param query the search query string
     * @return the preference value for JSON search requests, or null if not applicable
     */
    protected String processJsonSearchPreference(final HttpServletRequest req, final String query) {

    void sendResetsResponseAndForwards() throws Exception {
        SmbSession session = new SmbSession(addr, 445, inet, 0, auth);
        // prepare a dummy request/response using a real SMB block type
        ServerMessageBlock req = new SmbComOpenAndX("test.txt", 0, 0, null);
        ServerMessageBlock resp = new SmbComOpenAndX("test.txt", 0, 0, null);
        resp.received = true;

        session.transport(); // initialise transport

     */
    public static String encodeUrl(final String url) {
        final String enc = LaRequestUtil.getOptionalRequest()
                .filter(req -> req.getCharacterEncoding() != null)
                .map(HttpServletRequest::getCharacterEncoding)
                .orElse(Constants.UTF_8);
        final StringBuilder buf = new StringBuilder(url.length() + 100);

    public void setFileId(final byte[] fileId) {
        this.fileId = fileId;
    }

    @Override
    protected Smb2WriteResponse createResponse(final CIFSContext tc, final ServerMessageBlock2Request<Smb2WriteResponse> req) {
        return new Smb2WriteResponse(tc.getConfig());
    }

    /**
     * Sets the data to be written to the file.
     *
     * @param data the data buffer to write

        super(config, SMB2_TREE_DISCONNECT);
    }

    @Override
    protected Smb2TreeDisconnectResponse createResponse(final CIFSContext tc,
            final ServerMessageBlock2Request<Smb2TreeDisconnectResponse> req) {
        return new Smb2TreeDisconnectResponse(tc.getConfig());
    }

    /**
     * {@inheritDoc}
     *
     * @see jcifs.internal.CommonServerMessageBlockRequest#size()
     */
    @Override

        final LuceneQueryParser parser = new LuceneQueryParser(defaultField, analyzer);
        parser.setAllowLeadingWildcard(allowLeadingWildcard);
        LaRequestUtil.getOptionalRequest().ifPresent(req -> {
            if (req.getAttribute(Constants.DEFAULT_QUERY_OPERATOR) instanceof final String op) {
                parser.setDefaultOperator(Operator.valueOf(op));
            } else {

	},
) {
	for i, testCase := range testCases {
		// initialize httptest Recorder, this records any mutations to response writer inside the handler.
		rec := httptest.NewRecorder()
		// construct HTTP request
		req, err := newTestSignedRequestV4(testCase.method, getBucketLifecycleURL("", testCase.bucketName),
			int64(len(testCase.body)), bytes.NewReader(testCase.body), testCase.accessKey, testCase.secretKey, nil)
		if err != nil {

	globalIsTLS = true
	for i, test := range encryptRequestTests {
		content := bytes.NewReader(make([]byte, 64))
		req := &http.Request{Header: http.Header{}}
		for k, v := range test.header {
			req.Header.Set(k, v)
		}
		_, _, err := EncryptRequest(content, req, "bucket", "object", test.metadata)
		if err != nil {
			t.Fatalf("Test %d: Failed to encrypt request: %v", i, err)
		}

                    log.debug("Closing file handle " + this);
                }

                if (t.isSMB2()) {
                    final Smb2CloseRequest req = new Smb2CloseRequest(this.cfg, this.fileId);
                    t.send(req, RequestParam.NO_RETRY);
                } else {
                    t.send(new SmbComClose(this.cfg, this.fid, lastWriteTime), new SmbComBlankResponse(this.cfg), RequestParam.NO_RETRY);

 *   <li>DISABLED - No caching performed</li>
 * </ul>
 * <p>
 * Example usage:
 * <pre>
 * RequestCache cache = cacheFactory.createCache();
 * Result result = cache.request(myRequest, req -> {
 *     // Expensive operation to compute result
 *     return computedResult;
 * });
 * </pre>
 * <p>