Package org.eclipse.aether.connector.basic

Class BasicRepositoryConnector

java.lang.Object

org.eclipse.aether.connector.basic.BasicRepositoryConnector

All Implemented Interfaces:

Closeable, AutoCloseable, RepositoryConnector

final class BasicRepositoryConnector
extends Object
implements RepositoryConnector

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	BasicRepositoryConnector.GetTaskRunner
(package private) class	BasicRepositoryConnector.PeekTaskRunner
(package private) class	BasicRepositoryConnector.PutTaskRunner
(package private) class	BasicRepositoryConnector.TaskRunner

Field Summary

Fields

Modifier and Type	Field	Description
private final ChecksumPolicyProvider	checksumPolicyProvider
private final AtomicBoolean	closed
private static final String	CONFIG_PROP_PARALLEL_PUT
private static final String	CONFIG_PROP_SMART_CHECKSUMS
private static final String	CONFIG_PROP_THREADS
private Executor	executor
private final FileProcessor	fileProcessor
private final RepositoryLayout	layout
private static final org.slf4j.Logger	LOGGER
private final int	maxThreads
private final boolean	parallelPut
private final boolean	persistedChecksums
private final Map<String,ProvidedChecksumsSource>	providedChecksumsSources
private final RemoteRepository	repository
private final RepositorySystemSession	session
private final boolean	smartChecksums
private final Transporter	transporter

Constructor Summary

Constructors

Constructor	Description
BasicRepositoryConnector(RepositorySystemSession session, RemoteRepository repository, TransporterProvider transporterProvider, RepositoryLayoutProvider layoutProvider, ChecksumPolicyProvider checksumPolicyProvider, FileProcessor fileProcessor, Map<String,ProvidedChecksumsSource> providedChecksumsSources)

Method Summary

Modifier and Type	Method	Description
void	close()	Closes this connector and frees any network resources associated with it.
private void	failIfClosed()
void	get(Collection<? extends ArtifactDownload> artifactDownloads, Collection<? extends MetadataDownload> metadataDownloads)	Performs the specified downloads.
private Executor	getExecutor(int tasks)
private static List<List<MetadataUpload>>	groupUploads(Collection<? extends MetadataUpload> metadataUploads)	This method "groups" the Metadata to be uploaded by their level (version, artifact, group and root).
private ChecksumPolicy	newChecksumPolicy(String policy, TransferResource resource)
private TransferEvent.Builder	newEventBuilder(TransferResource resource, boolean upload, boolean peek)
private TransferResource	newTransferResource(URI path, File file, RequestTrace trace)
void	put(Collection<? extends ArtifactUpload> artifactUploads, Collection<? extends MetadataUpload> metadataUploads)	Performs the specified uploads.
private static <T> Collection<T>	safe(Collection<T> items)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

CONFIG_PROP_THREADS

private static final String CONFIG_PROP_THREADS

See Also:

• Constant Field Values

CONFIG_PROP_SMART_CHECKSUMS

private static final String CONFIG_PROP_SMART_CHECKSUMS

See Also:

• Constant Field Values

CONFIG_PROP_PARALLEL_PUT

private static final String CONFIG_PROP_PARALLEL_PUT

See Also:

• Constant Field Values

LOGGER

private static final org.slf4j.Logger LOGGER

providedChecksumsSources

private final Map<String,ProvidedChecksumsSource> providedChecksumsSources

fileProcessor

private final FileProcessor fileProcessor

repository

private final RemoteRepository repository

session

private final RepositorySystemSession session

transporter

private final Transporter transporter

layout

private final RepositoryLayout layout

checksumPolicyProvider

private final ChecksumPolicyProvider checksumPolicyProvider

maxThreads

private final int maxThreads

smartChecksums

private final boolean smartChecksums

parallelPut

private final boolean parallelPut

persistedChecksums

private final boolean persistedChecksums

executor

private Executor executor

closed

private final AtomicBoolean closed

Constructor Details

BasicRepositoryConnector

BasicRepositoryConnector(RepositorySystemSession session,
 RemoteRepository repository,
 TransporterProvider transporterProvider,
 RepositoryLayoutProvider layoutProvider,
 ChecksumPolicyProvider checksumPolicyProvider,
 FileProcessor fileProcessor,
 Map<String,ProvidedChecksumsSource> providedChecksumsSources)
                  throws NoRepositoryConnectorException

Throws:

NoRepositoryConnectorException

Method Details

getExecutor

private Executor getExecutor(int tasks)

close

public void close()

Description copied from interface: RepositoryConnector

Closes this connector and frees any network resources associated with it. Once closed, a connector must not be used for further transfers, any attempt to do so would yield a IllegalStateException or similar. Closing an already closed connector is harmless and has no effect.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface RepositoryConnector

failIfClosed

private void failIfClosed()

get

public void get(Collection<? extends ArtifactDownload> artifactDownloads,
 Collection<? extends MetadataDownload> metadataDownloads)

Description copied from interface: RepositoryConnector

Performs the specified downloads. If a download fails, the connector stores the underlying exception in the download object such that callers can inspect the result via ArtifactTransfer.getException() and MetadataTransfer.getException(), respectively. If reasonable, a connector should continue to process the remaining downloads after an error to retrieve as many items as possible. The connector may perform the transfers concurrently and in any order.

Specified by:

get in interface RepositoryConnector

Parameters:

artifactDownloads - The artifact downloads to perform, may be null or empty.

metadataDownloads - The metadata downloads to perform, may be null or empty.

put

public void put(Collection<? extends ArtifactUpload> artifactUploads,
 Collection<? extends MetadataUpload> metadataUploads)

Description copied from interface: RepositoryConnector

Performs the specified uploads. If an upload fails, the connector stores the underlying exception in the upload object such that callers can inspect the result via ArtifactTransfer.getException() and MetadataTransfer.getException(), respectively. The connector may perform the transfers concurrently and in any order.

Specified by:

put in interface RepositoryConnector

Parameters:

artifactUploads - The artifact uploads to perform, may be null or empty.

metadataUploads - The metadata uploads to perform, may be null or empty.

groupUploads

private static List<List<MetadataUpload>> groupUploads(Collection<? extends MetadataUpload> metadataUploads)

This method "groups" the Metadata to be uploaded by their level (version, artifact, group and root). This is MUST as clients consume metadata in opposite order (root, group, artifact, version), and hence, we must deploy and ensure (in case of parallel deploy) that all V level metadata is deployed before we start deploying A level, etc.

safe

private static <T> Collection<T> safe(Collection<T> items)

newTransferResource

private TransferResource newTransferResource(URI path,
 File file,
 RequestTrace trace)

newEventBuilder

private TransferEvent.Builder newEventBuilder(TransferResource resource,
 boolean upload,
 boolean peek)

newChecksumPolicy

private ChecksumPolicy newChecksumPolicy(String policy,
 TransferResource resource)

toString

public String toString()

Overrides:

toString in class Object