public abstract class MultiTransferHandler<T> extends TransferHook implements java.lang.Runnable, FilesMatchHandler, PostURLTransfer.TransferHolder, java.lang.AutoCloseable
Title: Digital Fountain Encoder/Decoder
Description:
Copyright: Copyright (c) 2004
Company: Unlimi-Tech Software Inc.
| Modifier and Type | Field and Description |
|---|---|
protected int |
countTransferred |
protected FileCatalystFileFilter |
filter |
protected boolean |
isParentPooled |
protected long |
lastBytesSoFar |
protected java.lang.String |
statusMessage |
static long |
waitForDiscWriteProgressive |
protected boolean |
willTransfer |
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 and Description |
|---|
MultiTransferHandler(FCClientEngine fcClient) |
| Modifier and Type | Method and Description |
|---|---|
void |
addObserver(java.util.Observer o)
Java has Deprecated Observable due to it being an anti-pattern.
|
void |
addTransferredLocalFile(java.lang.String filename) |
void |
addTransferredRemoteFile(java.lang.String filename) |
protected int |
calculateAverageKbpsRate(long bytesTotal,
long msTotal)
Calculate a transfer rate in kilo bits per second
Kilo here means a 1000, because this is a rate.
|
int |
calculateEffectiveRateOfZipTransfer(long sizeOfAllFilesZipped,
long timeForEffectiveRate) |
boolean |
checkForServerTimeout() |
boolean |
checkRegex(java.lang.String filename) |
void |
close() |
protected void |
deleteLocalFiles(java.util.LinkedList<java.nio.file.Path> tmpFileList)
Attempts to delete all files marked in temp file list locally.
|
protected void |
deleteRemoteFileNames(java.util.LinkedList<java.lang.String> tmpFileList)
Attempts to delete all remote files marked in temp file list.
|
protected abstract boolean |
doesDirectoryContainContents(T t) |
protected void |
downgradeFileTransferMode() |
protected void |
enableVerifySizeIfNeeded() |
protected boolean |
fileRegionMatch(java.nio.file.Path file,
java.lang.String rFile,
long offset,
long length) |
protected MD5Result |
filesMatch(java.nio.file.Path file,
java.lang.String rFile) |
protected MD5Result |
filesMatch(java.nio.file.Path file,
java.lang.String rFile,
boolean invalidateRemoteMD5CacheEntry) |
static MD5Result |
filesMatch(java.nio.file.Path file,
java.lang.String rFile,
boolean invalidateRemoteMD5CacheEntry,
FilesMatchHandler filesMatchHandler) |
protected void |
filesMatchBackground(java.nio.file.Path file,
java.lang.String rFile) |
protected MD5Result |
filesMatchPartial(java.nio.file.Path file,
java.lang.String rFile,
long checkInterval,
long checkLength) |
static MD5Result |
filesMatchPartial(java.nio.file.Path file,
java.lang.String rFile,
long checkInterval,
long checkLength,
boolean invalidateRemoteMD5CacheEntry,
FilesMatchHandler filesMatchHandler) |
protected void |
filterEmptyDirectoriesIfNeeded() |
int |
getActiveIndex() |
java.util.Map<java.lang.String,java.lang.Long> |
getAllFileAndSize() |
java.util.List<java.lang.String> |
getAllFilePaths()
Returns a list of all file paths contained within this TransferHook
|
long |
getAverageSetupTeardown() |
long |
getAvgMD5TimePerKB() |
long |
getBytesSoFarAllFiles()
Returns the number of bytes transferred so far for all files.
|
long |
getBytesSoFarAllFilesFull()
Return the full size of the files which were transferred.
|
long |
getBytesSoFarCurrentFile()
Returns the number of bytes transferred so far for the current file.
|
FileCatalystClientCallbackHandler |
getCallbackHandler() |
CancelHandler |
getCancelHandler() |
FCClientEngine |
getClient() |
FCClient |
getClientAPI() |
java.lang.String |
getCompFileFilter() |
int |
getCompressionLevel() |
int |
getCompressionMethod() |
int |
getCompressionStrategy() |
int |
getCountTransferred()
Returns the number of files that were actually transferred.
|
int |
getCurrentEffectiveRate()
Returns the rate for the current file in Kbps.
|
java.lang.String |
getCurrentFilename()
Returns the name of the file currently being transferred.
|
long |
getCurrentFileTime() |
long |
getCurrentFileTransferTime()
Returns the transfer time for the current file in milliseconds
|
int |
getCurrentPercent()
Returns the percent complete for the current file
|
int |
getCurrentRate()
Returns the rate in the last second for the current file in Kbps.
|
static java.lang.String |
getDeltaFilename(java.lang.String originalFilename,
java.lang.String uniqueID)
Returns the delta filename used when caculating deltas during a transfer.
|
int |
getDirection()
Returns either UPLOAD or DOWNLOAD constant depending on the direction of this transfer
|
int |
getEffectiveRateAverage()
Returns the effective rate for the current file in Kbps as an average over last 30 seconds.
|
int |
getEffectiveRateAverageInKBperSecond() |
int |
getFilesSoFar()
Returns the number of files transferred so far.
|
java.util.List<java.lang.String> |
getFilesTransferredLocal()
Returns a List containing the full local paths (Strings) of all files that were transferred.
|
java.util.List<java.lang.String> |
getFilesTransferredRemote()
Returns a List containing the full remote paths (Strings) of all files that were transferred.
|
FileCatalystFileFilter |
getFilter() |
java.lang.String |
getFormattedCurrentFileTransferTime()
Returns a human readable file transfer time
|
java.lang.String |
getFormattedOverallTransferTime()
Returns the time taken to transfer all files formatted to a String i.e 5 mins 21 secs
|
java.lang.String |
getFormattedTransferTime()
Returns the time taken to transfer the current file formatted to a String i.e 5 mins 21 secs
|
int |
getIncTransferOption() |
long |
getLastTry() |
java.lang.String |
getLocalFilename()
Returns the full path of the local file currently being transferred
|
protected CachedFileIndexInterface |
getLocalFileTransferIndex() |
java.nio.file.Path |
getLocalWorkingDirectory() |
unlimited.core.util.common.logs.LogUtils |
getLogFiles() |
static long |
getMaximumDeltaSize(long sourceFileSize,
long destFileSize) |
int |
getMaxTries() |
static java.lang.String |
getMD5Key(java.nio.file.Path file) |
int |
getMd5RateLimit() |
int |
getMeanEffectiveRate()
Returns the rate for the current file in Kbps.
|
static long |
getMinimumDeltaSize(long sourceFileSize,
long destFileSize) |
int |
getOverallRate()
Returns the average rate (in Kbps) spanned over all files averaged over the entire transfer.
|
double |
getOverallRateInKBperSecond()
Returns the average rate (in KB/s) spanned over all files averageed over the entire transfer.
|
java.lang.String |
getOverallTimeRemaining()
Return the time remaining for the all files formatted to a String i.e 5 mins 21 secs
|
long |
getOverallTimeRemainingMillis()
Returns the time remaining in milliseconds for all files
|
long |
getOverallTransferTime()
Returns the time taken to transfer all files so far in milliseconds
|
double |
getPacketLossPercent()
Returns the packet loss percent for the current transfer.
|
int |
getPercent()
Returns the percentage complete of all files to be transferred
|
java.lang.String |
getPostURL() |
static java.lang.String |
getPreservePathStructureFileName(java.lang.String lFile) |
int |
getProgressiveTimeout() |
java.lang.String |
getProgressiveTimeoutFilter() |
int |
getRateAverage()
Returns the network rate for the current file in Kbps as an average over last 30 seconds.
|
double |
getRateAverageInKBperSecond()
Returns the rate for the current file in KB/s as an average over last 30 seconds
|
double |
getRateInKBperSecond()
Returns the rate for the current file in KB/s
|
java.lang.String |
getRegex() |
java.lang.String |
getRemoteFilename()
Returns the full path of the remote file currently being transferred
|
java.lang.String |
getRemoteWorkingDirectory() |
long |
getRetransferHeaderSize() |
int |
getRoundTripTime()
Returns the current round trip time
|
static java.lang.String |
getSignatureFilename(java.lang.String originalFilename,
java.lang.String uniqueID)
Returns the delta filename used when caculating signatures during a transfer.
|
long |
getSizeAllFiles()
Returns the total size in bytes of all files that will be transferred
|
long |
getSizeCurrentFile()
Returns the size in bytes of the file currently being transferred.
|
long |
getSizeTransferredAlreadyAllFiles()
Size of files which are already found on the destination, if incremental is on and file was skipped or if file
transfer was resumed where 2 GB of data was there and you are continuing last 2GB of data.
|
long |
getSizeTransferredAlreadyCurrentFile()
Returns the number of bytes that were already transferred for this file (usually due to a resume)
|
java.lang.Integer |
getStatus(int index) |
int |
getStatusCode()
Returns the current status code, indicates what is currently happening with the transfer
|
java.lang.String |
getStatusMessage()
Returns a String representation of the current status of this transfer handler.
|
java.lang.String |
getTimeRemaining()
Return the time remaining for the current file formatted to a String i.e 5 mins 21 secs
|
long |
getTimeRemainingMillis()
Returns the time remaining in milliseconds for the current file
|
int |
getTmpMode() |
int |
getTotalFiles()
Returns the total number of files to be transferred.
|
UDPTransferMetricsContainer |
getTransferMetrics()
Returns transfer metric container specific to UDP transfers.
|
int |
getTransferMode()
Returns the current transfer mode
|
long |
getTransferStartTime()
Returns the transfer start time for the total transfer in milliseconds
|
java.util.List<java.lang.Integer> |
getTransferStatus()
Returns a list of all the status codes for current transfers within this TransferHook
|
long |
getTransferTime()
Returns the transfer time for the total transfer in milliseconds
|
java.lang.String |
getTransferWarningMessage()
Returns the transfer warning message if a transfer warning has occurred.
|
java.lang.String |
getUniqueID() |
int |
getVerifyMode() |
long |
getWaitRetry() |
long |
getZipFileSizeLimit() |
void |
handleError(java.lang.String postURL,
java.lang.Exception e) |
void |
handleProgressiveDelayBeforeAppend() |
protected void |
incrementSofarAllFiles(boolean isADeltaTransfer,
long dataSize) |
protected void |
incrementTotalFiles() |
protected void |
initializeProgressiveDelay() |
protected void |
initializeTransferHeadersEachAppend() |
boolean |
isAddSkippedFilesToTransferVector() |
boolean |
isAutoResume() |
boolean |
isAutoUnzip() |
boolean |
isAutoZip() |
boolean |
isCancelled() |
boolean |
isCancelledDueToError() |
boolean |
isDeleteAfterTransfer() |
boolean |
isDeletePartial() |
boolean |
isDowngradeModeOnReConnect() |
boolean |
isFatal()
Return true if a fatal error occurred
|
boolean |
isIncremental() |
boolean |
isIncrementalSizeCheckOnly() |
boolean |
isOptimizeBlocksize() |
boolean |
isPreservePathStructure() |
boolean |
isProgressiveTransfers() |
boolean |
isRenameExtensions() |
boolean |
isSecure()
Returns true if transfer is secure
|
boolean |
isStorTmp() |
boolean |
isTransferCancelled()
Returns true if the transfer was cancelled.
|
boolean |
isTransferComplete()
Returns true if all files are successfully transferred
|
boolean |
isTransferEmptyDirectories() |
boolean |
isTransferError()
Returns true if an error occured
|
protected boolean |
isTransferUsingDeltas() |
boolean |
isTransferWarning()
Returns true a recoverable transfer warning has occured.
|
boolean |
isUseCompression() |
boolean |
isValidFileCache() |
void |
killAll() |
void |
logFinalTransferStats(java.nio.file.Path file) |
void |
logMessage(java.util.logging.Level info,
java.lang.String string) |
static void |
main(java.lang.String[] args) |
void |
notifyObservers() |
void |
notifyObservers(java.lang.Object arg) |
protected boolean |
passesProgressiveTimeoutFilter(java.lang.String sourceFile) |
protected boolean |
permissionsAllowForDeltasTransfer()
Check to see if the permissions on teh server are OK for doing Deltas
|
void |
removeIndex(int index) |
protected void |
renameExtension(java.nio.file.Path file,
java.lang.String rFile)
OTIS feature, rename the extensions on the local and remote files from RDY to PKD
|
void |
run() |
abstract void |
runHandler() |
void |
setAddSkippedFilesToTransferVector(boolean addSkippedFilesToTransferVector) |
void |
setAppletTransferCache(java.util.HashMap<java.lang.String,java.lang.Long> transferCache) |
void |
setAutoResume(boolean autoResume) |
void |
setAutoUnzip(boolean b) |
void |
setAutoZip(boolean b) |
void |
setAvgMD5TimePerKB(long avgMD5TimePerKB) |
void |
setAvgRTT(long avgRTT) |
void |
setBandwidth(int bandwidth) |
void |
setCallbackHandler(FileCatalystClientCallbackHandler callbackHandler) |
void |
setCancelled()
Calling this method will cancel the current transfer.
|
protected void |
setCancelled(boolean isCancelled) |
void |
setClientAPI(FCClient clientAPI) |
void |
setCompFileFilter(java.lang.String compFileFilter) |
void |
setCompressionLevel(int compLevel) |
void |
setCompressionMethod(int compMethod) |
void |
setCompressionStrategy(int cs) |
void |
setDeleteAfterTransfer(boolean deleteAfterTransfer) |
void |
setDeletePartial(boolean deletePartial) |
void |
setDowngradeModeOnReConnect(boolean downgradeModeOnReConnect) |
void |
setFatal(boolean fatal)
Marks transfer as having failed in a fatal way, no retry at this point
|
void |
setFilesSoFar(int num) |
void |
setFilter(FileCatalystFileFilter filter) |
void |
setIncremental(boolean incremental) |
void |
setIncrementalSizeCheckOnly(boolean incrementalSizeCheckOnly) |
void |
setIncTransferOption(int incTransferOption) |
void |
setIsError(boolean isError) |
protected void |
setLastTry() |
protected void |
setLocalFileTransferIndex(CachedFileIndexInterface localFileTransferIndex) |
void |
setLocalMD5(java.lang.String localMD5) |
void |
setLocalWorkingDirectory(java.nio.file.Path localWorkingDirectory) |
void |
setLocalWorkingDirectory(java.lang.String localWorkingDirectory)
Deprecated.
|
void |
setLogFiles(unlimited.core.util.common.logs.LogUtils logFiles) |
void |
setMaxTries(int maxTries) |
void |
setMd5RateLimit(int md5RateLimit) |
void |
setOptimizeBlocksize(boolean optimizeBlocksize) |
void |
setParentPooled(boolean pooled) |
void |
setPostURL(java.lang.String postURL) |
void |
setPreservePathStructure(boolean preservePathStructure) |
void |
setProgressiveTimeout(int i) |
void |
setProgressiveTimeoutFilter(java.lang.String i) |
void |
setProgressiveTransfers(boolean progressiveTransfers) |
void |
setRegex(java.lang.String regex) |
void |
setRemoteMD5(java.lang.String remoteMD5) |
void |
setRemoteWorkingDirectory(java.lang.String remoteWorkingDirectory) |
void |
setRenameExtensions(boolean renameExtensions) |
void |
setRetransferHeaderSize(long retransferHeaderSize) |
void |
setSizeCurrentFile(long sizeCurrentFile) |
protected void |
setStatusCode(int code) |
void |
setStorTmp(boolean storTmp) |
void |
setTmpMode(int tmpMode) |
void |
setTransferEmptyDirectories(boolean transferEmptyDirectories) |
void |
setTransferMode(int transferMode) |
void |
setUniqueID(java.lang.String uniqueID) |
void |
setUseCompression(boolean useCompression) |
void |
setVerifyMode(int verifyMode) |
void |
setWaitRetry(long waitRetry) |
void |
setZipFileSizeLimit(long zipFileSizeLimit) |
boolean |
shouldCompressFile(java.nio.file.Path f) |
static boolean |
shouldPerformIncremental(long sourceFileSize,
long destFileSize) |
void |
updateObservers() |
protected void |
updateSofarAllFiles() |
protected void |
updateStatusTransferring() |
int |
validateVerifyMode(int verifyMode) |
boolean |
verifierRunning() |
protected void |
verifyFileContents(java.nio.file.Path file,
java.lang.String rfile,
boolean invalidateRemoteCache) |
protected void |
verifySize(java.nio.file.Path file,
java.lang.String rFile) |
static void |
waitForDiscWriteProgressives(MultiTransferHandler<?> handler) |
boolean |
willTransfer() |
addErrorMessage, getActualRate, getAllErrorMessages, getCurrentFileToIDs, getErrorCodes, getErrorMessage, getErrorSet, getRate, getSnapShot, getStatusAsParsableString, setFormatterclearChanged, countObservers, deleteObserver, deleteObservers, hasChanged, setChangedclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitaddErrorMessageprotected boolean willTransfer
public static long waitForDiscWriteProgressive
protected java.lang.String statusMessage
protected int countTransferred
protected FileCatalystFileFilter filter
protected long lastBytesSoFar
protected boolean isParentPooled
public MultiTransferHandler(FCClientEngine fcClient)
public boolean willTransfer()
public abstract void runHandler()
protected void setCancelled(boolean isCancelled)
public void setIsError(boolean isError)
setIsError in interface FilesMatchHandlerprotected void setStatusCode(int code)
public long getLastTry()
protected void setLastTry()
public boolean isFatal()
isFatal in class TransferHookpublic void setFatal(boolean fatal)
fatal - public void addObserver(java.util.Observer o)
TransferHookaddObserver in class TransferHookpublic void notifyObservers()
notifyObservers in class java.util.Observablepublic void notifyObservers(java.lang.Object arg)
notifyObservers in class java.util.Observablepublic void run()
run in interface java.lang.Runnablepublic void close()
throws java.lang.Exception
close in interface java.lang.AutoCloseablejava.lang.Exceptionpublic boolean isValidFileCache()
protected CachedFileIndexInterface getLocalFileTransferIndex()
protected void setLocalFileTransferIndex(CachedFileIndexInterface localFileTransferIndex)
public boolean shouldCompressFile(java.nio.file.Path f)
public long getAverageSetupTeardown()
public boolean isDeleteAfterTransfer()
public void setDeleteAfterTransfer(boolean deleteAfterTransfer)
public java.util.List<java.lang.String> getFilesTransferredRemote()
TransferStategetFilesTransferredRemote in interface TransferStategetFilesTransferredRemote in class TransferHookpublic java.util.List<java.lang.String> getFilesTransferredLocal()
TransferStategetFilesTransferredLocal in interface TransferStategetFilesTransferredLocal in class TransferHookpublic java.util.List<java.lang.Integer> getTransferStatus()
TransferStategetTransferStatus in interface TransferStategetTransferStatus in class TransferHookpublic java.lang.Integer getStatus(int index)
public java.util.List<java.lang.String> getAllFilePaths()
TransferStategetAllFilePaths in interface TransferStategetAllFilePaths in class TransferHookpublic java.util.Map<java.lang.String,java.lang.Long> getAllFileAndSize()
public void setCancelled()
TransferStatesetCancelled in interface TransferStatesetCancelled in class TransferHookpublic final int getTotalFiles()
TransferStategetTotalFiles in interface TransferStategetTotalFiles in class TransferHookprotected final void incrementTotalFiles()
public int getFilesSoFar()
TransferStategetFilesSoFar in interface TransferStategetFilesSoFar in class TransferHookpublic void setFilesSoFar(int num)
protected final void updateSofarAllFiles()
public java.lang.String getStatusMessage()
TransferStategetStatusMessage in interface TransferStategetStatusMessage in class TransferHookpublic long getBytesSoFarCurrentFile()
TransferStategetBytesSoFarCurrentFile in interface TransferStategetBytesSoFarCurrentFile in class TransferHookpublic long getSizeCurrentFile()
TransferStategetSizeCurrentFile in interface TransferStategetSizeCurrentFile in class TransferHookpublic long getSizeAllFiles()
TransferStategetSizeAllFiles in interface TransferStategetSizeAllFiles in class TransferHookpublic long getBytesSoFarAllFilesFull()
public long getBytesSoFarAllFiles()
TransferStategetBytesSoFarAllFiles in interface TransferStategetBytesSoFarAllFiles in class TransferHookpublic int getPercent()
TransferStategetPercent in interface TransferStategetPercent in class TransferHookpublic int getCurrentPercent()
TransferStategetCurrentPercent in interface TransferStategetCurrentPercent in class TransferHookpublic int getOverallRate()
TransferStategetOverallRate in interface TransferStategetOverallRate in class TransferHookpublic int getCurrentEffectiveRate()
TransferStategetCurrentEffectiveRate in interface TransferStategetCurrentEffectiveRate in class TransferHookpublic int getMeanEffectiveRate()
TransferStategetMeanEffectiveRate in interface TransferStategetMeanEffectiveRate in class TransferHookpublic double getRateInKBperSecond()
TransferStategetRateInKBperSecond in interface TransferStategetRateInKBperSecond in class TransferHookpublic int getRateAverage()
TransferStategetRateAverage in interface TransferStategetRateAverage in class TransferHookpublic int getEffectiveRateAverage()
TransferStategetEffectiveRateAverage in interface TransferStategetEffectiveRateAverage in class TransferHookpublic int getCurrentRate()
TransferStategetCurrentRate in interface TransferStategetCurrentRate in class TransferHookpublic double getRateAverageInKBperSecond()
TransferStategetRateAverageInKBperSecond in interface TransferStategetRateAverageInKBperSecond in class TransferHookpublic int getEffectiveRateAverageInKBperSecond()
public double getOverallRateInKBperSecond()
TransferStategetOverallRateInKBperSecond in interface TransferStategetOverallRateInKBperSecond in class TransferHookpublic long getTimeRemainingMillis()
TransferStategetTimeRemainingMillis in interface TransferStategetTimeRemainingMillis in class TransferHookpublic long getOverallTimeRemainingMillis()
TransferStategetOverallTimeRemainingMillis in interface TransferStategetOverallTimeRemainingMillis in class TransferHookpublic java.lang.String getTimeRemaining()
TransferStategetTimeRemaining in interface TransferStategetTimeRemaining in class TransferHookpublic java.lang.String getOverallTimeRemaining()
TransferStategetOverallTimeRemaining in interface TransferStategetOverallTimeRemaining in class TransferHookpublic UDPTransferMetricsContainer getTransferMetrics()
getTransferMetrics in class TransferHookpublic void updateObservers()
public long getOverallTransferTime()
TransferStategetOverallTransferTime in interface TransferStategetOverallTransferTime in class TransferHookpublic java.lang.String getFormattedOverallTransferTime()
TransferStategetFormattedOverallTransferTime in interface TransferStategetFormattedOverallTransferTime in class TransferHookpublic java.lang.String getFormattedCurrentFileTransferTime()
TransferStategetFormattedCurrentFileTransferTime in interface TransferStategetFormattedCurrentFileTransferTime in class TransferHookpublic java.lang.String getFormattedTransferTime()
TransferStategetFormattedTransferTime in interface TransferStategetFormattedTransferTime in class TransferHookpublic boolean isTransferComplete()
TransferStateisTransferComplete in interface TransferStateisTransferComplete in class TransferHookpublic boolean isTransferCancelled()
TransferStateisTransferCancelled in interface TransferStateisTransferCancelled in class TransferHookpublic boolean isCancelled()
public boolean isCancelledDueToError()
public final boolean isTransferError()
TransferStateisTransferError in interface TransferStateisTransferError in interface FilesMatchHandlerisTransferError in class TransferHookpublic boolean isTransferWarning()
TransferStateisTransferWarning in interface TransferStateisTransferWarning in class TransferHookpublic java.lang.String getTransferWarningMessage()
TransferStategetTransferWarningMessage in interface TransferStategetTransferWarningMessage in class TransferHookpublic int getStatusCode()
TransferStategetStatusCode in interface TransferStategetStatusCode in class TransferHookpublic java.lang.String getCurrentFilename()
TransferStategetCurrentFilename in interface TransferStategetCurrentFilename in class TransferHookpublic long getTransferTime()
TransferStategetTransferTime in interface TransferStategetTransferTime in class TransferHookpublic long getTransferStartTime()
TransferStategetTransferStartTime in interface TransferStategetTransferStartTime in class TransferHookpublic unlimited.core.util.common.logs.LogUtils getLogFiles()
public void setLogFiles(unlimited.core.util.common.logs.LogUtils logFiles)
public void setAutoZip(boolean b)
public boolean isAutoZip()
public boolean isOptimizeBlocksize()
public void setOptimizeBlocksize(boolean optimizeBlocksize)
protected void downgradeFileTransferMode()
protected void renameExtension(java.nio.file.Path file,
java.lang.String rFile)
throws FCException,
java.io.IOException
file - rFile - FCExceptionjava.io.IOExceptionprotected void filesMatchBackground(java.nio.file.Path file,
java.lang.String rFile)
throws FCException,
java.io.IOException
FCExceptionjava.io.IOExceptionprotected MD5Result filesMatch(java.nio.file.Path file, java.lang.String rFile) throws FCException, java.io.IOException
FCExceptionjava.io.IOExceptionpublic static MD5Result filesMatch(java.nio.file.Path file, java.lang.String rFile, boolean invalidateRemoteMD5CacheEntry, FilesMatchHandler filesMatchHandler) throws java.io.IOException, FCException
java.io.IOExceptionFCExceptionpublic static MD5Result filesMatchPartial(java.nio.file.Path file, java.lang.String rFile, long checkInterval, long checkLength, boolean invalidateRemoteMD5CacheEntry, FilesMatchHandler filesMatchHandler) throws java.io.IOException, FCException
java.io.IOExceptionFCExceptionprotected MD5Result filesMatch(java.nio.file.Path file, java.lang.String rFile, boolean invalidateRemoteMD5CacheEntry) throws FCException, java.io.IOException
FCExceptionjava.io.IOExceptionprotected MD5Result filesMatchPartial(java.nio.file.Path file, java.lang.String rFile, long checkInterval, long checkLength) throws FCException, java.io.IOException
FCExceptionjava.io.IOExceptionprotected boolean permissionsAllowForDeltasTransfer()
protected boolean fileRegionMatch(java.nio.file.Path file,
java.lang.String rFile,
long offset,
long length)
protected void initializeProgressiveDelay()
protected void initializeTransferHeadersEachAppend()
public boolean checkForServerTimeout()
checkForServerTimeout in interface FilesMatchHandlerpublic void setBandwidth(int bandwidth)
public boolean isIncremental()
public void setIncremental(boolean incremental)
public boolean isIncrementalSizeCheckOnly()
public void setIncrementalSizeCheckOnly(boolean incrementalSizeCheckOnly)
public int getIncTransferOption()
protected boolean isTransferUsingDeltas()
public void setCompressionMethod(int compMethod)
public int getCompressionMethod()
public void setCompressionLevel(int compLevel)
public int getCompressionLevel()
public void setCompressionStrategy(int cs)
public int getCompressionStrategy()
public void setIncTransferOption(int incTransferOption)
public boolean isAutoResume()
public void setAutoResume(boolean autoResume)
public int getTransferMode()
TransferStategetTransferMode in interface TransferStategetTransferMode in class TransferHookpublic void setTransferMode(int transferMode)
public boolean isSecure()
TransferStateisSecure in interface TransferStateisSecure in class TransferHookpublic int getCountTransferred()
TransferStategetCountTransferred in interface TransferStategetCountTransferred in class TransferHookpublic boolean isProgressiveTransfers()
public void setProgressiveTransfers(boolean progressiveTransfers)
public void setProgressiveTimeout(int i)
public int getProgressiveTimeout()
public void setProgressiveTimeoutFilter(java.lang.String i)
public java.lang.String getProgressiveTimeoutFilter()
public boolean isStorTmp()
public void setStorTmp(boolean storTmp)
public boolean isPreservePathStructure()
public boolean isUseCompression()
public int getTmpMode()
public java.lang.String getCompFileFilter()
public java.lang.String getUniqueID()
public int getActiveIndex()
public void removeIndex(int index)
public static long getMinimumDeltaSize(long sourceFileSize,
long destFileSize)
public static long getMaximumDeltaSize(long sourceFileSize,
long destFileSize)
public static boolean shouldPerformIncremental(long sourceFileSize,
long destFileSize)
public static void main(java.lang.String[] args)
public long getSizeTransferredAlreadyCurrentFile()
TransferStategetSizeTransferredAlreadyCurrentFile in interface TransferStategetSizeTransferredAlreadyCurrentFile in class TransferHookpublic long getSizeTransferredAlreadyAllFiles()
getSizeTransferredAlreadyAllFiles in interface TransferStategetSizeTransferredAlreadyAllFiles in class TransferHookpublic java.nio.file.Path getLocalWorkingDirectory()
public void setPreservePathStructure(boolean preservePathStructure)
public void setUseCompression(boolean useCompression)
public void setTmpMode(int tmpMode)
public void setCompFileFilter(java.lang.String compFileFilter)
public void setUniqueID(java.lang.String uniqueID)
public void setAvgRTT(long avgRTT)
@Deprecated public void setLocalWorkingDirectory(java.lang.String localWorkingDirectory)
public void setLocalWorkingDirectory(java.nio.file.Path localWorkingDirectory)
protected void deleteLocalFiles(java.util.LinkedList<java.nio.file.Path> tmpFileList)
tmpFileList - LinkedList LinkedList of Files that must be deleted.protected void deleteRemoteFileNames(java.util.LinkedList<java.lang.String> tmpFileList)
tmpFileList - LinkedList LinkedList of filenames that must be deleted.public static java.lang.String getSignatureFilename(java.lang.String originalFilename,
java.lang.String uniqueID)
originalFilename - StringuniqueID - Stringpublic static java.lang.String getDeltaFilename(java.lang.String originalFilename,
java.lang.String uniqueID)
originalFilename - StringuniqueID - Stringpublic static java.lang.String getMD5Key(java.nio.file.Path file)
public boolean isAddSkippedFilesToTransferVector()
public java.lang.String getRemoteWorkingDirectory()
public int getMaxTries()
public long getWaitRetry()
public boolean isTransferEmptyDirectories()
public FileCatalystClientCallbackHandler getCallbackHandler()
public java.lang.String getRegex()
public java.lang.String getPostURL()
public boolean isDeletePartial()
public void setAddSkippedFilesToTransferVector(boolean addSkippedFilesToTransferVector)
public void setSizeCurrentFile(long sizeCurrentFile)
public void setRemoteWorkingDirectory(java.lang.String remoteWorkingDirectory)
public void setMaxTries(int maxTries)
public void setWaitRetry(long waitRetry)
public void setTransferEmptyDirectories(boolean transferEmptyDirectories)
public void setCallbackHandler(FileCatalystClientCallbackHandler callbackHandler)
public void setRegex(java.lang.String regex)
public boolean checkRegex(java.lang.String filename)
public void setPostURL(java.lang.String postURL)
public void setDeletePartial(boolean deletePartial)
public void handleError(java.lang.String postURL,
java.lang.Exception e)
handleError in interface PostURLTransfer.TransferHolderpublic void setAppletTransferCache(java.util.HashMap<java.lang.String,java.lang.Long> transferCache)
public double getPacketLossPercent()
TransferStategetPacketLossPercent in interface TransferStategetPacketLossPercent in class TransferHookpublic int getRoundTripTime()
TransferStategetRoundTripTime in interface TransferStategetRoundTripTime in class TransferHookpublic int getVerifyMode()
public void setVerifyMode(int verifyMode)
verifyMode - the verifyMode to setpublic int validateVerifyMode(int verifyMode)
protected void enableVerifySizeIfNeeded()
public boolean verifierRunning()
public int getMd5RateLimit()
getMd5RateLimit in interface FilesMatchHandlerpublic void setMd5RateLimit(int md5RateLimit)
md5RateLimit - the md5RateLimit to setpublic boolean isRenameExtensions()
public void setRenameExtensions(boolean renameExtensions)
renameExtensions - the renameExtensions to setpublic long getZipFileSizeLimit()
public void setZipFileSizeLimit(long zipFileSizeLimit)
zipFileSizeLimit - the zipFileSizeLimit to setpublic boolean isDowngradeModeOnReConnect()
public void setDowngradeModeOnReConnect(boolean downgradeModeOnReConnect)
downgradeModeOnReConnect - the downgradeModeOnReConnect to setpublic long getCurrentFileTime()
protected int calculateAverageKbpsRate(long bytesTotal,
long msTotal)
bytesTotal - - total bytesmsTotal - - total time span in millisecondspublic long getCurrentFileTransferTime()
TransferStategetCurrentFileTransferTime in interface TransferStategetCurrentFileTransferTime in class TransferHookpublic int getDirection()
TransferStategetDirection in interface TransferStategetDirection in class TransferHookpublic java.lang.String getRemoteFilename()
TransferStategetRemoteFilename in interface TransferStategetRemoteFilename in class TransferHookpublic java.lang.String getLocalFilename()
TransferStategetLocalFilename in interface TransferStategetLocalFilename in class TransferHookpublic void logFinalTransferStats(java.nio.file.Path file)
file - public FileCatalystFileFilter getFilter()
public void setFilter(FileCatalystFileFilter filter)
filter - the filter to setprotected boolean passesProgressiveTimeoutFilter(java.lang.String sourceFile)
public int calculateEffectiveRateOfZipTransfer(long sizeOfAllFilesZipped,
long timeForEffectiveRate)
protected void verifySize(java.nio.file.Path file,
java.lang.String rFile)
protected void verifyFileContents(java.nio.file.Path file,
java.lang.String rfile,
boolean invalidateRemoteCache)
throws FCException,
java.io.IOException
FCExceptionjava.io.IOExceptionprotected void incrementSofarAllFiles(boolean isADeltaTransfer,
long dataSize)
protected abstract boolean doesDirectoryContainContents(T t)
protected void filterEmptyDirectoriesIfNeeded()
public void setParentPooled(boolean pooled)
public FCClientEngine getClient()
getClient in interface FilesMatchHandlerpublic void logMessage(java.util.logging.Level info,
java.lang.String string)
logMessage in interface PostURLTransfer.TransferHolderlogMessage in interface FilesMatchHandlerpublic long getAvgMD5TimePerKB()
getAvgMD5TimePerKB in interface FilesMatchHandlerpublic void setAvgMD5TimePerKB(long avgMD5TimePerKB)
setAvgMD5TimePerKB in interface FilesMatchHandlerpublic CancelHandler getCancelHandler()
getCancelHandler in interface FilesMatchHandlerpublic static java.lang.String getPreservePathStructureFileName(java.lang.String lFile)
public void setAutoUnzip(boolean b)
public boolean isAutoUnzip()
public void addTransferredRemoteFile(java.lang.String filename)
public void addTransferredLocalFile(java.lang.String filename)
public static void waitForDiscWriteProgressives(MultiTransferHandler<?> handler)
public void handleProgressiveDelayBeforeAppend()
protected final void updateStatusTransferring()
public long getRetransferHeaderSize()
public void setRetransferHeaderSize(long retransferHeaderSize)
retransferHeaderSize - the retransferHeaderSize to setpublic FCClient getClientAPI()
public void setClientAPI(FCClient clientAPI)
clientAPI - the clientAPI to setpublic void killAll()
killAll in class TransferHookpublic void setLocalMD5(java.lang.String localMD5)
setLocalMD5 in interface FilesMatchHandlerpublic void setRemoteMD5(java.lang.String remoteMD5)
setRemoteMD5 in interface FilesMatchHandler