public class TransferMechanismData extends unlimited.core.util.common.ConfigTool implements FileTransferData, java.lang.Cloneable
| Modifier and Type | Class and Description |
|---|---|
class |
TransferMechanismData.ServletLocationData
Data object that contains the current Servlet information.
|
| Modifier and Type | Field and Description |
|---|---|
protected CompressionData |
compressionData |
| Constructor and Description |
|---|
TransferMechanismData()
Default constructor for the TranfserMechanismData class
|
TransferMechanismData(java.util.Properties incProperties)
Constructor that loads a TransferMechanismData object from a supplied properties object
|
| Modifier and Type | Method and Description |
|---|---|
void |
cd(java.lang.String path)
Sets the current remote working directory to the specified path.
|
TransferMechanismData |
clone()
Clone method that generates an independent copy of this object
|
void |
delete(java.lang.String file)
Do not use this method, it only throws an exception, was put in during the effort to unify listings between single and multi client
|
static void |
exportFile(java.nio.file.Path aFile,
FileTransferData source)
Exports the supplied FileTransferData data as properties and writes the information to the specified file path
|
static java.util.Properties |
exportProperties(FileTransferData source)
Exports the supplied FileTransferData data into a standard properties object
|
void |
get(java.lang.String localPath,
java.lang.String remoteFile,
int inRate,
long offset,
long size,
int numDFEncoders,
int blockSize,
int unitSize,
int mode)
Do not use this method, it only throws an exception, was put in during the effort to unify listings between single and multi client
|
int |
getBlastRate()
Returns the implementation's current blast rate
|
int |
getBlockSize()
Return the current block size.
|
FileCatalystClientCallbackHandler |
getCallbackHandler()
Returns the currently set callback handler that will be used to confirm resume, overwrite and to do post processing
|
java.lang.String |
getClientAgentID()
Returns the client's agent ID.
|
java.lang.String |
getClientConnectKey()
Returns the client connect key, used to connect to non-FileCatalyst servers
|
java.util.function.Supplier<ClientCredentials> |
getClientCredentials()
Returns the credentials supplier that is set for this client.
|
int |
getClientIdentifier()
Returns the identifier for this transfer mechanism.
|
java.lang.String |
getClientName()
Used for HotFolder Reporting, And CSV Reports
|
java.lang.String |
getClientString()
Returns the client string for this transfer mechanism.
|
int |
getClientSubIdentifier()
Returns the current sub identifier that identifies this client as a sub component of a broader group of client apps.
|
java.lang.String |
getCompFileFilter()
Sets the compression FileFilter that is to be used by the implementation.
|
int |
getCompLevel()
Returns the current compression level (0 - 9).
|
int |
getCompMethod()
Returns the current compression method to be used during transfers.
|
CompressionData |
getCompressionData()
Returns a data object containing the compression data for the TransferMechanism
|
int |
getCompStrategy()
Returns the current compression deflater strategy that will be used in the current compression method to minimize the data and compress into smaller byte values.
|
int |
getCongCtrlStrategy()
Returns the current congestion control strategy.
|
int |
getCongestionControlAggression()
Returns an aggression factor between 1 (passive) and 10 (aggressive) used by the congestion control mechanism to
determine how passive or aggressive it should be in the face of network congestion.
|
int |
getConnectTimeout()
Return the connect timeout value (in milliseconds)
|
int |
getExtendedReadTimeout()
This is the length of time in milliseconds the client will wait for a reply after sending a long running command (such as MD5,
MKDLT, MKSIG, ZIP, UNZIP) to the FileCatalyst server.
|
FileCatalystFileFilter |
getFileFilter()
Returns the current file filter that is used to filter out information for a transfer.
|
int |
getFileTransferPriority()
Returns the task file transfer priority
|
java.lang.String |
getForceFileOwnershipGroup()
Returns the groupname / groupID to be used when attempting to force group level ownership for files downloaded by the client.
|
java.lang.String |
getForceFileOwnershipUser()
Returns the username to be used when attempting to force file ownership for files downloaded by the client
|
int |
getIncomingDataPort()
Returns the port used for incoming UDP packets on downloads
Only the first port will be returned in the case of v3.0 where multi-receive sockets have been enabled.
|
int[] |
getIncomingDataPorts()
Returns the list of ports used for incoming UDP packets on downloads
|
int |
getIncrementalMode()
Returns the current incremental mode.
|
java.nio.file.Path |
getLocalWorkingDirectoryPath() |
unlimited.core.util.common.logs.LogUtils |
getLogger()
Returns the logger that is used
|
java.lang.String |
getLogLocation()
Returns the current location for the log files.
|
int |
getMaxRetries()
Returns the number of times to retry a broken or interrupted transfer.
|
int |
getMd5RateLimit()
Returns the current MD5 that is set.
|
int |
getMode()
The current transfer mode of this client.
|
int |
getNumBlockReaders()
Returns the number of block reader threads.
|
int |
getNumBlockWriters()
Returns the number of block writer threads.
|
int |
getNumFTPStreams()
Returns the number of concurrent streams that will be used for FTP transfers
|
int |
getNumPacketProcessors()
Return the current number of packet processor threads.
|
int |
getNumReceiveSockets()
Returns the current number of receive sockets.
|
int |
getNumSenderSockets()
Return the number of Sender sockets to use
|
int |
getNumSenderThreads()
Returns the number of threads that will be used at most for each FC transmission.
|
int |
getNumThreads()
Returns the number of threads that will be used at most for each FC transmission.
|
int |
getNumUDPSockets()
Return the number of Sender sockets to use
|
java.util.Observer |
getObserver()
Returns the Observer that is currently set.
|
int |
getPacketQueueDepth()
Return the current packet queue depth.
|
int |
getPacketSize()
Returns the current packet size in bytes.
|
PostTaskSentData |
getPostTaskSentData()
Returns the current post task sent data
|
java.lang.String |
getPostURL()
Returns the current post URL to use
|
int |
getProgressiveTimeout()
Returns the current progressive timeout value.
|
java.lang.String |
getProgressiveTimeoutFilter()
Returns the current progressive timeout filter.
|
int |
getReadBufferSizeKB()
Return the current read buffer size, in KB
Value zero (0) indicates read buffer is dictated by the network block size.
|
int |
getReadTimeout()
This is the length of time in milliseconds the client will wait for a reply after sending a command to the FileCatalyst server.
|
int |
getRemotePort()
Gets the remote port to which this client will be connected.
|
java.lang.String |
getRemoteServer()
This method returns the remote server / hostname to which this client is connected.
|
boolean |
getRenameExtension()
Returns whether or not the rename extension will be used.
|
java.lang.String |
getServerAgentID()
Returns the server's current agent ID.
|
int |
getServerOverrideBandwidth()
Returns the override bandwidth value that has been specified by server.
|
java.lang.String |
getServletLocation()
FileCatalyst has the ability to upload using the HTTP/S protocol as long as the FileCatalyst Servlet application is
installed and properly configured.
|
TransferMechanismData.ServletLocationData |
getServletLocationData()
Generates and returns a data object containing all of the information relating to the Servlet
|
int |
getServletMultiplier()
When uploading in HTTP mode using FileCatalyst Servlet, this option allows the upload buffer size to be tuned.
|
int |
getSessionCount()
Returns the current number of active sessions that the implementation has
|
java.lang.String |
getSessionID()
Returns the current session ID of the implementation
|
unlimited.core.transfers.net.ssl.FCSSLSocketProducerImpl |
getSSLSocketProducer()
Retrieves the implementation that will be used to generate SSL sockets
|
int |
getStartRate()
Returns the current start rate for FC transfers.
|
void |
getSynchedFrom(FileTransferData master)
Syncs the supplied FileTransferData instance to this data object.
|
int |
getTargetRate()
Returns the current target rate for this client.
|
java.lang.String |
getTaskID()
Returns the current task ID
|
int |
getTempMode()
Returns the temporary mode for the implementation
|
java.lang.String |
getTransactionID()
Returns the current transaction ID that is set.
|
boolean |
getTransferEmptyDirectories()
Returns whether not the implementation is set to transfer empty directories.
|
int |
getTransferRate()
Returns the implementation's current transfer rate
|
int |
getUnitSize()
Use getPacketSize
|
int |
getUserRelativePriority()
This priority hint is to help the server distribute bandwidth within its own set parameters.
|
int |
getVerifyMode()
Returns the current integrity verification mode.
|
long |
getWaitRetry()
Returns the amount of milliseconds to wait between retries for failed transfers.
|
int |
getWriteBufferSizeKB()
Return the current write buffer size.
|
java.lang.String |
getWriteFileMode()
Gets the file write mode set
Client application will use these values for downloads only.
|
long |
getZipFileSizeLimit()
Returns the zip file size limit in bytes.
|
static void |
importFile(java.nio.file.Path aFile,
FileTransferData destination)
Imports the properties defined within a file, and synchs them with to the supplied FileTransferData object
|
static void |
importProperties(java.util.Properties props,
FileTransferData destination)
Imports the properties information and synchs them with to the supplied FileTransferData object
|
void |
initializeWorkingDirectory(java.lang.String pwd)
Initializes the current working directory to the value specified.
|
boolean |
isAutoResume()
Returns true if auto-resume is enabled.
|
boolean |
isAutoUnzip()
Returns true if auto unzip is enabled, false otherwise.
|
boolean |
isAutoZip()
Returns true if auto zip is enabled, false otherwise.
|
boolean |
isCompressionEnabled()
Returns true if compression is enabled, false otherwise.
|
boolean |
isCongestionControlEnabled()
Returns true if congestion control is currently enabled.
|
boolean |
isCurrentStateConnected()
Returns whether or not the current transfer mechanism is connected
|
boolean |
isDebug()
Returns true if debug is set to true.
|
boolean |
isDeleteAfterTransfer()
Returns true if the delete after transfer option is enabled, false otherwise.
|
boolean |
isDowngradeModeOnReConnect()
Returns true if the downgrade on reconnect option is enabled, false otherwise.
|
boolean |
isFileCatalystServer()
Do not use this method, it only throws an exception, was put in during the effort to unify listings between single and multi client
|
boolean |
isForceFileOwnershipEnabled()
Returns true if the force file ownership feature is currently enabled.
|
boolean |
isForceTCPmodeACKs()
Returns true if TCP mode ACKs are enabled.
|
boolean |
isIncrementalSizeCheckOnly()
Returns whether or not incremental has been set to use the size only option
|
boolean |
isMaintainLastModified()
Returns true if Maintain last modified is enabled.
|
boolean |
isMaintainPermissions()
Returns true if maintain permissions is enabled.
|
boolean |
isOptimizeBlockSize()
Returns true if optimize block size feature is enabled.
|
boolean |
isProgressiveTransfers()
Return true if the progressive option is enabled, false otherwise.
|
boolean |
isServerOverridebandwidth()
Returns whether or not the server has specified that the bandwidth should be overridden.
|
boolean |
isShowConsoleLog()
Returns true if console log is enabled.
|
boolean |
isTransferEmptyDirectories()
Returns whether or not the implementation should be transferring empty directories
|
boolean |
isTransferWithTempName()
Returns true if transferring with temporary names is enabled
|
boolean |
isUseCompression()
Returns true if compression is enabled, false otherwise.
|
boolean |
isUseCongestionControl()
Returns true if congestion control is currently enabled.
|
boolean |
isUseIncremental()
Returns true if incremental feature is enabled
|
boolean |
isUseSSL()
Returns true if SSL mode is enabled, false otherwise.
|
boolean |
isVerifyIntegrity()
Returns true if integrity check is enabled.
|
boolean |
isWorkingDirectoryInitialized()
Returns whether or not the working directory is currently initialized.
|
int |
lastServerRestrictedRate()
Returns the last rate (kbps) that the Server had replied with.
|
FileListData |
list()
Do not use this method, it only throws an exception, was put in during the effort to unify listings between single and multi client
|
protected void |
loadFromChannel(java.nio.channels.SeekableByteChannel channel) |
void |
loadFromFile(java.nio.file.Path propFile) |
void |
loadFromProperties() |
java.lang.String[] |
prms(java.lang.String filename)
Do not use this method, it only throws an exception, was put in during the effort to unify listings between single and multi client
|
java.lang.String |
pwd()
Returns the current remote working directory.
|
void |
saveToFile(java.nio.file.Path propFile) |
void |
saveToProperties() |
void |
setAutoResume(boolean autoResume)
Enables/disables auto resume feature.
|
void |
setAutoUnzip(boolean autoUnzip)
Enables/disables auto unzip feature.
|
void |
setAutoZip(boolean autoZip)
Enables/disables auto zip feature.
|
void |
setBlockSize(int blockSize)
Set the block size.
|
void |
setCallbackHandler(FileCatalystClientCallbackHandler callbackHandler)
Sets a callback handler that will be used to confirm resume, overwrite and to do post processing
|
void |
setClientAgentID(java.lang.String clientAgentID)
Sets the current client agent ID to the new specified value.
|
void |
setClientConnectKey(java.lang.String clientConnectKey)
This key must be set in order to connect to non-FileCatalyst servers.
|
void |
setClientCredentials(java.util.function.Supplier<ClientCredentials> creds)
Sets the credentials supplier for this connection.
|
void |
setClientIdentifier(int clientIdentifier)
An ID value that identifies this client to the FileCatalyst Server.
|
void |
setClientName(java.lang.String clientName)
Sets the current client name to the value that is specified
|
void |
setClientString(java.lang.String clientString)
Set a text string that will be displayed on the server UI to identify
this client.
|
void |
setClientSubIdentifier(int id)
Sets an ID that further identifies this client
|
void |
setClientWorkingPath(java.nio.file.Path clientWorkingPath)
Sets the client's current working path to the value specified
|
void |
setCompFileFilter(java.lang.String compFileFilter)
Sets the compression FileFilter that is to be used by the implementation
|
void |
setCompLevel(int compLevel)
Sets the compression level (0 - 9 with default of 4).
|
void |
setCompMethod(int compMethod)
Sets the current compression method to be used during transfers.
|
void |
setCompressionData(CompressionData compressionData) |
void |
setCompressionDataFromClient(FileTransferMechanism client) |
void |
setCompressionEnabled(boolean compressionEnabled)
Enables/disables on the fly compression.
|
void |
setCompStrategy(int compStrategy)
Sets the compression deflater strategy that will be used within the compression method to minimize the data and compress into smaller byte values.
|
void |
setCongCtrlStrategy(int congCtrlStrategy)
Sets the congestion control strategy.
|
void |
setCongestionControlAggression(int congestionControlAggression)
Specifies an aggression factor between 1 (passive) and 10 (aggressive) used by the congestion control mechanism to
determine how passive or aggressive it should be in the face of network congestion.
|
void |
setCongestionControlEnabled(boolean congestionControlEnabled)
Enables/disables congestion control for this client.
|
void |
setConnectTimeout(int connectTimeout)
Sets the connect timeout value (in milliseconds).
|
void |
setCurrentStateConnected(boolean currentStateConnected) |
void |
setDebug(boolean debug)
Turns on debug mode.
|
void |
setDeleteAfterTransfer(boolean deleteAfterTransfer)
With this option enabled, source files will be deleted after the transfer is complete.
|
void |
setDowngradeModeOnReConnect(boolean downgradeModeOnReConnect)
If set to true, if a disconnect occurs during a UDP transfer, upon reconnect
and resume, the transfer mode is downgraded to multi-stream TCP, then single
stream TCP, and finally HTTP (if available).
|
void |
setExtendedReadTimeout(int extendedReadTimeout)
This is the length of time the client will wait for a reply after sending a long running command (such as MD5,
MKDLT, MKSIG, ZIP, UNZIP) to the FileCatalyst server.
|
void |
setFileFilter(FileCatalystFileFilter fileFilter)
Sets the FileFilter that is to be used by the implementation.
|
void |
setFileTransferPriority(int fileTransferPriority)
Sets the FileTransferPrioriry to new new value.
|
void |
setForceFileOwnershipEnabled(boolean isForceFileOwnershipEnabled)
Sets whether or not the force file ownership feature is enabled.
|
void |
setForceFileOwnershipGroup(java.lang.String forceFileOwnershipGroup)
Sets the groupname / groupID to be used when attempting to force group level ownership for files downloaded by the client.
|
void |
setForceFileOwnershipUser(java.lang.String forceFileOwnershipUser)
Sets the username to be used when attempting to force file ownership for files downloaded by the client
|
void |
setForceTCPmodeACKs(boolean forceTCPmodeACKs)
By default, FileCatalyst uses UDP to acknowledge data received.
|
void |
setIncomingDataPort(int incomingDataPort)
Sets the port used for incoming UDP packets on downloads.
|
void |
setIncomingDataPorts(int[] incomingDataPorts)
Sets the port used for incoming UDP packets on downloads.
|
void |
setIncrementalMode(int incrementalMode)
When incremental is enabled, this method allows you to choose the incremental mode.
|
void |
setIncrementalSizeCheckOnly(boolean incrementalSizeCheckOnly)
Setting this value will cause the MD5 checks to be skipped and the files compared using size only.
|
void |
setIsAuto(boolean isAutoMode) |
void |
setIsServerOverrideBandwidth(boolean isOverride) |
void |
setLastServerRestrictedRate(int actual) |
void |
setLocalWorkingDirectory(java.nio.file.Path localWorkingDirecctory)
Sets the Local Working directory.
|
void |
setLogger(unlimited.core.util.common.logs.LogUtils logger)
overriding the logUtils object.
|
void |
setLogLocation(java.lang.String logLocation)
Specifies a directory on the local system where the log file should be stored.
|
void |
setMaintainLastModified(boolean maintainLastModified)
Sets the maintain last modified feature to the value specified.
|
void |
setMaintainPermissions(boolean maintainPermissions)
If set to true, upon each successful transfer, the destination file permissions will be set to match those of the
source file.
|
void |
setMaxRetries(int maxRetries)
Specify the number of times to retry a broken or interrupted transfer.
|
void |
setMd5RateLimit(int md5RateLimit)
Sets the rate limit to use when calculating MD5s of files
|
void |
setMode(int mode)
Set the transfer mode of this client.
|
void |
setNumBlockReaders(int numBlockReaders)
Sets the number of block reader threads.
|
void |
setNumBlockWriters(int numBlockWriters)
Sets the number of block writer threads to use when receiving a file.
|
void |
setNumFTPStreams(int numFTPStreams)
When transferring in FTP mode, it is possible to send with several concurrent streams.
|
void |
setNumPacketProcessors(int numPacketProcessors)
Sets the number of threads used to process incoming UDP packets when downloading.
|
void |
setNumReceiveSockets(int numReceiveSockets)
Set the number of UDP sockets to use to receive packets during a UDP download.
|
void |
setNumSenderSockets(int numSenderSockets)
Sets the number of UDP sockets to use when uploading a file in UDP mode.
|
void |
setNumSenderThreads(int numSenderThreads)
This value determines how many blocks will be sent into the pipe before redundant data will be sent.
|
void |
setNumThreads(int numThreads)
This value determines how many blocks will be sent into the pipe before redundant data will be sent.
|
void |
setNumUDPSockets(int numUDPSockets)
Sets the number of UDP sockets to use when uploading a file in UDP mode.
|
void |
setObserver(java.util.Observer obs)
FCClient is not directly observable, however TransferHook is.
|
void |
setOptimizeBlockSize(boolean optimizeBlockSize)
If set to true, FileCatalyst will attempt to optimize the current block size to be an exact multiple of the data
size that is being transmitted.
|
void |
setPacketQueueDepth(int packetQueueDepth)
Sets the depth of the application level packet queue.
|
void |
setPacketSize(int packetSize)
Set the unit size.
|
void |
setPostTaskSentData(PostTaskSentData data)
Sets the current post task sent data to the specified value
|
void |
setPostURL(java.lang.String postURL)
Sets the current post URL to the value that is defined
|
void |
setProgressiveTimeout(int progressiveTimeout)
Sets the current progressive timeout to the value supplied
|
void |
setProgressiveTimeoutFilter(java.lang.String progressiveTimeoutFilter)
Sets the current progressive timeout filter to the value that is set to
|
void |
setProgressiveTransfers(boolean progressiveTransfers)
With this option enabled, upon completion of an upload or download, FileCatalyst will compare the size of the
source file to the size when it began the transfer.
|
void |
setReadBufferSizeKB(int readBufferSizeKB)
Sets the read buffer size used when reading data from disk.
|
void |
setReadTimeout(int readTimeout)
This is the length of time the client will wait for a reply after sending a command to the FileCatalyst server.
|
void |
setRemotePort(int remotePort)
Sets the remote port to which this client will be connected.
|
void |
setRemoteServer(java.lang.String remoteServer)
Set the remote server to which this client should connect.
|
void |
setRenameExtension(boolean renameExtension)
Sets whether or not the rename extension should be used
|
void |
setServerAgentID(java.lang.String serverAgentID)
Sets the server agent ID to the new value
|
void |
setServerOverrideBandwidth(int totalOverridebandwidth) |
void |
setServletLocation(java.lang.String servletLocation)
FileCatalyst has the ability to upload using the HTTP/S protocol as long as the FileCatalyst Servlet application is
installed and properly configured.
|
void |
setServletLocation(java.lang.String servletLocation,
java.lang.String servletSessionID,
java.lang.String welcomeMessage)
FileCatalyst has the ability to upload using the HTTP/S protocol as long as the FileCatalyst Servlet application is
installed and properly configured.
|
void |
setServletMultiplier(int servletMultiplier)
When uploading in HTTP mode using FileCatalyst Servlet, this option allows the upload buffer size to be tuned.
|
void |
setSessionCount(int sessionCount) |
void |
setSessionID(java.lang.String sessionID)
Sets the session ID to the specified value.
|
void |
setShowConsoleLog(boolean showConsoleLog)
If set to true, all logging information is also sent to standard out.
|
void |
setSSLSocketProducer(unlimited.core.transfers.net.ssl.FCSSLSocketProducerImpl socketProducer)
Sets the implementation that will be used to generate SSL sockets
|
void |
setStartRate(int startRate)
Sets the start rate for FC transfers in Kilobits per second.
|
void |
setTargetRate(int targetRate)
Sets the target rate (kbps) for this client.
|
void |
setTaskID(java.lang.String taskID)
Sets the current task ID to the new value supplied
|
void |
setTransactionID(java.lang.String uniqueID)
Sets a unique transaction number for the transfer (instance variable).
|
void |
setTransferEmptyDirectories(boolean transferEmptyDirectories)
Sets whether or not the implementation should transfer empty directories
|
void |
setTransferRate(int transferRate) |
void |
setTransferToServerOverride(int serverOverrideBW)
Sets bandwidth value that the Server is attempting to override this client to.
|
void |
setTransferWithTempName(boolean transferWithTempName)
With this option enabled, files will be uploaded with a temporary filename and renamed back to their original name
when the transfer is complete.
|
void |
setTransferWithTempName(boolean transferWithTempName,
int tempMode)
With this option enabled, files will be uploaded with a temporary filename and renamed back to their original name
when the transfer is complete.
|
void |
setUnitSize(int unitSize)
Use setPacketSize()
|
void |
setUseCompression(boolean useCompression)
Enables/disables on the fly compression.
|
void |
setUseCongestionControl(boolean useCongestionControl)
Enables/disables congestion control for this client.
|
void |
setUseIncremental(boolean useIncremental)
If set to true, before each source file is transferred, it will be compared with the destination file if it exists
to ensure the file has changed.
|
void |
setUserRelativePriority(int priority)
This priority hint is to help the server distribute bandwidth within its own set parameters.
|
void |
setUseSSL(boolean useSSL)
If set to true, control connection will be made using an implicit SSL connection.
|
void |
setVerifyIntegrity(boolean verifyIntegrity)
If set to true, after each file is transferred an MD5 sum will be performed on the destination file and the result
will be compared to that of the source file to ensure the files are identical.
|
void |
setVerifyMode(int verifyMode)
Sets the integrity verification mode
|
void |
setWaitRetry(long waitRetry)
Sets the amount of time in milliseconds to wait before the client attempts to retry a failed transfer
|
void |
setWriteBufferSizeKB(int writeBufferSizeKB)
Sets the write buffer size used when saving data to disk.
|
void |
setWriteFileMode(java.lang.String writeFileMode)
Set JAVA file write mode when saving data to disk.
|
void |
setZipFileSizeLimit(long zipFileSizeLimit)
Sets the zip file size limit to the value specified.
|
long |
size(java.lang.String remoteFile)
Do not use this method, it only throws an exception, was put in during the effort to unify listings between single and multi client
|
java.util.stream.Stream<FileListDataItem> |
streamWithInlineParse()
Do not use this method, it only throws an exception, was put in during the effort to unify listings between single and multi client
|
java.util.stream.Stream<FileListDataItem> |
streamWithInlineParse(java.util.function.BooleanSupplier isCancelled)
Returns streaming meta data for files in the current remote directory.
|
static void |
synch(FileTransferData client,
FileTransferData master) |
static void |
synchAndConnect(FileTransferMechanism client,
FileTransferData master) |
static void |
synchConnectAndCD(FileTransferMechanism client,
FileTransferData master) |
static void |
synchIgnoreTargetRate(FileTransferData client,
FileTransferData master) |
void |
synchThisTo(FileTransferData slave)
Syncs this Servlet information to the specified FileTransferData instance
|
buildHandlerMap, getVal, registerMapping, setValgetProperty, getProperty, list, list, load, load, loadFromXML, propertyNames, save, setProperty, store, store, storeToXML, storeToXML, stringPropertyNamesclear, compute, computeIfAbsent, computeIfPresent, contains, containsKey, containsValue, elements, entrySet, equals, forEach, get, getOrDefault, hashCode, isEmpty, keys, keySet, merge, put, putAll, putIfAbsent, rehash, remove, remove, replace, replace, replaceAll, size, toString, valuesfinalize, getClass, notify, notifyAll, wait, wait, waitgetAutoConnectClientFactory, getLocalWorkingDirectory, isMoveToSent, setLocalWorkingDirectoryprotected CompressionData compressionData
public TransferMechanismData(java.util.Properties incProperties)
incProperties - Properties object containing the transfer mechanism datapublic TransferMechanismData()
public TransferMechanismData clone()
clone in class java.util.Hashtable<java.lang.Object,java.lang.Object>public int getBlastRate()
FileTransferDatagetBlastRate in interface FileTransferDatapublic int getBlockSize()
FileTransferDatagetBlockSize in interface FileTransferDatapublic FileCatalystClientCallbackHandler getCallbackHandler()
FileTransferDatagetCallbackHandler in interface FileTransferDatapublic java.lang.String getClientAgentID()
public java.lang.String getClientConnectKey()
FileTransferDatagetClientConnectKey in interface FileTransferDatapublic int getClientIdentifier()
FileCatalystClientIdentifiersgetClientIdentifier in interface FileTransferDatapublic java.lang.String getClientString()
public int getClientSubIdentifier()
public java.lang.String getCompFileFilter()
FileTransferDatagetCompFileFilter in interface FileTransferDatapublic int getCompLevel()
FileTransferDatagetCompLevel in interface FileTransferDatapublic int getCompMethod()
FileTransferDataThe available compression strategies that can be used are as follows:
getCompMethod in interface FileTransferDatapublic CompressionData getCompressionData()
public int getCompStrategy()
FileTransferDataValid return values are:
getCompStrategy in interface FileTransferDatapublic int getCongCtrlStrategy()
FileTransferDataThe possible options are:
CongestionControlType.RTT)CongestionControlType.LOSS)CongestionControlType.BSS)getCongCtrlStrategy in interface FileTransferDatapublic int getCongestionControlAggression()
FileTransferDatagetCongestionControlAggression in interface FileTransferDatapublic int getConnectTimeout()
FileTransferDatagetConnectTimeout in interface FileTransferDatapublic int getExtendedReadTimeout()
FileTransferDatagetExtendedReadTimeout in interface FileTransferDatapublic FileCatalystFileFilter getFileFilter()
FileTransferDatagetFileFilter in interface FileTransferDatapublic java.lang.String getClientName()
FileTransferDatagetClientName in interface FileTransferDatapublic int getIncomingDataPort()
FileTransferDatagetIncomingDataPort in interface FileTransferDatapublic int[] getIncomingDataPorts()
FileTransferDatagetIncomingDataPorts in interface FileTransferDatapublic int getIncrementalMode()
FileTransferDatagetIncrementalMode in interface FileTransferDatapublic java.nio.file.Path getLocalWorkingDirectoryPath()
getLocalWorkingDirectoryPath in interface FileTransferDatapublic unlimited.core.util.common.logs.LogUtils getLogger()
FileTransferDatagetLogger in interface FileTransferDatapublic java.lang.String getLogLocation()
FileTransferDatagetLogLocation in interface FileTransferDatapublic int getMaxRetries()
FileTransferDatagetMaxRetries in interface FileTransferDatapublic int getMd5RateLimit()
FileTransferDatagetMd5RateLimit in interface FileTransferDatapublic int getMode()
unlimited.fc.client.api.filelist.FileListDataItemSourceThe possible returns values can be found at the following locations:
TransferMode.UDPTransferMode.FTPTransferMode.HTTPTransferMode.AUTOgetMode in interface unlimited.fc.client.api.filelist.FileListDataItemSourcepublic int getNumBlockReaders()
FileTransferDatagetNumBlockReaders in interface FileTransferDatapublic int getNumBlockWriters()
FileTransferDatagetNumBlockWriters in interface FileTransferDatapublic int getNumFTPStreams()
FileTransferDatagetNumFTPStreams in interface FileTransferDatapublic int getNumPacketProcessors()
FileTransferDatagetNumPacketProcessors in interface FileTransferDatapublic int getNumReceiveSockets()
FileTransferDatagetNumReceiveSockets in interface FileTransferDatapublic int getNumSenderSockets()
FileTransferDatagetNumSenderSockets in interface FileTransferDatapublic int getNumSenderThreads()
FileTransferDatagetNumSenderThreads in interface FileTransferDatapublic int getNumThreads()
FileTransferDatagetNumThreads in interface FileTransferDatapublic int getNumUDPSockets()
FileTransferDatagetNumUDPSockets in interface FileTransferDatapublic java.util.Observer getObserver()
FileTransferDatagetObserver in interface FileTransferDatapublic int getPacketQueueDepth()
FileTransferDatagetPacketQueueDepth in interface FileTransferDatapublic int getPacketSize()
FileTransferDatagetPacketSize in interface FileTransferDatapublic PostTaskSentData getPostTaskSentData()
FileTransferDatagetPostTaskSentData in interface FileTransferDatapublic java.lang.String getPostURL()
FileTransferDatagetPostURL in interface FileTransferDatapublic int getProgressiveTimeout()
FileTransferDatagetProgressiveTimeout in interface FileTransferDatapublic java.lang.String getProgressiveTimeoutFilter()
FileTransferDatagetProgressiveTimeoutFilter in interface FileTransferDatapublic int getReadBufferSizeKB()
FileTransferDatagetReadBufferSizeKB in interface FileTransferDatapublic int getReadTimeout()
FileTransferDatagetReadTimeout in interface FileTransferDatapublic int getRemotePort()
FileTransferDatagetRemotePort in interface FileTransferDatapublic java.lang.String getRemoteServer()
FileTransferDatagetRemoteServer in interface FileTransferDatapublic boolean getRenameExtension()
FileTransferDatagetRenameExtension in interface FileTransferDatapublic java.lang.String getServerAgentID()
FileTransferDatagetServerAgentID in interface FileTransferDatapublic java.lang.String getServletLocation()
FileTransferDatagetServletLocation in interface FileTransferDatapublic TransferMechanismData.ServletLocationData getServletLocationData()
public int getServletMultiplier()
FileTransferDatagetServletMultiplier in interface FileTransferDatapublic int getSessionCount()
FileTransferDatagetSessionCount in interface FileTransferDatapublic java.lang.String getSessionID()
FileTransferDatagetSessionID in interface FileTransferDatapublic int getStartRate()
unlimited.fc.client.api.filelist.FileListDataItemSourceNote: Congestion control must be enabled for this value to have an effect.
getStartRate in interface unlimited.fc.client.api.filelist.FileListDataItemSourcepublic unlimited.core.transfers.net.ssl.FCSSLSocketProducerImpl getSSLSocketProducer()
FileTransferDatagetSSLSocketProducer in interface FileTransferDatapublic int getTargetRate()
FileTransferDatagetTargetRate in interface FileTransferDatapublic int getTempMode()
FileTransferDatagetTempMode in interface FileTransferDatapublic java.lang.String getTransactionID()
FileTransferData.setTransactionID(String)public boolean getTransferEmptyDirectories()
FileTransferDatagetTransferEmptyDirectories in interface FileTransferDatapublic int getTransferRate()
FileTransferDatagetTransferRate in interface FileTransferDatapublic int getUnitSize()
unlimited.fc.client.api.filelist.FileListDataItemSourcegetUnitSize in interface unlimited.fc.client.api.filelist.FileListDataItemSourcepublic int getVerifyMode()
FileTransferDataThe modes that can be returned are as follows:
getVerifyMode in interface FileTransferDatapublic long getWaitRetry()
FileTransferDatagetWaitRetry in interface FileTransferDatapublic int getWriteBufferSizeKB()
FileTransferDatagetWriteBufferSizeKB in interface FileTransferDatapublic java.lang.String getWriteFileMode()
FileTransferDatagetWriteFileMode in interface FileTransferDatapublic long getZipFileSizeLimit()
FileTransferDatagetZipFileSizeLimit in interface FileTransferDatapublic boolean isAutoResume()
FileTransferDataisAutoResume in interface FileTransferDatapublic boolean isAutoZip()
FileTransferDataisAutoZip in interface FileTransferDatapublic boolean isAutoUnzip()
FileTransferDataisAutoUnzip in interface FileTransferDatapublic boolean isCompressionEnabled()
FileTransferDataisCompressionEnabled in interface FileTransferDatapublic boolean isCongestionControlEnabled()
FileTransferDataisCongestionControlEnabled in interface FileTransferDatapublic boolean isCurrentStateConnected()
public boolean isDebug()
FileTransferDataisDebug in interface FileTransferDatapublic boolean isDeleteAfterTransfer()
FileTransferDataisDeleteAfterTransfer in interface FileTransferDatapublic boolean isDowngradeModeOnReConnect()
FileTransferDataisDowngradeModeOnReConnect in interface FileTransferDatapublic boolean isForceTCPmodeACKs()
FileTransferDataNote: In some cases UDP notifications may be blocked. If this is the case you may force the client to use TCP mode ACKs.
isForceTCPmodeACKs in interface FileTransferDatapublic boolean isMaintainLastModified()
FileTransferDataisMaintainLastModified in interface FileTransferDatapublic boolean isMaintainPermissions()
FileTransferDataisMaintainPermissions in interface FileTransferDatapublic boolean isOptimizeBlockSize()
FileTransferDataisOptimizeBlockSize in interface FileTransferDatapublic boolean isProgressiveTransfers()
FileTransferDataisProgressiveTransfers in interface FileTransferDatapublic boolean isShowConsoleLog()
FileTransferDataisShowConsoleLog in interface FileTransferDatapublic boolean isTransferEmptyDirectories()
FileTransferDataisTransferEmptyDirectories in interface FileTransferDatapublic boolean isTransferWithTempName()
FileTransferDataisTransferWithTempName in interface FileTransferDatapublic boolean isUseCompression()
FileTransferDataisUseCompression in interface FileTransferDatapublic boolean isUseCongestionControl()
FileTransferDataisUseCongestionControl in interface FileTransferDatapublic boolean isUseIncremental()
FileTransferDataisUseIncremental in interface FileTransferDatapublic boolean isIncrementalSizeCheckOnly()
FileTransferDataisIncrementalSizeCheckOnly in interface FileTransferDatapublic boolean isUseSSL()
FileTransferDataisUseSSL in interface FileTransferDatapublic boolean isVerifyIntegrity()
FileTransferDataisVerifyIntegrity in interface FileTransferDatapublic void setAutoResume(boolean autoResume)
FileTransferDatasetAutoResume in interface FileTransferDataautoResume - true/false to enabled or disable this feature.public void setAutoZip(boolean autoZip)
FileTransferDatasetAutoZip in interface FileTransferDataautoZip - booleanpublic void setAutoUnzip(boolean autoUnzip)
FileTransferDatasetAutoUnzip in interface FileTransferDataautoUnzip - booleanpublic void setBlockSize(int blockSize)
FileTransferDatasetBlockSize in interface FileTransferDatablockSize - An int value used to set the Block Sizepublic void setCallbackHandler(FileCatalystClientCallbackHandler callbackHandler)
FileTransferDatasetCallbackHandler in interface FileTransferDatacallbackHandler - the callbackHandler to setpublic void setClientAgentID(java.lang.String clientAgentID)
FileTransferDatasetClientAgentID in interface FileTransferDataclientAgentID - New ID to setpublic void setClientConnectKey(java.lang.String clientConnectKey)
FileTransferDatasetClientConnectKey in interface FileTransferDataclientConnectKey - String Client connect keypublic void setClientIdentifier(int clientIdentifier)
FileTransferDatasetClientIdentifier in interface FileTransferDataclientIdentifier - intpublic void setClientString(java.lang.String clientString)
FileTransferDatasetClientString in interface FileTransferDataclientString - the clientString to setpublic void setClientSubIdentifier(int id)
FileTransferDatasetClientSubIdentifier in interface FileTransferDataid - the clientSubIdentifier to setpublic void setCompFileFilter(java.lang.String compFileFilter)
FileTransferDatasetCompFileFilter in interface FileTransferDatacompFileFilter - Filter to setpublic void setCompLevel(int compLevel)
FileTransferDatasetCompLevel in interface FileTransferDatacompLevel - int The desired compression levelpublic void setCompMethod(int compMethod)
FileTransferDataThe available compression strategies that can be used are as follows:
setCompMethod in interface FileTransferDatacompMethod - int The desired compression Methodpublic void setCompressionData(CompressionData compressionData)
public void setCompressionDataFromClient(FileTransferMechanism client)
public void setCompressionEnabled(boolean compressionEnabled)
FileTransferDatasetCompressionEnabled in interface FileTransferDatapublic void setCompStrategy(int compStrategy)
FileTransferDataValid values are:
setCompStrategy in interface FileTransferDatacompStrategy - int The new compression strategypublic void setCongCtrlStrategy(int congCtrlStrategy)
FileTransferDataThe possible options are:
CongestionControlType.RTT)CongestionControlType.LOSS)CongestionControlType.BSS)setCongCtrlStrategy in interface FileTransferDatacongCtrlStrategy - the congCtrlStrategy to setpublic void setCongestionControlAggression(int congestionControlAggression)
FileTransferDatasetCongestionControlAggression in interface FileTransferDatacongestionControlAggression - int Aggression factor between 1 and 10.public void setCongestionControlEnabled(boolean congestionControlEnabled)
FileTransferDatasetCongestionControlEnabled in interface FileTransferDatapublic void setConnectTimeout(int connectTimeout)
FileTransferDatasetConnectTimeout in interface FileTransferDataconnectTimeout - int value used to set the connect timeoutpublic void setCurrentStateConnected(boolean currentStateConnected)
public void setDebug(boolean debug)
FileTransferDatasetDebug in interface FileTransferDatadebug - boolean value to turn the debug mode on or ofpublic void setDeleteAfterTransfer(boolean deleteAfterTransfer)
FileTransferDatasetDeleteAfterTransfer in interface FileTransferDatadeleteAfterTransfer - boolean Enables/disables the delete after transfer optionpublic void setDowngradeModeOnReConnect(boolean downgradeModeOnReConnect)
FileTransferDatasetDowngradeModeOnReConnect in interface FileTransferDatadowngradeModeOnReConnect - the downgradeModeOnReConnect to setpublic void setExtendedReadTimeout(int extendedReadTimeout)
FileTransferDatasetExtendedReadTimeout in interface FileTransferDataextendedReadTimeout - int New timeout value (in millisecs).public void setFileFilter(FileCatalystFileFilter fileFilter)
unlimited.fc.client.api.filelist.FileListDataItemSourcesetFileFilter in interface unlimited.fc.client.api.filelist.FileListDataItemSourcefileFilter - Filter to setpublic void setForceTCPmodeACKs(boolean forceTCPmodeACKs)
FileTransferDataNote: In some cases UDP notifications may be blocked. If this is the case you may force the client to use TCP mode ACKs.
setForceTCPmodeACKs in interface FileTransferDataforceTCPmodeACKs - true if TCP mode ACKs should be usedpublic void setClientName(java.lang.String clientName)
FileTransferDatasetClientName in interface FileTransferDataclientName - Name to setpublic void setClientWorkingPath(java.nio.file.Path clientWorkingPath)
FileTransferDatasetClientWorkingPath in interface FileTransferDataclientWorkingPath - Working path to setpublic void setIncomingDataPort(int incomingDataPort)
FileTransferDatasetIncomingDataPort in interface FileTransferDatapublic void setIncomingDataPorts(int[] incomingDataPorts)
FileTransferDatasetIncomingDataPorts in interface FileTransferDatapublic void setIncrementalMode(int incrementalMode)
FileTransferDataValid modes are
TransferMode.TRANSFER_FILE: Will transfer the entire file when it has been modified.TransferMode.TRANSFER_FILE_DELTAS: Will only transfer sections of the file that have been modified TransferMode.TRANSFER_FILE_UNIQUE_NAME: Will transfer the entire file, but under a unique name TransferMode.TRANSFER_FILE_DELTAS_UNIQUE_NAME: Will only transfer sections of the file that have
been modified but store the new file with a unique namesetIncrementalMode in interface FileTransferDataincrementalMode - int The desired incremental mode.public void setIncrementalSizeCheckOnly(boolean incrementalSizeCheckOnly)
FileTransferDatasetIncrementalSizeCheckOnly in interface FileTransferDatapublic void setLocalWorkingDirectory(java.nio.file.Path localWorkingDirecctory)
FileTransferDatasetLocalWorkingDirectory in interface FileTransferDatapublic void setLogger(unlimited.core.util.common.logs.LogUtils logger)
FileTransferDatasetLogger in interface FileTransferDatalogger - the logger to setpublic void setLogLocation(java.lang.String logLocation)
FileTransferDatasetLogLocation in interface FileTransferDatalogLocation - String value specifying where to store the logspublic void setMaintainLastModified(boolean maintainLastModified)
FileTransferDatasetMaintainLastModified in interface FileTransferDatamaintainLastModified - true/false to enabled and disable this feature.public void setMaintainPermissions(boolean maintainPermissions)
FileTransferDatasetMaintainPermissions in interface FileTransferDatamaintainPermissions - true/false to enabled and disable this feature.public void setMaxRetries(int maxRetries)
FileTransferDatasetMaxRetries in interface FileTransferDatamaxRetries - the maxRetries to setpublic void setMd5RateLimit(int md5RateLimit)
FileTransferDatasetMd5RateLimit in interface FileTransferDatamd5RateLimit - Limit to usepublic void setMode(int mode)
FileTransferDataThe possible values can be found at the following locations:
TransferMode.UDPTransferMode.FTPTransferMode.HTTPTransferMode.AUTOsetMode in interface FileTransferDatamode - int value used to specify which transfer mode to use (ie: TransferMode.UDP)public void setNumBlockReaders(int numBlockReaders)
FileTransferDatasetNumBlockReaders in interface FileTransferDatanumBlockReaders - the numBlockReaders to setpublic void setNumBlockWriters(int numBlockWriters)
FileTransferDatasetNumBlockWriters in interface FileTransferDatanumBlockWriters - the numBlockWriters to setpublic void setNumFTPStreams(int numFTPStreams)
FileTransferDatasetNumFTPStreams in interface FileTransferDatanumFTPStreams - Number of concurrent streams to use.public void setNumPacketProcessors(int numPacketProcessors)
FileTransferDatasetNumPacketProcessors in interface FileTransferDatanumPacketProcessors - the numPacketProcessors to setpublic void setNumReceiveSockets(int numReceiveSockets)
FileTransferDatasetNumReceiveSockets in interface FileTransferDatanumReceiveSockets - the numReceiveSockets to setpublic void setNumSenderSockets(int numSenderSockets)
FileTransferDatasetNumSenderSockets in interface FileTransferDatapublic void setNumSenderThreads(int numSenderThreads)
FileTransferDatasetNumSenderThreads in interface FileTransferDatanumSenderThreads - Number of block sender threads to start for each transmission.public void setNumThreads(int numThreads)
FileTransferDatasetNumThreads in interface FileTransferDatanumThreads - Number of block sender threads to start for each transmission.public void setNumUDPSockets(int numUDPSockets)
FileTransferDatasetNumUDPSockets in interface FileTransferDatanumUDPSockets - the Number of UDP Sockets to setpublic void setObserver(java.util.Observer obs)
FileTransferDatasetObserver in interface FileTransferDataobs - the observer to setpublic void setOptimizeBlockSize(boolean optimizeBlockSize)
FileTransferDatasetOptimizeBlockSize in interface FileTransferDataoptimizeBlockSize - true/false to enabled and disable this feature.public void setPacketQueueDepth(int packetQueueDepth)
FileTransferDatasetPacketQueueDepth in interface FileTransferDatapacketQueueDepth - the packetQueueDepth to setpublic void setPacketSize(int packetSize)
FileTransferDatasetPacketSize in interface FileTransferDatapacketSize - int value used to set the Unit Sizepublic void setPostTaskSentData(PostTaskSentData data)
FileTransferDatasetPostTaskSentData in interface FileTransferDatapublic void setPostURL(java.lang.String postURL)
FileTransferDatasetPostURL in interface FileTransferDatapostURL - New postURL to usepublic void setProgressiveTimeout(int progressiveTimeout)
FileTransferDatasetProgressiveTimeout in interface FileTransferDataprogressiveTimeout - New timeout to setpublic void setProgressiveTimeoutFilter(java.lang.String progressiveTimeoutFilter)
FileTransferDatasetProgressiveTimeoutFilter in interface FileTransferDataprogressiveTimeoutFilter - Filter to setpublic void setProgressiveTransfers(boolean progressiveTransfers)
FileTransferDatasetProgressiveTransfers in interface FileTransferDataprogressiveTransfers - boolean boolean Enables/disables the progressive transfer optionpublic void setReadBufferSizeKB(int readBufferSizeKB)
FileTransferDatasetReadBufferSizeKB in interface FileTransferDatareadBufferSizeKB - default value will utilize network block size for reads.public void setReadTimeout(int readTimeout)
FileTransferDatasetReadTimeout in interface FileTransferDatareadTimeout - int New timeout value (in millisecs)public void setRemotePort(int remotePort)
FileTransferDatasetRemotePort in interface FileTransferDataremotePort - int value to specify the remort post to be usedpublic void setRemoteServer(java.lang.String remoteServer)
FileTransferDatasetRemoteServer in interface FileTransferDataremoteServer - String value to specify the server to connect topublic void setRenameExtension(boolean renameExtension)
FileTransferDatasetRenameExtension in interface FileTransferDatarenameExtension - Enabled booleanpublic void setServerAgentID(java.lang.String serverAgentID)
FileTransferDatasetServerAgentID in interface FileTransferDataserverAgentID - New value to setpublic void setServletLocation(java.lang.String servletLocation)
FileTransferDatasetServletLocation in interface FileTransferDataservletLocation - String The URL of the FileCatalyst Servletpublic void setServletLocation(java.lang.String servletLocation,
java.lang.String servletSessionID,
java.lang.String welcomeMessage)
FileTransferDatasetServletLocation in interface FileTransferDataservletLocation - String The URL of the FileCatalyst ServletservletSessionID - If s session was already established that should be re-used, this session id should be setwelcomeMessage - When connecting with pre-connected Servlet session, you may pass the welcome message to the FCClient
as well so it can detect whether this is a FileCatalyst server or not as well as extract the version
string.public void setServletMultiplier(int servletMultiplier)
FileTransferDatasetServletMultiplier in interface FileTransferDataservletMultiplier - int multiplier value used to tune upload bufferpublic void setSessionCount(int sessionCount)
public void setSessionID(java.lang.String sessionID)
FileTransferDatasetSessionID in interface FileTransferDatapublic void setShowConsoleLog(boolean showConsoleLog)
FileTransferDatasetShowConsoleLog in interface FileTransferDatashowConsoleLog - boolean value set to show the console Log or notpublic void setStartRate(int startRate)
FileTransferDatasetStartRate in interface FileTransferDatastartRate - int value used to set the rate in which the transfer should start atpublic void setTargetRate(int targetRate)
FileTransferDatasetTargetRate in interface FileTransferDatatargetRate - int value to specify the maximum transfer ratepublic void setTransactionID(java.lang.String uniqueID)
FileTransferDataApplies to temporary file name, zip file name, signature/delta filename.
By default, a random unique ID is created per machine by the API. This ensures that on the server, two separate client connections into the same user account should not encounter a filename collision. However, if two concurrent transfers are being launched using the same fileset (ie: upload using auto-zip) from the client API to separate servers, this value must be set for each transfer in order to ensure that temporary & working file name is not reused for two distinct transfers.
Value may be overridden if you explicitly specify a transaction ID during upload(Vector, String, String) or download(Vector, String, String) calls.
setTransactionID in interface FileTransferDatauniqueID - String value, should be alpha-numeric (Long.toString(System.currentTimeMillis()))public void setTransferEmptyDirectories(boolean transferEmptyDirectories)
FileTransferDatasetTransferEmptyDirectories in interface FileTransferDatatransferEmptyDirectories - Boolean value to setpublic void setTransferRate(int transferRate)
public void setTransferWithTempName(boolean transferWithTempName)
FileTransferDatasetTransferWithTempName in interface FileTransferDatatransferWithTempName - boolean true/false to enable or disable this featurepublic void setTransferWithTempName(boolean transferWithTempName,
int tempMode)
FileTransferDatasetTransferWithTempName in interface FileTransferDatatransferWithTempName - boolean true/false to enable or disable this featuretempMode - int Sets the desired mode, TransferMode.PREFIX or TransferMode.SUFFIX.TransferModepublic void setUnitSize(int unitSize)
FileTransferDatasetUnitSize in interface FileTransferDataunitSize - int value used to set the Unit Size. In Bytes.public void setUseCompression(boolean useCompression)
FileTransferDatasetUseCompression in interface FileTransferDatauseCompression - boolean true/false to enable/disable compression.public void setUseCongestionControl(boolean useCongestionControl)
FileTransferDatasetUseCongestionControl in interface FileTransferDatauseCongestionControl - boolean value used to turn congestion control on/offpublic void setUseIncremental(boolean useIncremental)
FileTransferDatasetUseIncremental in interface FileTransferDatauseIncremental - boolean value to turn incremental on/offpublic void setUseSSL(boolean useSSL)
FileTransferDatasetUseSSL in interface FileTransferDatauseSSL - Boolean value to turn SSL on/offpublic void setSSLSocketProducer(unlimited.core.transfers.net.ssl.FCSSLSocketProducerImpl socketProducer)
FileTransferDatasetSSLSocketProducer in interface FileTransferDatasocketProducer - Concrete instance that provides logic for generating SSL socketspublic void setVerifyIntegrity(boolean verifyIntegrity)
FileTransferDatasetVerifyIntegrity in interface FileTransferDataverifyIntegrity - true/false to enable or disable this feature.public void setVerifyMode(int verifyMode)
FileTransferDatasetVerifyMode in interface FileTransferDataverifyMode - int Sets the desired mode, TransferMode.VERIFY_AFTER or TransferMode.VERIFY_ON_THE_FLY.TransferModepublic void setWaitRetry(long waitRetry)
FileTransferDatasetWaitRetry in interface FileTransferDatawaitRetry - the waitRetry to setpublic void setWriteBufferSizeKB(int writeBufferSizeKB)
FileTransferDatasetWriteBufferSizeKB in interface FileTransferDatawriteBufferSizeKB - default value will utilize network block size for writes. Value in KB.public void setWriteFileMode(java.lang.String writeFileMode)
FileTransferDatasetWriteFileMode in interface FileTransferDatawriteFileMode - Default "" uses "rws" for Windows/Linux, and "rw" for Solaris/MacOSX. Possible values are "", rw, rws, rwdpublic void setZipFileSizeLimit(long zipFileSizeLimit)
FileTransferDatasetZipFileSizeLimit in interface FileTransferDatazipFileSizeLimit - the zipFileSizeLimit (in bytes) to setpublic void setUserRelativePriority(int priority)
FileTransferDatasetUserRelativePriority in interface FileTransferDatapriority - hint for server to distribute bandwidth when it would normally split it evenly.public int getUserRelativePriority()
FileTransferDatagetUserRelativePriority in interface FileTransferDatapublic java.lang.String pwd()
throws unlimited.core.util.common.exception.FCException,
java.io.IOException
FileTransferDatapwd in interface FileTransferDataunlimited.core.util.common.exception.FCException - If an error in the FC protocol occursjava.io.IOException - If a timeout, or other IO error occurspublic void cd(java.lang.String path)
throws unlimited.core.util.common.exception.FCException,
java.io.IOException
FileTransferDatacd in interface FileTransferDatapath - The desired remote path to change to.unlimited.core.util.common.exception.FCException - If an error in the FC protocol occurs, permission denied, etc...java.io.IOException - If a timeout, or other IO error occurspublic boolean isForceFileOwnershipEnabled()
unlimited.fc.client.api.filelist.FileListDataItemSourceisForceFileOwnershipEnabled in interface unlimited.fc.client.api.filelist.FileListDataItemSourcepublic void setForceFileOwnershipEnabled(boolean isForceFileOwnershipEnabled)
unlimited.fc.client.api.filelist.FileListDataItemSourcesetForceFileOwnershipEnabled in interface unlimited.fc.client.api.filelist.FileListDataItemSourceisForceFileOwnershipEnabled - the isForceFileOwnershipEnabled to setpublic java.lang.String getForceFileOwnershipUser()
FileTransferDatagetForceFileOwnershipUser in interface FileTransferDatapublic void setForceFileOwnershipUser(java.lang.String forceFileOwnershipUser)
FileTransferDatasetForceFileOwnershipUser in interface FileTransferDataforceFileOwnershipUser - the forceFileOwnershipUser to setpublic java.lang.String getForceFileOwnershipGroup()
FileTransferDatagetForceFileOwnershipGroup in interface FileTransferDatapublic void setForceFileOwnershipGroup(java.lang.String forceFileOwnershipGroup)
FileTransferDatasetForceFileOwnershipGroup in interface FileTransferDatapublic void getSynchedFrom(FileTransferData master)
master - TransferData to be synced to this objectpublic void synchThisTo(FileTransferData slave)
slave - TransferData to sync this information topublic static void synch(FileTransferData client, FileTransferData master)
public static void synchIgnoreTargetRate(FileTransferData client, FileTransferData master)
public static void synchAndConnect(FileTransferMechanism client, FileTransferData master)
public static void synchConnectAndCD(FileTransferMechanism client, FileTransferData master)
public void loadFromProperties()
public void saveToProperties()
public void loadFromFile(java.nio.file.Path propFile)
protected void loadFromChannel(java.nio.channels.SeekableByteChannel channel)
throws java.io.IOException
java.io.IOExceptionpublic void saveToFile(java.nio.file.Path propFile)
public void initializeWorkingDirectory(java.lang.String pwd)
pwd - Remote directory to set. If null, working directory becomes uninitialized.public boolean isWorkingDirectoryInitialized()
public static void importFile(java.nio.file.Path aFile,
FileTransferData destination)
throws java.io.IOException
aFile - File to load the properites fromdestination - TransferData to import the properties too.java.io.IOException - Thrown if there is an issue importing the propertiespublic static void importProperties(java.util.Properties props,
FileTransferData destination)
throws java.io.IOException
props - Properties object to import into the TransferDatadestination - TransferData to import the properties too.java.io.IOException - Thrown if there is an issue importing the propertiespublic static void exportFile(java.nio.file.Path aFile,
FileTransferData source)
throws java.io.IOException
aFile - Path to which the properties should be exported too.source - FileTransferData information to be exportedjava.io.IOException - Thrown if there are issues with file access.public static java.util.Properties exportProperties(FileTransferData source) throws java.io.IOException
source - FileTransferData information to be exportedjava.io.IOException - Thrown if there are issues with file access.public int lastServerRestrictedRate()
FileTransferDatalastServerRestrictedRate in interface FileTransferDatapublic void setLastServerRestrictedRate(int actual)
public boolean isServerOverridebandwidth()
FileTransferDataisServerOverridebandwidth in interface FileTransferDatapublic void setIsServerOverrideBandwidth(boolean isOverride)
public int getServerOverrideBandwidth()
FileTransferDatagetServerOverrideBandwidth in interface FileTransferDatapublic void setTransferToServerOverride(int serverOverrideBW)
FileTransferDatasetTransferToServerOverride in interface FileTransferDataserverOverrideBW - Kbps bandwidth valuepublic void setServerOverrideBandwidth(int totalOverridebandwidth)
public void setTaskID(java.lang.String taskID)
FileTransferDatasetTaskID in interface FileTransferDatapublic java.lang.String getTaskID()
FileTransferDatagetTaskID in interface FileTransferDatapublic int getFileTransferPriority()
FileTransferDatagetFileTransferPriority in interface FileTransferDatapublic void setFileTransferPriority(int fileTransferPriority)
FileTransferDataValid values are as follows:
setFileTransferPriority in interface FileTransferDatapublic void setIsAuto(boolean isAutoMode)
public boolean isFileCatalystServer()
throws java.io.IOException,
unlimited.core.util.common.exception.FCException
isFileCatalystServer in interface unlimited.fc.client.api.filelist.FileListDataItemSourcejava.io.IOExceptionunlimited.core.util.common.exception.FCExceptionpublic java.util.stream.Stream<FileListDataItem> streamWithInlineParse() throws unlimited.core.util.common.exception.FCException, java.io.IOException
streamWithInlineParse in interface unlimited.fc.client.api.filelist.FileListDataItemSourceunlimited.core.util.common.exception.FCException - If an error in the FC protocol occursjava.io.IOException - If a timeout, or other IO error occurspublic FileListData list() throws unlimited.core.util.common.exception.FCException, java.io.IOException
list in interface unlimited.fc.client.api.filelist.FileListDataItemSourceunlimited.core.util.common.exception.FCException - If an error in the FC protocol occursjava.io.IOException - If a timeout, or other IO error occurspublic java.lang.String[] prms(java.lang.String filename)
throws unlimited.core.util.common.exception.FCException,
java.io.IOException
prms in interface unlimited.fc.client.api.filelist.FileListDataItemSourceunlimited.core.util.common.exception.FCExceptionjava.io.IOExceptionpublic long size(java.lang.String remoteFile)
throws unlimited.core.util.common.exception.FCException,
java.io.IOException
size in interface unlimited.fc.client.api.filelist.FileListDataItemSourceremoteFile - String The path to the remote fileunlimited.core.util.common.exception.FCException - If an error in the FC protocol occursjava.io.IOException - If a timeout, or other IO error occurspublic void get(java.lang.String localPath,
java.lang.String remoteFile,
int inRate,
long offset,
long size,
int numDFEncoders,
int blockSize,
int unitSize,
int mode)
throws java.io.IOException,
unlimited.core.util.common.exception.FCException,
java.security.NoSuchAlgorithmException,
unlimited.core.util.common.exception.FCException,
java.io.IOException
get in interface unlimited.fc.client.api.filelist.FileListDataItemSourcelocalPath - Location of where to store the file after it has been downloadedremoteFile - Remote file to be downloaded from the ServerinRate - Rate to use for the download transferoffset - Location in the local file to start placing downloaded data into (0 = start of file)size - Amount of date to retrieve from the FC Server. (Typically this is (remote file size - (offset))numDFEncoders - Number of encoders to use for theblockSize - Size of blocks to be used in the download transferunitSize - Size of the individual units in the download transfer. Value with compared with the Server's max unit size. Minimum of the two values will be usedmode - Transfer mode to be used for the download. Available modes can be at TransferModejava.io.IOExceptionunlimited.core.util.common.exception.FCExceptionjava.security.NoSuchAlgorithmExceptionpublic void delete(java.lang.String file)
throws unlimited.core.util.common.exception.FCException,
java.io.IOException
delete in interface unlimited.fc.client.api.filelist.FileListDataItemSourcefile - The file to be deletedunlimited.core.util.common.exception.FCException - If an error in the FC protocol occursjava.io.IOException - If a timeout, or other IO error occurspublic java.util.stream.Stream<FileListDataItem> streamWithInlineParse(java.util.function.BooleanSupplier isCancelled) throws unlimited.core.util.common.exception.FCException, java.io.IOException
unlimited.fc.client.api.filelist.FileListDataItemSourcestreamWithInlineParse in interface unlimited.fc.client.api.filelist.FileListDataItemSourceisCancelled - cancel handler to stop stream on cancelunlimited.core.util.common.exception.FCException - If an error in the FC protocol occursjava.io.IOException - If a timeout, or other IO error occurspublic java.util.function.Supplier<ClientCredentials> getClientCredentials()
FileTransferDatagetClientCredentials in interface FileTransferDatapublic void setClientCredentials(java.util.function.Supplier<ClientCredentials> creds)
FileTransferDatasetClientCredentials in interface FileTransferDataCopyright © 2006 - 2022 - HelpSystems LLC All Rights Reserved.