Package unlimited.fc.client.transferhandler

Class FileCatalystTransmitHandler

java.lang.Object

java.util.Observable

unlimited.fc.client.api.TransferHook

unlimited.fc.client.transferhandler.MultiTransferHandler<java.nio.file.Path>

unlimited.fc.client.transferhandler.FileCatalystTransmitHandler

All Implemented Interfaces:

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

public class FileCatalystTransmitHandler
extends MultiTransferHandler<java.nio.file.Path>

Title:

Description:

Copyright: Copyright (c) 2006

Company: Unlimi-Tech Software Inc.

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
FileCatalystTransmitHandler(FCClientEngine fcClient, java.util.List<java.nio.file.Path> files, int blockSize, int unitSize, int numCodecs, int bandwidth, boolean verify, boolean keepModificationDateTime, boolean keepPermissions, boolean preservePathStructure)
FileCatalystTransmitHandler(FCClientEngine fcClient, java.util.List<java.nio.file.Path> files, int blockSize, int unitSize, int numCodecs, int bandwidth, boolean verify, boolean keepModificationDateTime, boolean keepPermissions, boolean preservePathStructure, boolean recurse, CachedFileIndexInterface fileTransferIndex, java.nio.file.Path basePath)
FileCatalystTransmitHandler(FCClientEngine fcClient, java.util.List<java.nio.file.Path> files, java.util.List<java.lang.String> renameVector, int blockSize, int unitSize, int numCodecs, int bandwidth, boolean verify, boolean keepModificationDateTime, boolean keepPermissions, boolean preservePathStructure)

Method Summary

Modifier and Type	Method	Description
void	addToQueue(java.nio.file.Path f)
void	doBenchMark()
protected boolean	doesDirectoryContainContents(java.nio.file.Path t)
void	flagSymlinkFolderForDeletion(java.nio.file.Path file)
java.nio.file.Path	getCurrentFileObject()
java.lang.String	getDmgFileName()
java.util.List<java.nio.file.Path>	getFiles()
int	getMaxAgeSentItemsDays()
int	getSignatureTransferMode()
java.lang.String	getZipFilename()
boolean	isAutoDMG()
boolean	isMoveToSent()
void	refreshInfo()
protected java.lang.String	renameTempFile(java.lang.String originalName, java.lang.String destFile)
void	runHandler()
void	setAutoDMG(boolean autoDMG)
void	setDmgFileName(java.lang.String dmgFileName)
void	setMaxAgeSentItemsDays(int maxAgeSentItemsDays)
void	setMoveToSent(boolean moveToSent, java.lang.String sentPath)
void	setRenameVector(java.util.List<java.lang.String> renameVector)
void	setSignatureTransferMode(int signatureTransferMode)
void	setZipFilename(java.lang.String zipFilename)
protected long	waitForSourceFileToBeStaticIfRequired(java.nio.file.Path 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

FileCatalystTransmitHandler

public FileCatalystTransmitHandler(FCClientEngine fcClient,
                                   java.util.List<java.nio.file.Path> files,
                                   int blockSize,
                                   int unitSize,
                                   int numCodecs,
                                   int bandwidth,
                                   boolean verify,
                                   boolean keepModificationDateTime,
                                   boolean keepPermissions,
                                   boolean preservePathStructure)

FileCatalystTransmitHandler

public FileCatalystTransmitHandler(FCClientEngine fcClient,
                                   java.util.List<java.nio.file.Path> files,
                                   java.util.List<java.lang.String> renameVector,
                                   int blockSize,
                                   int unitSize,
                                   int numCodecs,
                                   int bandwidth,
                                   boolean verify,
                                   boolean keepModificationDateTime,
                                   boolean keepPermissions,
                                   boolean preservePathStructure)

FileCatalystTransmitHandler

public FileCatalystTransmitHandler(FCClientEngine fcClient,
                                   java.util.List<java.nio.file.Path> files,
                                   int blockSize,
                                   int unitSize,
                                   int numCodecs,
                                   int bandwidth,
                                   boolean verify,
                                   boolean keepModificationDateTime,
                                   boolean keepPermissions,
                                   boolean preservePathStructure,
                                   boolean recurse,
                                   CachedFileIndexInterface fileTransferIndex,
                                   java.nio.file.Path basePath)

Method Detail

addToQueue

public void addToQueue(java.nio.file.Path f)

getFiles

public java.util.List<java.nio.file.Path> getFiles()

runHandler

public void runHandler()

Specified by:

runHandler in class MultiTransferHandler<java.nio.file.Path>

refreshInfo

public void refreshInfo()

waitForSourceFileToBeStaticIfRequired

protected long waitForSourceFileToBeStaticIfRequired(java.nio.file.Path file,
                                                     long soureFileSize)
                                              throws java.io.IOException

Throws:

java.io.IOException

isMoveToSent

public boolean isMoveToSent()

setMoveToSent

public void setMoveToSent(boolean moveToSent,
                          java.lang.String sentPath)
                   throws java.io.IOException

Throws:

java.io.IOException

doBenchMark

public void doBenchMark()

Parameters:

startTime -

isAutoDMG

public boolean isAutoDMG()

getDmgFileName

public java.lang.String getDmgFileName()

getZipFilename

public java.lang.String getZipFilename()

getCurrentFileObject

public java.nio.file.Path getCurrentFileObject()

getMaxAgeSentItemsDays

public int getMaxAgeSentItemsDays()

setAutoDMG

public void setAutoDMG(boolean autoDMG)

setDmgFileName

public void setDmgFileName(java.lang.String dmgFileName)

setZipFilename

public void setZipFilename(java.lang.String zipFilename)

setMaxAgeSentItemsDays

public void setMaxAgeSentItemsDays(int maxAgeSentItemsDays)

getSignatureTransferMode

public int getSignatureTransferMode()

Returns:

the signatureTransferMode

setSignatureTransferMode

public void setSignatureTransferMode(int signatureTransferMode)

Parameters:

signatureTransferMode - the signatureTransferMode to set

renameTempFile

protected java.lang.String renameTempFile(java.lang.String originalName,
                                          java.lang.String destFile)
                                   throws java.io.IOException

Throws:

java.io.IOException

doesDirectoryContainContents

protected boolean doesDirectoryContainContents(java.nio.file.Path t)

Specified by:

doesDirectoryContainContents in class MultiTransferHandler<java.nio.file.Path>

flagSymlinkFolderForDeletion

public void flagSymlinkFolderForDeletion(java.nio.file.Path file)

setRenameVector

public void setRenameVector(java.util.List<java.lang.String> renameVector)