Package unlimited.fc.client.transferhandler

Class FileCatalystReceiveHandler

java.lang.Object

java.util.Observable

unlimited.fc.client.api.TransferHook

unlimited.fc.client.transferhandler.MultiTransferHandler<java.lang.String>

unlimited.fc.client.transferhandler.FileCatalystReceiveHandler

All Implemented Interfaces:

java.lang.AutoCloseable, java.lang.Runnable, unlimited.core.transfers.UDPTransferMetrics, unlimited.core.util.common.CancelHandler, PostURLTransfer.TransferHolder, TransferState, FilesMatchHandler

public class FileCatalystReceiveHandler
extends MultiTransferHandler<java.lang.String>

Field Summary

Fields inherited from class unlimited.fc.client.transferhandler.MultiTransferHandler

countTransferred, filter, isParentPooled, lastBytesSoFar, statusMessage, waitForDiscWriteProgressive, willTransfer

Fields inherited from class unlimited.fc.client.api.TransferHook

BIDIRECTIONAL, CANCELLED, CHECKING, COMPRESSING, CREATINGDMG, currentFileToIDs, DECOMPRESSING, DELTA, DOINGCHMOD, DOINGMDTM, DONEFILE, DOWNLOAD, ERROR, errorMessageStack, FINISHED, IDLE, INITIALIZING, MONITORING, MOVINGFILES, NOTATTEMPTED, PROCESSING, REBUILD, RECONNECTING, SIGNATURE, SUCCESS, TRANSFERRING, UPLOAD, VERIFYING

Constructor Summary

Constructors

Constructor	Description
FileCatalystReceiveHandler(FCClientEngine fcClient, java.util.List<java.lang.String> files, java.nio.file.Path localPath, int blockSize, int unitSize, int numDecoders, int bandwidth, boolean verify, boolean keepModificationDateTime, boolean keepPermissions)
FileCatalystReceiveHandler(FCClientEngine fcClient, java.util.List<java.lang.String> files, java.nio.file.Path localPath, int blockSize, int unitSize, int numDecoders, int bandwidth, boolean verify, boolean keepModificationDateTime, boolean keepPermissions, boolean recurse, CachedFileIndexInterface fileTransferIndex)

Method Summary

Modifier and Type	Method	Description
void	createZeroByteFileLocally(java.nio.file.Path localFile, java.lang.String remoteFile)
protected boolean	doesDirectoryContainContents(java.lang.String t)
void	doRemoteSync(java.nio.file.Path file, java.lang.String rfile, long origSize, boolean compress, int level, int strategy, java.lang.String uniqueID)
protected java.nio.file.Path	getOriginalFile(java.nio.file.Path tempFile)
java.nio.file.Path	getPathForRecursiveTransfer(java.lang.String remoteFile, java.nio.file.Path localPath)
protected java.nio.file.Path	getTempFile(java.nio.file.Path localFile)
protected boolean	isExceptionFatal(java.lang.Exception ex)
void	runHandler()
void	setFilePermissions(java.nio.file.Path localFile, java.lang.String remoteFile)
void	setFilesList(java.util.List<java.lang.String> files)
void	setRenameVector(java.util.List<java.nio.file.Path> renameList)
protected long	waitForSourceFileToBeStaticIfRequired(java.lang.String file, long soureFileSize)

Methods inherited from class unlimited.fc.client.transferhandler.MultiTransferHandler

