synchronized (transport()) {
            if (response != null) {
                response.received = false;
            }

            expiration = System.currentTimeMillis() + SmbConstants.SO_TIMEOUT;
            sessionSetup(request, response);
            if (response != null && response.received) {
                return;
            }

import jcifs.internal.dfs.DfsReferralResponseBuffer;
import jcifs.internal.smb1.trans.SmbComTransaction;
import jcifs.internal.smb1.trans.SmbComTransactionResponse;

/**
 * Trans2 GetDfsReferral response message for DFS referral queries.
 * This class handles the response from a TRANS2_GET_DFS_REFERRAL request, which returns
 * DFS referral information for redirecting clients to distributed file system targets.
 */

import jcifs.internal.smb1.trans.nt.FileNotifyInformationImpl;
import jcifs.internal.smb2.ServerMessageBlock2Response;
import jcifs.internal.util.SMBUtil;
import jcifs.smb.NtStatus;

/**
 * SMB2 Change Notify response message.
 *
 * This response contains information about file system changes
 * that occurred in the monitored directory.
 *
 * @author mbechler
 */

import org.dbflute.optional.OptionalEntity;
import org.dbflute.optional.OptionalThing;
import org.lastaflute.web.Execute;
import org.lastaflute.web.response.ActionResponse;
import org.lastaflute.web.response.HtmlResponse;
import org.lastaflute.web.response.render.RenderData;
import org.lastaflute.web.ruts.process.ActionRuntime;
import org.lastaflute.web.validation.VaErrorHook;

            CommonServerMessageBlock response = mock(CommonServerMessageBlock.class);

            // Sign with first digest
            digest1.sign(data, 0, data.length, request, response);

            // Verify with second digest (simulating server verification)
            boolean isValid = digest2.verify(data, 0, data.length, 0, response);

import org.codelibs.fess.helper.ProcessHelper;
import org.codelibs.fess.opensearch.config.exentity.CrawlingInfo;
import org.lastaflute.web.Execute;
import org.lastaflute.web.response.JsonResponse;

import jakarta.annotation.Resource;

/**
 * API action for admin crawling info.
 *
 */
public class ApiAdminCrawlinginfoAction extends FessApiAdminAction {

    /**

		redirectPage.append("/error/systemerror/");
		response.sendRedirect(redirectPage.toString());
	} else {
		response.sendError(statusCode);
	}
} else if("logOut".equals(type)) {
	redirectPage.append("/login/?type=logout&code=" + statusCode);
	response.sendRedirect(redirectPage.toString());
} else if("badRequest".equals(type)) {
	redirectPage.append("/error/badrequest/");
	response.sendRedirect(redirectPage.toString());

		redirectPage.append("/error/systemerror/");
		response.sendRedirect(redirectPage.toString());
	} else {
		response.sendError(statusCode);
	}
} else if("logOut".equals(type)) {
	redirectPage.append("/login/?type=logout&code=" + statusCode);
	response.sendRedirect(redirectPage.toString());
} else if("badRequest".equals(type)) {
	redirectPage.append("/error/badrequest/");
	response.sendRedirect(redirectPage.toString());

    try (Response response = client.newCall(request).execute()) {
      // Consume and discard the response body.
      response.body().source().readByteString();
    }

    System.out.println("REQUEST 2 (pooled connection)");
    try (Response response = client.newCall(request).execute()) {
      // Consume and discard the response body.
      response.body().source().readByteString();
    }
  }

import okhttp3.Request;
import okhttp3.Response;

public final class SynchronousGet {
  private final OkHttpClient client = new OkHttpClient();

  public void run() throws Exception {
    Request request = new Request.Builder()
        .url("https://publicobject.com/helloworld.txt")
        .build();

    try (Response response = client.newCall(request).execute()) {