public RepositorySystemSession newRepositorySession(MavenExecutionRequest request) {
        return newRepositorySessionBuilder(request).build();
    }

    @Override
    @SuppressWarnings({"checkstyle:methodLength"})
    public SessionBuilder newRepositorySessionBuilder(MavenExecutionRequest request) {
        requireNonNull(request, "request");

				return errDiskNotFound
			}
			err := localDrives[index].MakeVol(ctx, bucket)
			if opts.ForceCreate && errors.Is(err, errVolumeExists) {
				// No need to return error when force create was
				// requested.
				return nil
			}
			return err
		}, index)
	}

	errs := g.Wait()
	return reduceWriteQuorumErrs(ctx, errs, bucketOpIgnoredErrs, (len(localDrives)/2)+1)

      val route = factory.newRoute(address)
      val pool = factory.newConnectionPool()
      val url = "https://example.com/".toHttpUrl()
      val request = Request(url = url)
      val response =
        Response
          .Builder()
          .request(request)
          .protocol(Protocol.HTTP_1_1)
          .code(200)
          .message("OK")
          .build()
      val handshake =

        MetadataResolutionRequest request = new DefaultMetadataResolutionRequest();
        injectSession(request);
        request.setArtifact(artifact);
        request.setLocalRepository(localRepository);
        request.setRemoteRepositories(remoteRepositories);
        request.setResolveManagedVersions(resolveManagedVersions);
        return retrieve(request);
    }

    @Override

                break;
            }

            if (request != null) {
                log.debug("Resetting request");
                request.reset();
            }
            if (rpath != null) {
                // resolveDfs() and tree.send() modify the request packet.
                // I want to restore it before retrying. request.reset()

        RdmaNegotiateRequest request = new RdmaNegotiateRequest();
        request.setMinVersion(0x0100);
        request.setMaxVersion(0x0100);
        request.setCreditsRequested(credits.getInitialCredits());
        request.setPreferredSendSize(maxReceiveSize);
        request.setMaxReceiveSize(maxReceiveSize);
        request.setMaxFragmentedSize(rdmaConnection.maxFragmentedSize);
        

import jcifs.Configuration;
import jcifs.internal.CommonServerMessageBlockRequest;
import jcifs.internal.CommonServerMessageBlockResponse;
import jcifs.internal.Request;

/**
 * Base class for SMB2/SMB3 request messages.
 *
 * This abstract class provides common functionality for handling
 * request messages in the SMB2/SMB3 protocol.
 *
 * @author mbechler
 * @param <T>
 *            response type
 */

        request.setAttribute(API_FORMAT_TYPE, formatType);
        return formatType;
    }

    /**
     * Detects the format type from the request parameters.
     * @param request The HTTP servlet request.
     * @return The detected format type.
     */
    protected FormatType detectFormatType(final HttpServletRequest request) {
        String value = request.getParameter("type");

            // try TreeConnectAndX with the request
            // this does not make any sense if we are disconnecting right now
            T chainedResponse = null;
            if (!(request instanceof SmbComTreeDisconnect) && !(request instanceof Smb2TreeDisconnectRequest)) {
                chainedResponse = treeConnect(request, response);
            }

            pluginSession.setDependencyGraphTransformer(session.getDependencyGraphTransformer());

            CollectRequest request = new CollectRequest();
            request.setRequestContext(REPOSITORY_CONTEXT);
            request.setRepositories(repositories);
            request.setRoot(new org.eclipse.aether.graph.Dependency(pluginArtifact, null));
            for (Dependency dependency : plugin.getDependencies()) {