addObserver, addTransferredLocalFile, addTransferredRemoteFile, calculateAverageKbpsRate, calculateEffectiveRateOfZipTransfer, checkForServerTimeout, checkRegex, close, deleteLocalFiles, deleteRemoteFileNames, downgradeFileTransferMode, enableVerifySizeIfNeeded, fileRegionMatch, filesMatch, filesMatch, filesMatch, filesMatchBackground, filesMatchPartial, filesMatchPartial, filterEmptyDirectoriesIfNeeded, getActiveIndex, getAllFileAndSize, getAllFilePaths, getAverageSetupTeardown, getAvgMD5TimePerKB, getBytesSoFarAllFiles, getBytesSoFarAllFilesFull, getBytesSoFarCurrentFile, getCallbackHandler, getCancelHandler, getClient, getClientAPI, getCompFileFilter, getCompressionLevel, getCompressionMethod, getCompressionStrategy, getCountTransferred, getCurrentEffectiveRate, getCurrentFilename, getCurrentFileTime, getCurrentFileTransferTime, getCurrentPercent, getCurrentRate, getDeltaFilename, getDirection, getEffectiveRateAverage, getEffectiveRateAverageInKBperSecond, getFilesSoFar, getFilesTransferredLocal, getFilesTransferredRemote, getFilter, getFormattedCurrentFileTransferTime, getFormattedOverallTransferTime, getFormattedTransferTime, getIncTransferOption, getLastTry, getLocalFilename, getLocalFileTransferIndex, getLocalWorkingDirectory, getLogFiles, getMaximumDeltaSize, getMaxTries, getMD5Key, getMd5RateLimit, getMeanEffectiveRate, getMinimumDeltaSize, getOverallRate, getOverallRateInKBperSecond, getOverallTimeRemaining, getOverallTimeRemainingMillis, getOverallTransferTime, getPacketLossPercent, getPercent, getPostURL, getPreservePathStructureFileName, getProgressiveTimeout, getProgressiveTimeoutFilter, getRateAverage, getRateAverageInKBperSecond, getRateInKBperSecond, getRegex, getRemoteFilename, getRemoteWorkingDirectory, getRetransferHeaderSize, getRoundTripTime, getSignatureFilename, getSizeAllFiles, getSizeCurrentFile, getSizeTransferredAlreadyAllFiles, getSizeTransferredAlreadyCurrentFile, getStatus, getStatusCode, getStatusMessage, getTimeRemaining, getTimeRemainingMillis, getTmpMode, getTotalFiles, getTransferMetrics, getTransferMode, getTransferStartTime, getTransferStatus, getTransferTime, getTransferWarningMessage, getUniqueID, getVerifyMode, getWaitRetry, getZipFileSizeLimit, handleError, handleProgressiveDelayBeforeAppend, incrementSofarAllFiles, incrementTotalFiles, initializeProgressiveDelay, initializeTransferHeadersEachAppend, isAddSkippedFilesToTransferVector, isAutoResume, isAutoUnzip, isAutoZip, isCancelled, isCancelledDueToError, isDeleteAfterTransfer, isDeletePartial, isDowngradeModeOnReConnect, isFatal, isIncremental, isIncrementalSizeCheckOnly, isOptimizeBlocksize, isPreservePathStructure, isProgressiveTransfers, isRenameExtensions, isSecure, isStorTmp, isTransferCancelled, isTransferComplete, isTransferEmptyDirectories, isTransferError, isTransferUsingDeltas, isTransferWarning, isUseCompression, isValidFileCache, killAll, logFinalTransferStats, logMessage, main, notifyObservers, notifyObservers, passesProgressiveTimeoutFilter, permissionsAllowForDeltasTransfer, removeIndex, renameExtension, run, setAddSkippedFilesToTransferVector, setAppletTransferCache, setAutoResume, setAutoUnzip, setAutoZip, setAvgMD5TimePerKB, setAvgRTT, setBandwidth, setCallbackHandler, setCancelled, setCancelled, setClientAPI, setCompFileFilter, setCompressionLevel, setCompressionMethod, setCompressionStrategy, setDeleteAfterTransfer, setDeletePartial, setDowngradeModeOnReConnect, setFatal, setFilesSoFar, setFilter, setIncremental, setIncrementalSizeCheckOnly, setIncTransferOption, setIsError, setLastTry, setLocalFileTransferIndex, setLocalMD5, setLocalWorkingDirectory, setLocalWorkingDirectory, setLogFiles, setMaxTries, setMd5RateLimit, setOptimizeBlocksize, setParentPooled, setPostURL, setPreservePathStructure, setProgressiveTimeout, setProgressiveTimeoutFilter, setProgressiveTransfers, setRegex, setRemoteMD5, setRemoteWorkingDirectory, setRenameExtensions, setRetransferHeaderSize, setSizeCurrentFile, setStatusCode, setStorTmp, setTmpMode, setTransferEmptyDirectories, setTransferMode, setUniqueID, setUseCompression, setVerifyMode, setWaitRetry, setZipFileSizeLimit, shouldCompressFile, shouldPerformIncremental, updateObservers, updateSofarAllFiles, updateStatusTransferring, validateVerifyMode, verifierRunning, verifyFileContents, verifySize, waitForDiscWriteProgressives, willTransfer

