final HighlightInfo highlightInfo = new HighlightInfo();
            final String widthStr = req.getParameter(SCREEN_WIDTH);
            if (StringUtil.isNotBlank(widthStr)) {
                final int width = Integer.parseInt(widthStr);
                updateHighlightInfo(highlightInfo, width);
                final HttpSession session = req.getSession(false);

     *
     * @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

	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)
		}

     */
    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

	}
	return d.disk.StatInfoFile(ctx, volume, path, glob)
}

func (d *naughtyDisk) ReadMultiple(ctx context.Context, req ReadMultipleReq, resp chan<- ReadMultipleResp) error {
	if err := d.calcError(); err != nil {
		close(resp)
		return err
	}
	return d.disk.ReadMultiple(ctx, req, resp)
}

func (d *naughtyDisk) CleanAbandonedData(ctx context.Context, volume string, path string) error {

        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

 *   <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>

                    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);