Transport - Code Search

maven-core/src/main/java/org/apache/maven/internal/impl/DefaultTransportProvider.java

    private final org.eclipse.aether.spi.connector.transport.TransporterProvider transporterProvider;

    @Inject
    public DefaultTransportProvider(TransporterProvider transporterProvider) {
        this.transporterProvider = requireNonNull(transporterProvider);
    }

    @Override
    public Transport transport(Session session, RemoteRepository repository) {
        try {

Java

- Registered: Sun Mar 24 03:35:10 GMT 2024

- Last Modified: Tue Dec 05 08:11:33 GMT 2023

- 2.5K bytes

- Viewed (0)

github.com/square/okhttp

docs/changelogs/changelog_1x.md

 * Add URLStreamHandlerFactory support so that `URL.openConnection()` uses
   OkHttp.
 * Expose the transport ("http/1.1", "spdy/3", etc.) via magic request headers.
   Use `X-Android-Transports` to write the preferred transports and
   `X-Android-Selected-Transport` to read the negotiated transport.


## Version 1.0.2

_2013-05-11_

 * Fix: Remove use of Java 6-only APIs.

Plain Text

- Registered: Fri May 03 11:42:14 GMT 2024

- Last Modified: Sun Feb 06 02:19:09 GMT 2022

- 6.4K bytes

- Viewed (0)

github.com/apache/maven

maven-api-impl/src/main/java/org/apache/maven/internal/impl/DefaultTransportProvider.java

    private final org.eclipse.aether.spi.connector.transport.TransporterProvider transporterProvider;

    @Inject
    public DefaultTransportProvider(TransporterProvider transporterProvider) {
        this.transporterProvider = requireNonNull(transporterProvider);
    }

    @Override
    public Transport transport(Session session, RemoteRepository repository) {
        try {

Java

- Registered: Sun May 05 03:35:11 GMT 2024

- Last Modified: Mon Mar 25 10:50:01 GMT 2024

- 2.5K bytes

- Viewed (0)

github.com/minio/minio

internal/config/identity/openid/openid.go

	return cfg
}

// LookupConfig lookup jwks from config, override with any ENVs.
func LookupConfig(s config.Config, transport http.RoundTripper, closeRespFn func(io.ReadCloser), serverRegion string) (c Config, err error) {
	openIDClientTransport := http.DefaultTransport
	if transport != nil {
		openIDClientTransport = transport
	}
	c = Config{
		Enabled:            false,
		arnProviderCfgsMap: map[arn.ARN]*providerCfg{},

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Thu Nov 16 04:42:31 GMT 2023

- 16.5K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb/SmbTransportPoolImpl.java

import org.slf4j.LoggerFactory;

import jcifs.Address;
import jcifs.CIFSContext;
import jcifs.CIFSException;
import jcifs.SmbConstants;
import jcifs.SmbTransport;
import jcifs.SmbTransportPool;
import jcifs.util.transport.TransportException;


/**
 * @author mbechler
 * @internal
 */
public class SmbTransportPoolImpl implements SmbTransportPool {

Java

- Registered: Sun May 05 00:10:10 GMT 2024

- Last Modified: Sun Dec 20 14:09:34 GMT 2020

- 12.5K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/internal/smb2/Smb2CancelRequest.java

        setAsyncId(asyncId);
        if ( asyncId != 0 ) {
            addFlags(SMB2_FLAGS_ASYNC_COMMAND);
        }
    }


    /**
     * {@inheritDoc}
     *
     * @see jcifs.util.transport.Request#getCreditCost()
     */
    @Override
    public int getCreditCost () {
        return 1;
    }


    /**
     * {@inheritDoc}
     *

Java

- Registered: Sun May 05 00:10:10 GMT 2024

- Last Modified: Sun Jul 01 13:12:10 GMT 2018

- 4.1K bytes

- Viewed (0)

github.com/apache/maven

maven-api-impl/src/test/java/org/apache/maven/internal/impl/standalone/RepositorySystemSupplier.java

import org.eclipse.aether.spi.connector.layout.RepositoryLayoutProvider;
import org.eclipse.aether.spi.connector.transport.TransporterFactory;
import org.eclipse.aether.spi.connector.transport.TransporterProvider;
import org.eclipse.aether.spi.connector.transport.http.ChecksumExtractor;
import org.eclipse.aether.spi.connector.transport.http.ChecksumExtractorStrategy;
import org.eclipse.aether.spi.io.ChecksumProcessor;

Java

- Registered: Sun May 05 03:35:11 GMT 2024

- Last Modified: Thu May 02 15:10:38 GMT 2024

- 43.7K bytes

- Viewed (0)

github.com/minio/minio

cmd/update.go

	if runtime.GOOS == "windows" {
		return MinioReleaseURL + "minio.exe"
	}

	return MinioReleaseURL + "minio"
}

func getUpdateReaderFromURL(u *url.URL, transport http.RoundTripper, mode string) (io.ReadCloser, error) {
	clnt := &http.Client{
		Transport: transport,
	}
	req, err := http.NewRequest(http.MethodGet, u.String(), nil)
	if err != nil {
		return nil, AdminError{
			Code:       AdminUpdateUnexpectedFailure,

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Wed Apr 24 04:08:47 GMT 2024

- 18.7K bytes

- Viewed (0)

github.com/minio/minio

docs/debugging/s3-check-md5/main.go

	secure := strings.EqualFold(u.Scheme, "https")
	transport, err := minio.DefaultTransport(secure)
	if err != nil {
		log.Fatalln(err)
	}
	if insecure {
		// skip TLS verification
		transport.TLSClientConfig.InsecureSkipVerify = true
	}

	s3Client, err := minio.New(u.Host, &minio.Options{
		Creds:     credentials.NewStaticV4(accessKey, secretKey, ""),
		Secure:    secure,
		Transport: transport,
	})
	if err != nil {

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Sat Feb 17 01:15:57 GMT 2024

- 6.3K bytes

- Viewed (0)

github.com/minio/minio

internal/config/identity/openid/providercfg.go

	}

	req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
	if accessToken != "" {
		req.Header.Set("Authorization", "Bearer "+accessToken)
	}

	client := &http.Client{
		Transport: transport,
	}

	resp, err := client.Do(req)
	if err != nil {
		return nil, err
	}

	defer xhttp.DrainBody(resp.Body)
	if resp.StatusCode != http.StatusOK {

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Thu Jan 18 07:03:17 GMT 2024

- 4.6K bytes

- Viewed (0)

Search Options