Methods inherited from class unlimited.fc.client.api.TransferHook

addErrorMessage, getActualRate, getAllErrorMessages, getCurrentFileToIDs, getErrorCodes, getErrorMessage, getErrorSet, getRate, getSnapShot, getStatusAsParsableString, setFormatter

Methods inherited from class java.util.Observable

clearChanged, countObservers, deleteObserver, deleteObservers, hasChanged, setChanged

Methods inherited from class java.lang.Object

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

Methods inherited from interface unlimited.fc.client.transferhandler.FilesMatchHandler

addErrorMessage

Constructor Detail

FileCatalystReceiveHandler

public FileCatalystReceiveHandler(FCClientEngine fcClient,
                                  java.util.List<java.lang.String> files,
                                  java.nio.file.Path localPath,
                                  int blockSize,
                                  int unitSize,
                                  int numDecoders,
                                  int bandwidth,
                                  boolean verify,
                                  boolean keepModificationDateTime,
                                  boolean keepPermissions)

FileCatalystReceiveHandler

public FileCatalystReceiveHandler(FCClientEngine fcClient,
                                  java.util.List<java.lang.String> files,
                                  java.nio.file.Path localPath,
                                  int blockSize,
                                  int unitSize,
                                  int numDecoders,
                                  int bandwidth,
                                  boolean verify,
                                  boolean keepModificationDateTime,
                                  boolean keepPermissions,
                                  boolean recurse,
                                  CachedFileIndexInterface fileTransferIndex)

Method Detail

setFilesList

public void setFilesList(java.util.List<java.lang.String> files)

runHandler

public void runHandler()

Specified by:

runHandler in class MultiTransferHandler<java.lang.String>

setFilePermissions

public void setFilePermissions(java.nio.file.Path localFile,
                               java.lang.String remoteFile)
                        throws unlimited.core.util.common.exception.FCException,
                               java.io.IOException

Throws:

unlimited.core.util.common.exception.FCException

java.io.IOException

getPathForRecursiveTransfer

public java.nio.file.Path getPathForRecursiveTransfer(java.lang.String remoteFile,
                                                      java.nio.file.Path localPath)

doRemoteSync

public void doRemoteSync(java.nio.file.Path file,
                         java.lang.String rfile,
                         long origSize,
                         boolean compress,
                         int level,
                         int strategy,
                         java.lang.String uniqueID)
                  throws unlimited.core.util.common.exception.FCException,
                         java.io.IOException,
                         java.lang.Exception

Parameters:

file -

rfile -

Throws:

unlimited.core.util.common.exception.FCException

java.io.IOException

java.lang.Exception

getTempFile

protected java.nio.file.Path getTempFile(java.nio.file.Path localFile)

getOriginalFile

protected java.nio.file.Path getOriginalFile(java.nio.file.Path tempFile)

waitForSourceFileToBeStaticIfRequired

protected long waitForSourceFileToBeStaticIfRequired(java.lang.String file,
                                                     long soureFileSize)
                                              throws java.io.IOException

Throws:

java.io.IOException

isExceptionFatal

protected boolean isExceptionFatal(java.lang.Exception ex)

doesDirectoryContainContents

protected boolean doesDirectoryContainContents(java.lang.String t)

Specified by:

doesDirectoryContainContents in class MultiTransferHandler<java.lang.String>

createZeroByteFileLocally

public void createZeroByteFileLocally(java.nio.file.Path localFile,
                                      java.lang.String remoteFile)
                               throws java.io.IOException,
                                      unlimited.core.util.common.exception.FCException

Throws:

java.io.IOException

unlimited.core.util.common.exception.FCException

setRenameVector

public void setRenameVector(java.util.List<java.nio.file.Path> renameList)