io.takari.aether.connector

Class AetherRepositoryConnector.GetTask<T extends org.eclipse.aether.spi.connector.Transfer>

java.lang.Object

io.takari.aether.connector.AetherRepositoryConnector.GetTask<T>

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

AetherRepositoryConnector

class AetherRepositoryConnector.GetTask<T extends org.eclipse.aether.spi.connector.Transfer>
extends java.lang.Object
implements java.lang.Runnable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	AetherRepositoryConnector.GetTask.FileTransfer

Field Summary

Fields

Modifier and Type	Field and Description
private java.lang.String	checksumPolicy
private T	download
private java.lang.Exception	exception
private java.io.File	fileInLocalRepository
private AetherRepositoryConnector.LatchGuard	latch
private java.lang.String	path
private AetherRepositoryConnector.ExceptionWrapper<T>	wrapper

Constructor Summary

Constructors

Constructor and Description
GetTask(java.lang.String path, java.io.File fileInLocalRepository, java.lang.String checksumPolicy, java.util.concurrent.CountDownLatch latch, T download, AetherRepositoryConnector.ExceptionWrapper<T> wrapper)

Method Summary

Modifier and Type	Method and Description
void	flush()
T	getDownload()
java.lang.Exception	getException()
private Response	getResponse(java.lang.String uri, boolean resumeDownloadInProgress, java.io.File temporaryFileInLocalRepository)
private void	rename(java.io.File from, java.io.File to)
private boolean	resourceExist(java.lang.String uri)
private AetherRepositoryConnector.GetTask.FileTransfer	resumableGet(java.lang.String uri, java.io.File fileInLocalRepository, org.eclipse.aether.transfer.TransferResource transferResource, org.eclipse.aether.transfer.TransferEvent.RequestType requestType, boolean emitProgressEvent)
void	run()
private void	validateChecksums(java.io.File temporaryFileInLocalRepository, java.io.File fileInLocalRepository, java.lang.String uri, org.eclipse.aether.transfer.TransferResource transferResource)
private boolean	verifyChecksums(java.io.File temporaryFileInLocalRepository, java.io.File fileInLocalRepository, java.lang.String uri, java.util.Map<java.lang.String,java.lang.Object> checksums)

Methods inherited from class java.lang.Object

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

Field Detail

download

private final T extends org.eclipse.aether.spi.connector.Transfer download

path

private final java.lang.String path

fileInLocalRepository

private final java.io.File fileInLocalRepository

checksumPolicy

private final java.lang.String checksumPolicy

latch

private final AetherRepositoryConnector.LatchGuard latch

exception

private volatile java.lang.Exception exception

wrapper

private final AetherRepositoryConnector.ExceptionWrapper<T extends org.eclipse.aether.spi.connector.Transfer> wrapper

Constructor Detail

GetTask

public GetTask(java.lang.String path,
               java.io.File fileInLocalRepository,
               java.lang.String checksumPolicy,
               java.util.concurrent.CountDownLatch latch,
               T download,
               AetherRepositoryConnector.ExceptionWrapper<T> wrapper)

Method Detail

getDownload

public T getDownload()

getException

public java.lang.Exception getException()

run

public void run()

Specified by:

run in interface java.lang.Runnable

resourceExist

private boolean resourceExist(java.lang.String uri)
                       throws java.io.IOException

Throws:

java.io.IOException

validateChecksums

private void validateChecksums(java.io.File temporaryFileInLocalRepository,
                               java.io.File fileInLocalRepository,
                               java.lang.String uri,
                               org.eclipse.aether.transfer.TransferResource transferResource)
                        throws java.lang.Exception

Throws:

java.lang.Exception

verifyChecksums

private boolean verifyChecksums(java.io.File temporaryFileInLocalRepository,
                                java.io.File fileInLocalRepository,
                                java.lang.String uri,
                                java.util.Map<java.lang.String,java.lang.Object> checksums)
                         throws org.eclipse.aether.transfer.ChecksumFailureException

Parameters:

temporaryFileInLocalRepository - The in-progress name of the resource being downloaded e.g. ${localRepo}/io/tesla/maven/maven-core/3.1.2/aether-90e2b299-3604-4504-b13b-dc147f001c1e-maven-core-3.1.2.jar-in-progress

fileInLocalRepository - The name of the completed name of the resource being downloaded e.g. ${localRepo}/io/tesla/maven/maven-core/3.1.2/maven-core-3.1.2.jar

uri - The URI of the resource in the remote repository e.g. http://repo1.maven.org/maven2/io/tesla/maven/maven-core/3.1.2/maven-core-3.1.2.jar

checksums - The calculated checksums of the file e.g. 724036fb069c47ccc1e27b370f99f6f10069e34a

Returns:

Whether the checksum file remotely matches the locally calculated checksum

Throws:

org.eclipse.aether.transfer.ChecksumFailureException

resumableGet

private AetherRepositoryConnector.GetTask.FileTransfer resumableGet(java.lang.String uri,
                                                                    java.io.File fileInLocalRepository,
                                                                    org.eclipse.aether.transfer.TransferResource transferResource,
                                                                    org.eclipse.aether.transfer.TransferEvent.RequestType requestType,
                                                                    boolean emitProgressEvent)
                                                             throws java.lang.Exception

Throws:

java.lang.Exception

getResponse

private Response getResponse(java.lang.String uri,
                             boolean resumeDownloadInProgress,
                             java.io.File temporaryFileInLocalRepository)
                      throws java.io.IOException

Throws:

java.io.IOException

flush

public void flush()

rename

private void rename(java.io.File from,
                    java.io.File to)
             throws java.io.IOException

Throws:

java.io.IOException