req := mustNewRequest(method, urlStr, contentLength, body, t)
	req.Header.Set("Content-Md5", "invalid-digest")
	cred := globalActiveCred
	if err := signRequestV4(req, cred.AccessKey, cred.SecretKey); err != nil {
		t.Fatalf("Unable to initialized new signed http request %s", err)
	}
	return req
}

        Smb2SessionSetupRequest req = new Smb2SessionSetupRequest(mockContext, securityMode, capabilities, previousSessionId, token);
        req.setSessionBinding(true);
        byte[] buffer = new byte[512];

        // When
        req.encode(buffer, 0);

        // Then - Verify complete structure

                    new Smb2Lock(200L, 300L, Smb2Lock.SMB2_LOCKFLAG_SHARED_LOCK) };
            Smb2LockRequest req = new Smb2LockRequest(mockConfig, testFileId, multipleLocks);

            Smb2LockResponse response = req.createResponse(mockContext, req);
            assertNotNull(response);
        }
    }

    @Nested
    @DisplayName("Integration Tests")
    class IntegrationTests {

        FilterChain chain = new FilterChain() {
            @Override
            public void doFilter(ServletRequest req, ServletResponse res) throws IOException, ServletException {
                chainCalled.set(true);
                assertSame(request, req);
                assertSame(response, res);
            }
        };

        // Setup WebApiManagerFactory that returns null

	for k, v := range req.Form {
		if !defaultSigParams.Contains(k) {
			query[k] = v
		}
	}

	// Get the encoded query.
	encodedQuery := query.Encode()

	// Verify if date query is same.
	if req.Form.Get(xhttp.AmzDate) != query.Get(xhttp.AmzDate) {
		return ErrSignatureDoesNotMatch
	}
	// Verify if expires query is same.
	if req.Form.Get(xhttp.AmzExpires) != query.Get(xhttp.AmzExpires) {

        final HttpServletRequest req = (HttpServletRequest) request;
        final HttpServletResponse resp = (HttpServletResponse) response;
        NtlmPasswordAuthentication ntlm = negotiate(req, resp, false);

        if (ntlm == null) {
            return;
        }

        chain.doFilter(new NtlmHttpServletRequest(req, ntlm), response);
    }

    /**

                    req.nextElement();
                    if (req.hasMoreElements()) {
                        final SmbComBlankResponse interim = new SmbComBlankResponse();
                        super.sendrecv(req, interim, RESPONSE_TIMEOUT);
                        if (interim.errorCode != 0) {
                            checkStatus(req, interim);
                        }
                        req.nextElement();

    @Override
    public void doGet(final HttpServletRequest req, final HttpServletResponse resp) throws IOException, ServletException {
        Address dc;
        String msg, pathInfo, server = null;
        boolean offerBasic, possibleWorkgroup = true;
        NtlmPasswordAuthentication ntlm = null;
        final HttpSession ssn = req.getSession(false);

        pathInfo = req.getPathInfo();
        if (pathInfo != null) {

    @Override
    public void doGet(final HttpServletRequest req, final HttpServletResponse resp) throws IOException, ServletException {
        UniAddress dc;
        String msg, pathInfo, server = null;
        boolean offerBasic, possibleWorkgroup = true;
        NtlmPasswordAuthentication ntlm = null;
        final HttpSession ssn = req.getSession(false);

        pathInfo = req.getPathInfo();
        if (pathInfo != null) {

            if (th.isSMB2()) {
                final Smb2IoctlRequest req =
                        new Smb2IoctlRequest(th.getConfig(), Smb2IoctlRequest.FSCTL_PIPE_TRANSCEIVE, fh.getFileId(), inB);
                req.setFlags(Smb2IoctlRequest.SMB2_O_IOCTL_IS_FSCTL);
                req.setInputData(new ByteEncodable(buf, off, length));
                req.setMaxOutputResponse(maxRecvSize);