public class FCClientEngine
extends java.lang.Object
implements java.util.Observer
| Modifier and Type | Field and Description |
|---|---|
static int |
AUTO |
protected java.lang.String |
cachePWD |
protected java.lang.String |
clientAgentID |
protected java.lang.String |
clientName |
protected java.nio.file.Path |
clientWorkingPath |
static int |
commandChannelProtocol |
static int |
FTP |
protected boolean |
http |
static int |
HTTP |
protected boolean |
isConnected |
protected boolean |
isFileCatalystServer |
protected boolean |
isFileCatalystServerEnterprise |
protected boolean |
isFileCatalystServerPro |
protected boolean |
isLoggedIn |
protected boolean |
isTransferringData |
protected int |
maxServerRate |
protected <any> |
modtimeCache |
protected MonitoredTransfer |
monitoredTransfer |
protected int |
newDownloadRate |
protected boolean |
printDebugStatements |
protected int |
readTimeoutLong |
protected RemoteServiceVersion |
remoteServiceVersion |
protected java.lang.String |
serverAgentID |
protected java.lang.String |
servletLocation |
int |
sessionCount |
protected java.lang.String |
sessionID |
protected int |
sessionPriority |
long |
sessionTimeStamp |
protected boolean |
shouldPerformServerPostProcess |
protected <any> |
sizeCache |
protected FCSSLSocketProducerImpl |
sslSocketProducer |
protected static int |
streamCap |
static <any> |
systemCache |
protected int |
targetRate |
protected static FileListDataItem |
TERMINAL |
protected java.lang.String |
TOKEN_AUTH_SUCCESS_HEADER |
protected int |
transferID |
protected UDPTransferSettings |
transferSettings |
static int |
UDP |
static java.lang.String |
UNABLE_TO_CONNECT_TO_NON_FILE_CATALYST_SERVER |
| Modifier | Constructor and Description |
|---|---|
protected |
FCClientEngine()
Default constructor -- used by FCClientEngineHTTP
|
| Modifier and Type | Method and Description |
|---|---|
void |
abort(boolean waitForReply)
Abort a FileCatalyst transmision and reception
|
void |
abortAck(boolean abortAck) |
long |
accessTime(java.lang.String fileName)
Get the last access time of the named file from the remote server.
|
void |
addClientConnectKey(java.lang.String key) |
void |
applyPatch(java.lang.String remoteFile,
java.lang.String remotePatch,
long offset)
Applies a patch file on the remote server to the specified file at the specified offset
|
void |
applyRemoteFileAttributesToLocalFile(java.nio.file.Path localFile,
java.lang.String remoteFile) |
void |
binary() |
protected java.lang.String |
buildFilterCommand(FileCatalystFileFilter<?> filter)
Builds the command that will bew used to send the filte data to the Server
|
protected java.lang.String |
buildUNZIPCommand(java.lang.String remoteFile,
boolean maintainPermissions,
boolean maintainTimeStamp) |
protected java.lang.String |
buildWeblinkCommand(WeblinkDataContainer linkDO) |
boolean |
cancelTransfer()
Cancels the current transfer, if one is occurring
|
void |
cdup()
Change to the parent directory
|
void |
chdir(java.lang.String dir)
Change the remote working directory to that supplied
|
boolean |
checkDownloadPermissions()
Returns true if this user acount has download permissions
|
boolean |
checkUploadModifyPermissions()
Returns true if this user acount has upload/modify/rename permissions
Use A Random String Because Fast Machines With Multi-Client Can Have Overlapping Timeslices
|
void |
close() |
static FCClientEngine |
createFCClientEngine(FCClientControlSocketRequestData ctrlSocketData)
Main constructor call, used by most FileCatalyst products.
|
static FCClientEngine |
createFCClientEngine(FCClientControlSocketRequestData ctrlSocketData,
FCClient fcClient) |
static FCClientEngineBridge |
createFCClientEngine(java.net.Socket controlSocket,
boolean sslSocket,
java.util.function.Supplier<ClientCredentials> credentials,
LogUtils log,
int millis)
Used by FCClient.java
|
static FCClientEngine |
createFCClientEngine(java.net.Socket controlSocket,
boolean sslSocket,
java.util.function.Supplier<ClientCredentials> credentials,
LogUtils log,
int millis,
FCClient fcClient) |
static FCClientEngine |
createFCClientEngine(java.lang.String remoteHost,
boolean sslSocket)
Used by test class
|
static FCClientEngine |
createFCClientEngine(java.lang.String remoteHost,
boolean sslSocket,
FCClient fcClient) |
java.lang.String |
createPatch(java.lang.String remoteFile,
long offset,
long length)
Creates a new patch file on the remote server that contains the bytes from offset to offeset+length of remoteFile
|
java.net.Socket |
createThirdPartyFTPServerDataConnection(java.lang.String command) |
long |
creationTime(java.lang.String fileName)
Get the creation time of the named file from the remote server.
|
FCClientControlSocketBridge |
ctrlClient() |
void |
delete(java.lang.String remoteFile)
Delete the specified remote file
|
void |
deleteAll(FileListData remoteFiles) |
void |
deleteAll(FileListData remoteFiles,
boolean ftpDelete) |
void |
deleteAll(java.util.List<java.lang.String> remoteFiles)
Bulk delete, deletes all the specified files in a single command.
|
void |
deleteAll(java.util.List<java.lang.String> remoteFiles,
boolean ftpDelete)
Bulk delete, deletes all the specified files in a single command.
|
void |
detectFCServer() |
protected void |
detectSessionKilledByAdmin() |
FileListData |
dir()
List current directory's contents as an array of strings of filenames.
|
FileListData |
dir(java.lang.String dirname)
List a directory's contents as an array of strings of filenames.
|
FileListData |
dir(java.lang.String dirname,
boolean full)
List a directory's contents as an array of strings.
|
FileListData |
dir(java.lang.String dirname,
boolean full,
java.lang.String filterFlag)
List a directory's contents as an array of strings.
|
FileListData |
dir(java.lang.String dirname,
boolean full,
java.lang.String filterFlag,
java.lang.String wildcard)
List a directory's contents as an array of strings.
|
java.lang.String[] |
dirRaw(java.lang.String dirname,
boolean full,
java.lang.String filterFlag) |
protected FileListData |
doDirListing(java.lang.String dirname,
boolean full,
java.lang.String filterFlag,
java.lang.String wildcard,
FileListDataItemConsumer resultData) |
protected FileListData |
doDirListing(java.lang.String dirname,
boolean full,
java.lang.String filterFlag,
java.lang.String wildcard,
FileListDataItemConsumer resultData,
java.util.function.BooleanSupplier isCancelled) |
java.util.stream.Stream<FileListDataItem> |
doDirStream(DirListParams params) |
java.util.stream.Stream<FileListDataItem> |
doDirStream(java.lang.String dirname,
boolean full,
java.lang.String filterFlag,
java.lang.String wildcard,
FileListDataItemConsumer resultData,
java.util.function.BooleanSupplier isCancelled) |
<any> |
exists(java.util.stream.Stream<java.lang.String> nameStream) |
boolean |
exists(java.lang.String remoteFile)
Test if the remote file, denoted by the given remote path, exists on the server and returns true if it exists,
false otherwise.
|
java.lang.String |
featureSet()
Get the feature list from the server
|
java.util.ArrayList<FileSystemEvent> |
fileSystemEvents(long timeout)
Get a list of file system events from the server
|
void |
filter(FileCatalystFileFilter<?> filter)
Initializes the file filter on the server.
|
void |
filter(long olderThan,
long newerThan,
long upperByteLimit,
long lowerByteLimit,
java.lang.String filterString,
int filterMode,
boolean applyFilterToDirectories)
Deprecated.
This method is deprecated. Please use
filter(FileCatalystFileFilter) instead |
void |
flushCaches()
Flush the caches used in the transfer
|
void |
generateNewTransferID() |
void |
get(DownloadTransferRequestData downloadRequestData)
Get a file from the FileCatalyst server.
|
ServerConfigs |
getAllServerClientConfigs() |
AutoDetectData |
getAutoDetectData() |
int |
getBlastRate()
2015/11/25 - leaving the comment below on what this returns, but noting that
what it really returns is the mean average of total good data sent.
|
java.lang.String |
getCachedPWD() |
java.lang.String |
getClientAgentID() |
int |
getClientIdentifier() |
java.lang.String |
getClientString() |
int |
getClientSubIdentifier() |
java.lang.Object |
getComLock() |
int |
getCompLevel() |
int |
getCompMethod() |
int |
getCompStrategy() |
int |
getCongestionControlAggression() |
java.util.Map<java.lang.String,java.lang.Integer> |
getCurrentFileToIDs() |
int |
getCurrentGoodputRate() |
int |
getCurrentRate() |
int |
getCurrentRTT() |
int[] |
getDataPort() |
protected DirListTool |
getDirListTool(DirListParams p,
FCClientEngine e) |
boolean |
getDone() |
void |
getDone(boolean isDone) |
java.lang.String |
getErrorMessage()
Get the last error message text
|
FCClient |
getFCClientObject() |
ForceFileOwnershipConfig |
getForceFileOwnerConfig() |
HashCode |
getHashCode() |
void |
getHTTP(DownloadTransferRequestData requestData) |
int |
getIdealConcurrentFTPStreams(int rate,
long length,
int bufferSize,
int maxStream) |
boolean |
getIsTransferringData() |
java.lang.String |
getLastReplyText()
Gets the latest valid reply from the server
|
long |
getLastThroughtput() |
FCReply |
getLastValidReply()
Gets the latest valid reply from the server
|
protected java.lang.String |
getLocalHost() |
LogUtils |
getLogger() |
java.lang.String |
getMD5(java.lang.String remoteFile)
Request the MD5 digest of the remote file
|
java.lang.String |
getMD5(java.lang.String remoteFile,
long offset,
long length)
Request the MD5 digest of the remote file
|
java.lang.String |
getMD5(java.lang.String remoteFile,
long offset,
long length,
long checkInterval,
long checkLength)
Request the Partial MD5 digest of the remote file
|
int |
getMeanEffectiveRate() |
MonitoredTransfer |
getMonitoredTransfer() |
int |
getNumFTPStreams() |
int |
getNumUDPSockets() |
double |
getPacketLoss() |
java.lang.String |
getPlatForm() |
protected java.lang.String |
getRemoteHost() |
RemoteServiceVersion |
getRemoteServiceVersion()
Returns the remote service version of the server.
|
ClientDataReport |
getReporter() |
FCClientReportManager |
getReportManager()
Returns the report manager that is used to encapsulate all reporting functionality into one single resource
|
java.lang.String |
getReportStatus(MonitoredTransfer monTransfer) |
java.lang.String |
getServerAgentID() |
java.lang.String |
getServerConfigurationValue(java.lang.String request) |
int |
getServerLinkExpiryDayValue() |
java.lang.String |
getServerVersion() |
java.lang.String |
getServletLocation() |
int |
getSessionCount() |
java.lang.String |
getSessionID() |
static FCClienEngineSpeedCache |
getSpeedcache() |
int |
getStartRate() |
protected java.lang.String |
getSystKey() |
java.lang.String |
getTaskID() |
long |
getTransferGoodput() |
int |
getTransferID() |
long |
getTransferLength() |
UDPTransferMetricsContainer |
getTransferMetrics()
Returns transfer metric container specific to UDP transfers.
|
int |
getTransferPercent() |
int |
getTransferRate() |
UDPTransferSettings |
getTransferSettings() |
long |
getTransferThroughput() |
float |
getTransmitZipRatio() |
java.lang.String |
getUserEmail()
Returns The User's Email Address When Requested
|
java.lang.String |
getUserFullName()
Gathers The Full Name Of The User
|
UserPermissionsContainer |
getUserPermissions()
Gathers The User's Permissions From The Server
|
protected java.lang.String |
getVersionForSetup() |
java.lang.String |
getWelcomeMessage() |
void |
gobbleExtraReplies(int incomingTimeout,
int incomingNumToGobble) |
boolean |
hasAutoDetectData() |
boolean |
hasReporter() |
java.lang.String |
help(java.lang.String command)
Get the help text for the specified command
|
protected void |
informServerToWriteReport(PropertyTransmission reportArgs) |
void |
initAES()
Send a AESK command, initialized the AES secret key on the server
|
int[] |
initFCTransfer(int numDecoders,
int blockSize,
int unitSize,
long length,
boolean congestionControl,
int fileID,
int mode) |
static void |
initSOCKS(java.lang.String port,
java.lang.String host)
Set up SOCKS v4/v5 proxy settings.
|
static void |
initSOCKSAuthentication(java.lang.String username,
java.lang.String password)
Set up SOCKS username and password for SOCKS username/password authentication.
|
protected java.lang.String |
innerSyst() |
protected boolean |
innerZipChunkTest(java.lang.String zipFileName) |
void |
isAborted(boolean isAborted) |
boolean |
isAllowConnectNonFileCatalystServer() |
protected boolean |
isChannelClosed(java.lang.String message) |
boolean |
isComplete() |
boolean |
isCongestionControl() |
boolean |
isConnected()
Get the connection status
|
boolean |
isDeltasStillGrowing() |
boolean |
isFileCatalystServer()
True if it is a FileCatalyst Server.
|
boolean |
isFileCatalystServerEnterprise() |
boolean |
isFileCatalystServerPro()
True if is a PRO (non-UDP) FileCatalyst License.
|
boolean |
isForceTCPmodeACKs() |
boolean |
isHttp() |
boolean |
isLinkEnabledOnServer() |
boolean |
isLoggedIn() |
boolean |
isProgressiveTransfer() |
boolean |
isQuitting() |
boolean |
isReportingEnabled() |
boolean |
isServerBandwidthOverride() |
boolean |
isServerTimeout() |
boolean |
isTimeout(java.lang.String message) |
boolean |
isTransferCancelled() |
boolean |
isTransferComplete() |
boolean |
isTransferError() |
boolean |
isUseCompression() |
boolean |
isZipStillExtracting() |
boolean |
isZipStillGrowing(java.lang.String zipFileName) |
int |
lastServerRestrictedRate() |
FCReply |
lastValidReply() |
void |
lastValidReply(FCReply validateReply) |
void |
log(java.lang.String line) |
void |
log(java.lang.String line,
java.lang.Throwable e) |
void |
mkdir(java.lang.String remotedir)
Create the specified remote working directory
|
void |
mkdlt(java.lang.String srcfile,
java.lang.String sigfile,
int blockLength,
boolean compress,
int compLevel,
int strategy)
Called by ReceiverHandler to create a delta file remotely.
|
void |
mkdlt(java.lang.String srcfile,
java.lang.String sigfile,
int blockLength,
boolean compress,
int compLevel,
int strategy,
java.lang.String uniqueID,
boolean waitForDeltaCreation)
Called by ReceiverHandler to create a delta file remotely.
|
void |
mkfile(java.lang.String file)
Create the specified remote working directory
|
java.lang.String |
mksig(java.lang.String srcfile,
boolean compress,
java.lang.String uniqueID) |
java.lang.String |
mksig(java.lang.String srcfile,
java.lang.String uniqueID) |
java.util.Date |
modtime(java.lang.String remoteFile)
Get modification time for a remote file
|
java.util.Date |
modtime(java.lang.String remoteFile,
boolean bypassCache)
Get modification time for a remote file
|
void |
modtime(java.lang.String remoteFile,
java.util.Date d)
Set modification time for a remote file
|
boolean |
monitorIsNull() |
void |
noop()
Send a NOOP command
|
void |
notifyServerOfCurrentRTT() |
int |
numFTPStreams() |
void |
numFTPStreams(int streams) |
void |
overrideSessionID(java.lang.String sessionID) |
protected java.lang.String |
performAsyncMD5(java.lang.String md5Command) |
protected java.lang.String |
performSyncedMD5(java.lang.String md5Command) |
java.lang.String[] |
prms(java.lang.String fileName)
Return the file permission of the file/directory listed in the argument from the remote server.
|
void |
put(UploadTransferRequestData requestData)
Put a local file onto the FileCatalyst server.
|
boolean |
putDone() |
void |
putDone(boolean putDone) |
boolean |
putIsFinished() |
java.lang.String |
pwd()
Get the current remote working directory
|
void |
quit()
Quit the FileCatalyst session
|
void |
quit(boolean flushCaches)
Quit the FileCatalyst session, optionally do not flush the cache, in the case of a reconnect attempt
|
void |
quote(java.lang.String command,
java.lang.String[] validCodes)
Issue arbitrary FileCatalyst commands to the FileCatalyst server.
|
java.lang.String |
rbfil(java.lang.String srcfile,
java.lang.String deltafile,
int blockLength,
boolean compress,
int level,
boolean uniqueName) |
int |
readTimeout() |
void |
readTimeout(int readTimeout) |
void |
reconnect(boolean maintainCurrentDirectory) |
protected void |
refreshCachedPWD(java.lang.String dir) |
void |
registerReportListener(MultiTransferHandler<?> mth) |
RemoteServiceVersion |
remoteServiceVersion() |
java.util.stream.Stream<FileListDataItem> |
remoteSynchFile(java.util.stream.Stream<FileListDataItem> itemStream) |
void |
remoteTransferInitiate(ServerToServerTransferSettings settings)
Initiate a
|
java.lang.String |
remoteTransferStatus() |
void |
rename(java.lang.String from,
java.lang.String to)
Rename a file or directory
|
void |
resetTransferVariables() |
void |
rmdir(java.lang.String dir)
Delete the specified remote working directory
|
void |
rmdirRecursive(FileListDataItem item)
Recursively delete a remote folder
|
void |
sendEmail(java.lang.String emailAddress,
int statusCode,
java.lang.String note)
Instruct the server to send an email to the administrator
|
void |
sendJobStatus(TransferStatusEnum status) |
protected void |
sendRTTKeepALive() |
protected void |
sendTransmitRateCommand(int targetRate,
int startRate) |
WeblinkResult |
sendWeblink(WeblinkDataContainer linkDO)
Creates A Weblink From The Data Container Given
|
void |
serverPostProcess(java.lang.String file)
Execute post processing on the specified file
|
boolean |
serverSupportsFSEvents()
Checks if FSEVT command is supported.
|
boolean |
serverSupportsUDP() |
void |
setAutoDetectData(FCClient fcClient) |
int |
setBandwidth(int bandwidth) |
protected int |
setBandwidthFTPReceiver(int bandwidth) |
protected int |
setBandwidthFTPTransmit(int bandwidth,
MonitoredTransfer monitoredTransfer) |
protected void |
setBandwidthRemoteTransfer(int bandwidth) |
protected int |
setBandwidthUDPSender(int bandwidth) |
protected int |
setBandwidthUPDReceiver(int bandwidth) |
void |
setClientAgentID(java.lang.String clientAgentID) |
void |
setClientIdentifier(int clientIdentifier) |
void |
setClientName(java.lang.String clientName) |
void |
setClientString(java.lang.String clientString)
The client string provides additional information about the connecting client.
|
void |
setClientSubIdentifier(int clientSubIdentifier)
The sub identifier identifies this client as a sub component of a broader group of client apps.
|
void |
setClientWorkingPath(java.nio.file.Path clientWorkingPath) |
void |
setCompLevel(int compLevel) |
void |
setCompMethod(int compMethod) |
void |
setCompStrategy(int compStrategy)
Deprecated.
We no longer support setting compression strategy.
|
void |
setCongestionControl(boolean congestionControl) |
void |
setCongestionControlAggression(int congestionControlAggression) |
void |
setConnectMode(FCConnectMode mode)
Deprecated.
|
void |
setCurrentFilesMatch(FilesMatch filesMatch) |
void |
setCurrentFileToIDs(java.util.Map<java.lang.String,java.lang.Integer> currentFileToIDs) |
void |
setDataPort(int[] dataPort)
Set the DataPort
|
void |
setDownloadRate(int targetRate,
int startRate)
Sets the target rate of the current transfer
|
void |
setErrorMessage(java.lang.String errMess)
Sets the last error message text
|
void |
setForceTCPmodeACKs(boolean forceTCPmodeACKs) |
void |
setHttp(boolean http) |
protected void |
setLastValidReply(FCReply reply) |
void |
setLogStream(LogUtils log)
Set the logging stream, replacing stdout
|
void |
setMaxRate(int rate) |
void |
setMaxServerRate(int rate)
set the max server rate (aka bandwidth)
|
void |
setMonitoredTransfer(MonitoredTransfer monitoredTransfer) |
void |
setNumFTPStreams(int numFTPStreams) |
void |
setNumUDPSockets(int numUDPSockets) |
void |
setOverrideServerBandwidth(FTPTransmit transfer) |
void |
setProgressiveTransfer(boolean isProgressive)
This state is needed to suppress or allow a user data report to be
written when the transfer completes.
|
void |
setQuitting(boolean quitting) |
void |
setReadTimeout(int millisecs)
This is the timeout value that get set when we are sending commands that should not take long to execute, PWD,
LIST, etc...
|
void |
setReadTimeoutLong(int millisecs)
This is the timeout value that get set when we are sending commands that take long to execute, MD5, MKDLT, etc...
|
void |
setReportManager(FCClientReportManager reporter) |
void |
setServletLocation(java.lang.String servletLocation) |
void |
setSessionPriority(int priority) |
void |
setSslSocketProducer(FCSSLSocketProducerImpl sslSocketProducer) |
void |
setStartRate(int startRate) |
void |
setTaskID(java.lang.String taskID) |
protected void |
setTransferID(int transferID) |
void |
setTransferSettings(UDPTransferSettings transferSettings) |
void |
setUDPTransferMetrics(UDPTransferMetrics udp) |
void |
setup(java.util.function.Supplier<ClientCredentials> newCredentials)
Login into an account on the FileCatalyst server.
|
void |
setUseCompression(boolean useCompression) |
void |
setUserEmail(java.lang.String newEmail)
Sets the user's email address
|
void |
setUserFullName(java.lang.String newName) |
void |
setVerifyMode(int verifyMode) |
void |
setWelcomeMessage(java.lang.String welcomeMessage) |
boolean |
shouldPerformServerPostProcess() |
boolean |
site(java.lang.String command)
Run a site-specific command on the server.
|
java.lang.String |
size(java.lang.String fileName,
boolean bypassCache)
Get the size of the named file from the remote server.
|
java.util.stream.Stream<FileListDataItem> |
streamWithInlineParse(java.lang.String directory,
java.util.function.BooleanSupplier isSynched,
java.lang.AutoCloseable closer) |
java.util.stream.Stream<FileListDataItem> |
streamWithInlineParse(java.lang.String directory,
java.util.function.BooleanSupplier isSynched,
java.lang.AutoCloseable closer,
java.util.function.BooleanSupplier isCancelled) |
java.util.stream.Stream<FileListDataItem> |
streamWithInlineParse(java.lang.String directory,
FCClient fcClient) |
java.util.stream.Stream<FileListDataItem> |
streamWithInlineParse(java.lang.String directory,
FCClient fcClient,
java.util.function.BooleanSupplier isCancelled) |
void |
syncFileType(FileListDataItem aFile) |
java.lang.String |
system()
Get the type of the OS at the server
|
int |
testApproximateDownloadSpeed()
Performs a quick test to determine the approximate download speed to the connected server.
|
int |
testApproximateUploadSpeed()
Performs a quick test to determine the approximate upload speed to the connected server.
|
void |
testDataConnection() |
void |
testDataConnection(boolean portFallback)
Tests whether TCP data connection is possible.
|
int |
testIncomingUDP(int packetSize,
int expectedPackets,
int rate,
int destinationPort)
Send a RUDP command
Server will send the specifed number of packets back to the client
returns number of packets recieved by client
|
int |
testMaximumDownloadSpeed()
Performs a quick test to determine the approximate download speed to the
connected server.
|
int |
testMaximumUploadSpeed()
Performs a quick test to determine the approximate upload speed to the connected server.
|
void |
testMultiDataConnection() |
int |
testOutgoingUDP(int packetSize,
int numpackets,
int rate)
Send a TUDP command
returns number of packets received by the server
|
void |
testUDPACKs() |
void |
unzip(java.lang.String remoteFile,
boolean maintainPermissions,
boolean maintainTimeStamp)
Request that a file on the server be unzipped
|
void |
update(java.util.Observable observable,
java.lang.Object object) |
void |
updateReportWriter(java.lang.String transferType,
java.lang.String transferDirection,
long size,
java.nio.file.Path localFile) |
protected void |
validateLinkDataContainer(WeblinkDataContainer linkDO) |
void |
waitingForAbortAck(boolean waitingForAbortAck) |
void |
zip(java.lang.String zipFilename,
java.util.List<java.lang.String> remoteFiles) |
void |
zip(java.lang.String zipFilename,
java.util.List<java.lang.String> remoteFiles,
long zipSizeLimit) |
void |
zip(java.lang.String zipFilename,
java.util.List<java.lang.String> remoteFiles,
long zipSizeLimit,
boolean waitForZipCreation,
boolean needsRecurse) |
boolean |
zipErrors() |
public static <any> systemCache
protected final boolean printDebugStatements
protected static final FileListDataItem TERMINAL
protected static final int streamCap
protected int readTimeoutLong
public static final int commandChannelProtocol
public static final java.lang.String UNABLE_TO_CONNECT_TO_NON_FILE_CATALYST_SERVER
protected final java.lang.String TOKEN_AUTH_SUCCESS_HEADER
public static final int FTP
public static final int AUTO
public static final int HTTP
public static final int UDP
protected boolean isFileCatalystServerEnterprise
protected boolean isFileCatalystServerPro
protected boolean isFileCatalystServer
protected RemoteServiceVersion remoteServiceVersion
protected boolean isConnected
protected int maxServerRate
protected MonitoredTransfer monitoredTransfer
protected int targetRate
protected java.lang.String cachePWD
protected <any> sizeCache
protected <any> modtimeCache
protected int newDownloadRate
protected java.lang.String clientName
protected java.nio.file.Path clientWorkingPath
protected java.lang.String sessionID
protected java.lang.String serverAgentID
protected java.lang.String clientAgentID
public final long sessionTimeStamp
public final int sessionCount
protected int transferID
protected java.lang.String servletLocation
protected boolean http
protected boolean shouldPerformServerPostProcess
protected UDPTransferSettings transferSettings
protected boolean isLoggedIn
protected boolean isTransferringData
protected volatile int sessionPriority
protected FCSSLSocketProducerImpl sslSocketProducer
protected FCClientEngine()
public RemoteServiceVersion remoteServiceVersion()
public java.lang.String getTaskID()
public void setTaskID(java.lang.String taskID)
public void setMonitoredTransfer(MonitoredTransfer monitoredTransfer)
public long getLastThroughtput()
public java.lang.Object getComLock()
public final MonitoredTransfer getMonitoredTransfer()
public void setUDPTransferMetrics(UDPTransferMetrics udp)
public void generateNewTransferID()
protected final void setTransferID(int transferID)
public java.util.Map<java.lang.String,java.lang.Integer> getCurrentFileToIDs()
public void setCurrentFileToIDs(java.util.Map<java.lang.String,java.lang.Integer> currentFileToIDs)
public boolean isQuitting()
public void setQuitting(boolean quitting)
public static FCClientEngine createFCClientEngine(java.lang.String remoteHost, boolean sslSocket) throws java.io.IOException, FCException
remoteHost - sslSocket - java.io.IOExceptionFCExceptionpublic static FCClientEngine createFCClientEngine(java.lang.String remoteHost, boolean sslSocket, FCClient fcClient) throws java.io.IOException, FCException
java.io.IOExceptionFCExceptionpublic static FCClientEngine createFCClientEngine(FCClientControlSocketRequestData ctrlSocketData) throws java.io.IOException, FCException
remoteHost - ctrlClientPort - sslSocket - log - millis - enableReporting - java.io.IOExceptionFCExceptionpublic static FCClientEngine createFCClientEngine(FCClientControlSocketRequestData ctrlSocketData, FCClient fcClient) throws java.io.IOException, FCException
java.io.IOExceptionFCExceptionpublic static FCClientEngineBridge createFCClientEngine(java.net.Socket controlSocket,
boolean sslSocket,
java.util.function.Supplier<ClientCredentials> credentials,
LogUtils log,
int millis)
throws java.io.IOException,
FCException
controlSocket - sslSocket - user - password - log - millis - enableReporting - fileMode - File mode UDP Receiver should open up files. Valid modes should be "", rw, rws, rwd. Blank lets the
OS detemine the mode (legacy)writeBufferSize - Size of write buffer (in bytes) to use to write to disk. Default size of zero will save
files in block-size chunks.java.io.IOExceptionFCExceptionpublic static FCClientEngine createFCClientEngine(java.net.Socket controlSocket, boolean sslSocket, java.util.function.Supplier<ClientCredentials> credentials, LogUtils log, int millis, FCClient fcClient) throws java.io.IOException, FCException
java.io.IOExceptionFCExceptionpublic static void initSOCKS(java.lang.String port,
java.lang.String host)
port - SOCKS proxy porthost - SOCKS proxy hostnamepublic static void initSOCKSAuthentication(java.lang.String username,
java.lang.String password)
username - the SOCKS usernamepassword - the SOCKS passwordpublic void setReadTimeout(int millisecs)
millisecs - int@Deprecated public void setConnectMode(FCConnectMode mode)
mode - ACTIVE or PASV modepublic boolean isConnected()
public void setErrorMessage(java.lang.String errMess)
errMess - text of the error messagepublic void setDataPort(int[] dataPort)
dataPort - public int[] getDataPort()
public java.lang.String getErrorMessage()
public void setLogStream(LogUtils log)
log - the new logging streampublic void setMaxServerRate(int rate)
rate - public void setMaxRate(int rate)
public FCReply getLastValidReply()
public java.lang.String getLastReplyText()
public void setup(java.util.function.Supplier<ClientCredentials> newCredentials) throws java.io.IOException, FCException
ClientCredentials - credentialsjava.io.IOExceptionFCExceptionprotected void setLastValidReply(FCReply reply)
public void testUDPACKs()
public void detectFCServer()
throws java.io.IOException,
FCException
java.io.IOExceptionFCExceptionpublic void notifyServerOfCurrentRTT()
throws java.io.IOException,
FCException
java.io.IOExceptionFCExceptionpublic void quit()
throws java.io.IOException,
FCException
java.io.IOExceptionFCExceptionpublic void quit(boolean flushCaches)
throws java.io.IOException,
FCException
java.io.IOExceptionFCExceptionprotected java.lang.String getVersionForSetup()
public void abort(boolean waitForReply)
throws java.io.IOException,
FCException
java.io.IOExceptionFCExceptionpublic boolean checkDownloadPermissions()
public boolean checkUploadModifyPermissions()
public void quote(java.lang.String command,
java.lang.String[] validCodes)
throws java.io.IOException,
FCException
command - command to be sent to servervalidCodes - valid return codes for this commandjava.io.IOExceptionFCExceptionpublic java.lang.String help(java.lang.String command)
throws java.io.IOException,
FCException
command - name of the command to get help onjava.io.IOExceptionFCExceptionpublic java.lang.String system()
throws java.io.IOException,
FCException
java.io.IOExceptionFCExceptionprotected java.lang.String getSystKey()
protected java.lang.String innerSyst()
throws java.io.IOException,
FCException
java.io.IOExceptionFCExceptionpublic java.lang.String featureSet()
throws java.io.IOException,
FCException
java.io.IOExceptionFCExceptionpublic boolean serverSupportsFSEvents()
public java.util.ArrayList<FileSystemEvent> fileSystemEvents(long timeout) throws java.io.IOException, FCException
java.io.IOExceptionFCExceptionpublic void filter(FileCatalystFileFilter<?> filter) throws java.io.IOException
filter - Filter object containing the data that you wish to filter onjava.io.IOExceptionprotected java.lang.String buildFilterCommand(FileCatalystFileFilter<?> filter) throws FCException
filter - Filter that contains the data that we will be sendingFCException@Deprecated
public void filter(long olderThan,
long newerThan,
long upperByteLimit,
long lowerByteLimit,
java.lang.String filterString,
int filterMode,
boolean applyFilterToDirectories)
throws java.io.IOException,
FCException
filter(FileCatalystFileFilter) insteadolderThan - newerThan - upperByteLimit - lowerByteLimit - filterString - filterMode - java.io.IOExceptionFCExceptionpublic void modtime(java.lang.String remoteFile,
java.util.Date d)
throws java.io.IOException,
FCException
remoteFile - name of remote filejava.io.IOExceptionFCExceptionpublic java.util.Date modtime(java.lang.String remoteFile)
throws java.io.IOException,
FCException
remoteFile - name of remote filejava.io.IOExceptionFCExceptionpublic java.util.Date modtime(java.lang.String remoteFile,
boolean bypassCache)
throws java.io.IOException,
FCException
remoteFile - name of remote filejava.io.IOExceptionFCExceptionpublic void flushCaches()
public void noop()
throws java.io.IOException,
FCException
java.io.IOExceptionFCExceptionpublic void log(java.lang.String line)
public void log(java.lang.String line,
java.lang.Throwable e)
public LogUtils getLogger()
public int testIncomingUDP(int packetSize,
int expectedPackets,
int rate,
int destinationPort)
throws java.io.IOException,
FCException
java.io.IOExceptionFCExceptionpublic int testOutgoingUDP(int packetSize,
int numpackets,
int rate)
throws java.io.IOException,
FCException
java.io.IOExceptionFCExceptionpublic void testDataConnection()
throws java.io.IOException,
FCException
java.io.IOExceptionFCExceptionpublic void testDataConnection(boolean portFallback)
throws java.io.IOException,
FCException
portFallback - java.io.IOExceptionFCExceptionpublic void testMultiDataConnection()
throws java.io.IOException,
FCException
java.io.IOExceptionFCExceptionpublic boolean isServerTimeout()
throws FCException,
java.io.IOException
FCExceptionjava.io.IOExceptionpublic void initAES()
throws java.io.IOException,
FCException
java.io.IOExceptionFCExceptionpublic java.lang.String pwd()
throws java.io.IOException,
FCException
java.io.IOExceptionFCExceptionpublic void cdup()
throws java.io.IOException,
FCException
java.io.IOExceptionFCExceptionpublic boolean exists(java.lang.String remoteFile)
throws FCException,
java.io.IOException
remoteFile - String The path to the remote fileFCException - If an error in the FC protocol occursjava.io.IOException - If a timeout, or other IO error occurspublic boolean serverSupportsUDP()
public boolean isFileCatalystServer()
public boolean isFileCatalystServerPro()
public boolean isFileCatalystServerEnterprise()
public void binary()
throws java.io.IOException,
FCException
java.io.IOExceptionFCExceptionpublic void setDownloadRate(int targetRate,
int startRate)
throws java.io.IOException,
FCException
java.io.IOExceptionFCExceptionprotected void sendTransmitRateCommand(int targetRate,
int startRate)
throws java.io.IOException
java.io.IOExceptionpublic FCClient getFCClientObject() throws FCException, java.io.IOException
FCExceptionjava.io.IOExceptionpublic void reconnect(boolean maintainCurrentDirectory)
throws FCException,
java.io.IOException
FCExceptionjava.io.IOExceptionpublic void chdir(java.lang.String dir)
throws java.io.IOException,
FCException
dir - name of remote directory to change tojava.io.IOExceptionFCExceptionprotected void refreshCachedPWD(java.lang.String dir)
throws java.io.IOException
java.io.IOExceptionpublic void mkfile(java.lang.String file)
throws java.io.IOException,
FCException
dir - name of remote directory to createjava.io.IOExceptionFCExceptionpublic void mkdir(java.lang.String remotedir)
throws java.io.IOException,
FCException
dir - name of remote directory to createjava.io.IOExceptionFCExceptionpublic java.lang.String mksig(java.lang.String srcfile,
java.lang.String uniqueID)
throws java.io.IOException,
FCException
srcfile - java.io.IOExceptionFCExceptionpublic java.lang.String mksig(java.lang.String srcfile,
boolean compress,
java.lang.String uniqueID)
throws java.io.IOException,
FCException
srcfile - String Name of the source file.compress - boolean Compress flag for the signature. Default false (value currently ignored in v2.4.2)uniqueID - String Unique identifier for the delta transferjava.io.IOExceptionFCExceptionpublic void mkdlt(java.lang.String srcfile,
java.lang.String sigfile,
int blockLength,
boolean compress,
int compLevel,
int strategy)
throws java.io.IOException,
FCException
srcfile - Stringsigfile - StringblockLength - intcompress - booleancompLevel - intstrategy - intjava.io.IOExceptionFCExceptionpublic void mkdlt(java.lang.String srcfile,
java.lang.String sigfile,
int blockLength,
boolean compress,
int compLevel,
int strategy,
java.lang.String uniqueID,
boolean waitForDeltaCreation)
throws java.io.IOException,
FCException
srcfile - Stringsigfile - StringblockLength - intcompress - booleancompLevel - intstrategy - intuniqueID - Stringjava.io.IOExceptionFCExceptionpublic boolean isDeltasStillGrowing()
throws FCException,
java.io.IOException
FCExceptionjava.io.IOExceptionpublic boolean isZipStillGrowing(java.lang.String zipFileName)
throws FCException,
java.io.IOException
FCExceptionjava.io.IOExceptionprotected boolean innerZipChunkTest(java.lang.String zipFileName)
throws FCException,
java.io.IOException
FCExceptionjava.io.IOExceptionpublic boolean isZipStillExtracting()
throws FCException,
java.io.IOException
FCExceptionjava.io.IOExceptionpublic java.lang.String rbfil(java.lang.String srcfile,
java.lang.String deltafile,
int blockLength,
boolean compress,
int level,
boolean uniqueName)
throws java.io.IOException,
FCException
srcfile - Stringdeltafile - StringblockLength - intcompress - booleanlevel - intuniqueName - booleanjava.io.IOExceptionFCExceptionpublic void rmdir(java.lang.String dir)
throws java.io.IOException,
FCException
dir - name of remote directory to deletejava.io.IOExceptionFCExceptionpublic void serverPostProcess(java.lang.String file)
throws java.io.IOException,
FCException
file - The file on which to perform post processingjava.io.IOExceptionFCExceptionpublic boolean shouldPerformServerPostProcess()
public void rename(java.lang.String from,
java.lang.String to)
throws java.io.IOException,
FCException
from - name of file or directory to renameto - intended namejava.io.IOExceptionFCExceptionpublic void delete(java.lang.String remoteFile)
throws java.io.IOException,
FCException
remoteFile - name of remote file to deletejava.io.IOExceptionFCExceptionpublic void deleteAll(java.util.List<java.lang.String> remoteFiles)
throws java.io.IOException,
FCException
remoteFiles - files to deletejava.io.IOExceptionFCExceptionpublic void deleteAll(java.util.List<java.lang.String> remoteFiles,
boolean ftpDelete)
throws java.io.IOException,
FCException
remoteFiles - files to deleteftpDelete - use FTP style deletion, rejecting deletes on directories if they contain itemsjava.io.IOExceptionFCExceptionpublic void deleteAll(FileListData remoteFiles) throws FCException, java.io.IOException
FCExceptionjava.io.IOExceptionpublic void deleteAll(FileListData remoteFiles, boolean ftpDelete) throws FCException, java.io.IOException
FCExceptionjava.io.IOExceptionpublic void applyRemoteFileAttributesToLocalFile(java.nio.file.Path localFile,
java.lang.String remoteFile)
throws java.io.IOException
java.io.IOExceptionpublic java.lang.String getMD5(java.lang.String remoteFile)
throws java.io.IOException,
FCException
remoteFile - name of remote file to deletejava.io.IOExceptionFCExceptionpublic void unzip(java.lang.String remoteFile,
boolean maintainPermissions,
boolean maintainTimeStamp)
throws java.io.IOException,
FCException
remoteFile - name of remote file to unzipjava.io.IOExceptionFCExceptionprotected java.lang.String buildUNZIPCommand(java.lang.String remoteFile,
boolean maintainPermissions,
boolean maintainTimeStamp)
public void zip(java.lang.String zipFilename,
java.util.List<java.lang.String> remoteFiles)
throws java.io.IOException,
FCException
java.io.IOExceptionFCExceptionpublic void zip(java.lang.String zipFilename,
java.util.List<java.lang.String> remoteFiles,
long zipSizeLimit)
throws java.io.IOException,
FCException
java.io.IOExceptionFCExceptionpublic void zip(java.lang.String zipFilename,
java.util.List<java.lang.String> remoteFiles,
long zipSizeLimit,
boolean waitForZipCreation,
boolean needsRecurse)
throws java.io.IOException,
FCException
java.io.IOExceptionFCExceptionpublic java.lang.String getMD5(java.lang.String remoteFile,
long offset,
long length)
throws java.io.IOException,
FCException
remoteFile - name of remote file to deletejava.io.IOExceptionFCExceptionpublic java.lang.String getMD5(java.lang.String remoteFile,
long offset,
long length,
long checkInterval,
long checkLength)
throws java.io.IOException,
FCException
remoteFile - name of remote file to deletejava.io.IOExceptionFCExceptionprotected java.lang.String performSyncedMD5(java.lang.String md5Command)
throws java.io.IOException,
FCException
java.io.IOExceptionFCExceptionprotected java.lang.String performAsyncMD5(java.lang.String md5Command)
throws java.io.IOException
java.io.IOExceptionpublic FileListData dir(java.lang.String dirname, boolean full) throws java.io.IOException, FCException
dirname - name of directory ( not a file mask)full - true if detailed listing required false otherwisejava.io.IOExceptionFCExceptionpublic java.lang.String[] dirRaw(java.lang.String dirname,
boolean full,
java.lang.String filterFlag)
throws java.io.IOException,
FCException
java.io.IOExceptionFCExceptionprotected DirListTool getDirListTool(DirListParams p, FCClientEngine e) throws FCException, java.io.IOException
FCExceptionjava.io.IOExceptionpublic FileListData dir(java.lang.String dirname, boolean full, java.lang.String filterFlag) throws java.io.IOException, FCException
dirname - name of directory ( not a file mask)full - true if detailed listing required false otherwisefilterFlag - apply a filter flag (-f for files) to the dir command. Only valid when FULL is set to FALSE.java.io.IOExceptionFCExceptionpublic FileListData dir(java.lang.String dirname, boolean full, java.lang.String filterFlag, java.lang.String wildcard) throws java.io.IOException, FCException
dirname - name of directory ( not a file mask)full - true if detailed listing required false otherwisefilterFlag - apply a filter flag (-f for files) to the dir command. Only valid when FULL is set to FALSE.wildcard - apply a wildcard to the list on server side to increase performancejava.io.IOExceptionFCExceptionprotected FileListData doDirListing(java.lang.String dirname, boolean full, java.lang.String filterFlag, java.lang.String wildcard, FileListDataItemConsumer resultData) throws java.io.IOException, FCException, java.net.SocketException, java.io.UnsupportedEncodingException
java.io.IOExceptionFCExceptionjava.net.SocketExceptionjava.io.UnsupportedEncodingExceptionprotected FileListData doDirListing(java.lang.String dirname, boolean full, java.lang.String filterFlag, java.lang.String wildcard, FileListDataItemConsumer resultData, java.util.function.BooleanSupplier isCancelled) throws java.io.IOException, FCException, java.net.SocketException, java.io.UnsupportedEncodingException
java.io.IOExceptionFCExceptionjava.net.SocketExceptionjava.io.UnsupportedEncodingExceptionpublic java.util.stream.Stream<FileListDataItem> doDirStream(java.lang.String dirname, boolean full, java.lang.String filterFlag, java.lang.String wildcard, FileListDataItemConsumer resultData, java.util.function.BooleanSupplier isCancelled) throws java.io.IOException, FCException, java.net.SocketException, java.io.UnsupportedEncodingException
java.io.IOExceptionFCExceptionjava.net.SocketExceptionjava.io.UnsupportedEncodingExceptionpublic java.util.stream.Stream<FileListDataItem> doDirStream(DirListParams params) throws FCException, java.io.IOException, java.net.SocketException, java.io.UnsupportedEncodingException
FCExceptionjava.io.IOExceptionjava.net.SocketExceptionjava.io.UnsupportedEncodingExceptionpublic void rmdirRecursive(FileListDataItem item) throws java.lang.Exception
item - java.lang.Exceptionpublic FileListData dir(java.lang.String dirname) throws java.io.IOException, FCException
dirname - name of directory( not a file mask)java.io.IOExceptionFCExceptionpublic FileListData dir() throws java.io.IOException, FCException
java.io.IOExceptionFCExceptionpublic void sendEmail(java.lang.String emailAddress,
int statusCode,
java.lang.String note)
throws java.io.IOException,
FCException
email - the senders email addresscode - the constant code representing the transfer statusjava.io.IOExceptionFCExceptionpublic boolean site(java.lang.String command)
throws java.io.IOException,
FCException
command - the site command to runjava.io.IOExceptionFCExceptionpublic java.lang.String size(java.lang.String fileName,
boolean bypassCache)
throws java.io.IOException,
FCException
fileName - name of the filejava.io.IOExceptionFCExceptionpublic long creationTime(java.lang.String fileName)
throws java.io.IOException,
FCException
fileName - name of the filejava.io.IOExceptionFCExceptionpublic long accessTime(java.lang.String fileName)
throws java.io.IOException,
FCException
fileName - name of the filejava.io.IOExceptionFCExceptionpublic java.lang.String getPlatForm()
throws java.io.IOException
java.io.IOExceptionpublic int getIdealConcurrentFTPStreams(int rate,
long length,
int bufferSize,
int maxStream)
public java.lang.String getServerVersion()
public java.lang.String[] prms(java.lang.String fileName)
throws java.io.IOException,
FCException
fileName - name of the filejava.io.IOExceptionFCExceptionpublic void resetTransferVariables()
public void put(UploadTransferRequestData requestData) throws java.io.IOException, FCException
localPath - path of the local fileremoteFile - name of remote file in current directoryoutRate - sending bandwidthnumDFEncoders - number of DF encoders to be usedappend - true if appending, false otherwisejava.io.IOExceptionFCExceptionpublic boolean putIsFinished()
public void getHTTP(DownloadTransferRequestData requestData) throws java.io.IOException, FCException, java.io.IOException
java.io.IOExceptionFCExceptionpublic void setOverrideServerBandwidth(FTPTransmit transfer)
public final boolean isTimeout(java.lang.String message)
protected final boolean isChannelClosed(java.lang.String message)
protected java.lang.String getRemoteHost()
protected java.lang.String getLocalHost()
protected void detectSessionKilledByAdmin()
protected void sendRTTKeepALive()
public void gobbleExtraReplies(int incomingTimeout,
int incomingNumToGobble)
public void get(DownloadTransferRequestData downloadRequestData) throws java.io.IOException, FCException, java.security.NoSuchAlgorithmException, FCException, java.io.IOException
localPath - path of the local fileremoteFile - name of remote file in current directoryoutRate - sending bandwidthnumDFEncoders - number of DF encoders to be usedappend - true if appending, false otherwisejava.io.IOExceptionFCExceptionjava.security.NoSuchAlgorithmExceptionpublic java.net.Socket createThirdPartyFTPServerDataConnection(java.lang.String command)
throws java.io.IOException
java.io.IOExceptionpublic boolean isReportingEnabled()
public int[] initFCTransfer(int numDecoders,
int blockSize,
int unitSize,
long length,
boolean congestionControl,
int fileID,
int mode)
throws FCException,
java.io.IOException
FCExceptionjava.io.IOExceptionpublic void update(java.util.Observable observable,
java.lang.Object object)
update in interface java.util.Observerobservable - object - protected void informServerToWriteReport(PropertyTransmission reportArgs)
public java.lang.String getReportStatus(MonitoredTransfer monTransfer)
public int getTransferPercent()
public int getMeanEffectiveRate()
public int getBlastRate()
public int getTransferRate()
public int getCurrentRate()
public int getCurrentGoodputRate()
public long getTransferGoodput()
public long getTransferThroughput()
public boolean isTransferComplete()
public boolean isTransferCancelled()
public boolean isTransferError()
public boolean cancelTransfer()
public long getTransferLength()
public int setBandwidth(int bandwidth)
protected void setBandwidthRemoteTransfer(int bandwidth)
protected int setBandwidthFTPReceiver(int bandwidth)
protected int setBandwidthFTPTransmit(int bandwidth,
MonitoredTransfer monitoredTransfer)
protected int setBandwidthUPDReceiver(int bandwidth)
protected int setBandwidthUDPSender(int bandwidth)
public void setCongestionControl(boolean congestionControl)
public int getStartRate()
public void setStartRate(int startRate)
public boolean isCongestionControl()
public int getNumFTPStreams()
public boolean isUseCompression()
public int getCompStrategy()
public int getCompMethod()
public int getCompLevel()
public boolean isAllowConnectNonFileCatalystServer()
public java.lang.String getWelcomeMessage()
public int getClientIdentifier()
public int getCongestionControlAggression()
public void setNumFTPStreams(int numFTPStreams)
public void setUseCompression(boolean useCompression)
public void setCompMethod(int compMethod)
public void setCompLevel(int compLevel)
@Deprecated public void setCompStrategy(int compStrategy)
compStrategy - public void setReadTimeoutLong(int millisecs)
millisecs - intpublic void setWelcomeMessage(java.lang.String welcomeMessage)
public void setClientIdentifier(int clientIdentifier)
public void setCongestionControlAggression(int congestionControlAggression)
public void addClientConnectKey(java.lang.String key)
public int getNumUDPSockets()
public void setNumUDPSockets(int numUDPSockets)
numUDPSockets - the numUDPSockets to setpublic double getPacketLoss()
public int getCurrentRTT()
public boolean isForceTCPmodeACKs()
public void setForceTCPmodeACKs(boolean forceTCPmodeACKs)
forceTCPmodeACKs - the forceTCPmodeACKs to setpublic java.lang.String getServerAgentID()
public java.lang.String getClientAgentID()
public void setClientAgentID(java.lang.String clientAgentID)
public java.lang.String getSessionID()
public int getClientSubIdentifier()
public void setClientSubIdentifier(int clientSubIdentifier)
clientSubIdentifier - the clientSubIdentifier to setpublic java.lang.String getClientString()
public void setClientString(java.lang.String clientString)
clientString - the clientString to setpublic void setReportManager(FCClientReportManager reporter)
public FCClientReportManager getReportManager()
public ClientDataReport getReporter()
public boolean hasReporter()
public void setClientName(java.lang.String clientName)
clientName - the clientName to setpublic void setClientWorkingPath(java.nio.file.Path clientWorkingPath)
clientName - the hotFolderName to setclientWorkingPath - TODOpublic java.lang.String getServletLocation()
public void setServletLocation(java.lang.String servletLocation)
servletLocation - the servletLocation to setpublic boolean isHttp()
public void setHttp(boolean http)
http - the http to setpublic UDPTransferSettings getTransferSettings()
public void setProgressiveTransfer(boolean isProgressive)
public boolean isProgressiveTransfer()
public void setTransferSettings(UDPTransferSettings transferSettings)
transferSettings - the transferSettings to setpublic UDPTransferMetricsContainer getTransferMetrics()
public RemoteServiceVersion getRemoteServiceVersion()
public void remoteTransferInitiate(ServerToServerTransferSettings settings) throws java.io.IOException, FCException
FCExceptionjava.io.IOExceptionpublic java.lang.String createPatch(java.lang.String remoteFile,
long offset,
long length)
throws java.io.IOException,
FCException
remoteFile - offset - length - java.io.IOExceptionFCExceptionpublic void applyPatch(java.lang.String remoteFile,
java.lang.String remotePatch,
long offset)
throws java.io.IOException,
FCException
remoteFile - remotePatch - offset - java.io.IOExceptionFCExceptionpublic java.lang.String remoteTransferStatus()
throws FCException,
java.io.IOException
FCExceptionjava.io.IOExceptionpublic boolean zipErrors()
throws java.io.IOException
java.io.IOExceptionpublic int testApproximateUploadSpeed()
throws FCException,
java.io.IOException
unlimited.core.util.common.exception.FCExceptionFCExceptionjava.io.IOExceptionpublic int testApproximateDownloadSpeed()
throws FCException,
java.io.IOException
unlimited.core.util.common.exception.FCExceptionFCExceptionjava.io.IOExceptionpublic int testMaximumUploadSpeed()
throws FCException,
java.io.IOException
unlimited.core.util.common.exception.FCExceptionFCExceptionjava.io.IOExceptionpublic int testMaximumDownloadSpeed()
throws FCException,
java.io.IOException
unlimited.core.util.common.exception.FCExceptionFCExceptionjava.io.IOExceptionpublic boolean monitorIsNull()
public int getSessionCount()
public boolean isLoggedIn()
public void setVerifyMode(int verifyMode)
public void overrideSessionID(java.lang.String sessionID)
public boolean isComplete()
public java.util.stream.Stream<FileListDataItem> streamWithInlineParse(java.lang.String directory, FCClient fcClient) throws FCException, java.net.SocketException, java.io.UnsupportedEncodingException, java.io.UncheckedIOException, java.io.IOException
FCExceptionjava.net.SocketExceptionjava.io.UnsupportedEncodingExceptionjava.io.UncheckedIOExceptionjava.io.IOExceptionpublic java.util.stream.Stream<FileListDataItem> streamWithInlineParse(java.lang.String directory, FCClient fcClient, java.util.function.BooleanSupplier isCancelled) throws FCException, java.net.SocketException, java.io.UnsupportedEncodingException, java.io.UncheckedIOException, java.io.IOException
FCExceptionjava.net.SocketExceptionjava.io.UnsupportedEncodingExceptionjava.io.UncheckedIOExceptionjava.io.IOExceptionpublic java.util.stream.Stream<FileListDataItem> streamWithInlineParse(java.lang.String directory, java.util.function.BooleanSupplier isSynched, java.lang.AutoCloseable closer) throws FCException, java.net.SocketException, java.io.UnsupportedEncodingException, java.io.UncheckedIOException, java.io.IOException
FCExceptionjava.net.SocketExceptionjava.io.UnsupportedEncodingExceptionjava.io.UncheckedIOExceptionjava.io.IOExceptionpublic java.util.stream.Stream<FileListDataItem> streamWithInlineParse(java.lang.String directory, java.util.function.BooleanSupplier isSynched, java.lang.AutoCloseable closer, java.util.function.BooleanSupplier isCancelled) throws FCException, java.net.SocketException, java.io.UnsupportedEncodingException, java.io.UncheckedIOException, java.io.IOException
FCExceptionjava.net.SocketExceptionjava.io.UnsupportedEncodingExceptionjava.io.UncheckedIOExceptionjava.io.IOExceptionpublic <any> exists(java.util.stream.Stream<java.lang.String> nameStream)
public java.util.stream.Stream<FileListDataItem> remoteSynchFile(java.util.stream.Stream<FileListDataItem> itemStream)
public java.lang.String getUserEmail()
throws java.io.IOException,
FCException
java.io.IOExceptionFCExceptionpublic void setUserEmail(java.lang.String newEmail)
throws java.io.IOException
newEmail - - The New Email Address To Be Setjava.io.IOExceptionpublic java.lang.String getUserFullName()
throws FCException,
java.io.IOException
FCExceptionjava.io.IOExceptionpublic void setUserFullName(java.lang.String newName)
throws FCException,
java.io.IOException
FCExceptionjava.io.IOExceptionpublic UserPermissionsContainer getUserPermissions() throws FCException, java.io.IOException
java.io.IOExceptionFCExceptionpublic WeblinkResult sendWeblink(WeblinkDataContainer linkDO) throws FCException, java.io.IOException
linkDO - - Data Container Containing Data For The Linkjava.io.IOExceptionFCExceptionprotected void validateLinkDataContainer(WeblinkDataContainer linkDO) throws FCException
FCExceptionprotected java.lang.String buildWeblinkCommand(WeblinkDataContainer linkDO)
public void sendJobStatus(TransferStatusEnum status) throws FCException, java.io.IOException
FCExceptionjava.io.IOExceptionpublic boolean isLinkEnabledOnServer()
throws FCException,
java.io.IOException
FCExceptionjava.io.IOExceptionpublic int getServerLinkExpiryDayValue()
throws FCException,
java.io.IOException
FCExceptionjava.io.IOExceptionpublic java.lang.String getServerConfigurationValue(java.lang.String request)
throws FCException,
java.io.IOException
FCExceptionjava.io.IOExceptionpublic ServerConfigs getAllServerClientConfigs() throws FCException, java.io.IOException
FCExceptionjava.io.IOExceptionpublic java.lang.String getCachedPWD()
public boolean getIsTransferringData()
public void updateReportWriter(java.lang.String transferType,
java.lang.String transferDirection,
long size,
java.nio.file.Path localFile)
public float getTransmitZipRatio()
public void setSessionPriority(int priority)
public int lastServerRestrictedRate()
public boolean isServerBandwidthOverride()
public HashCode getHashCode()
public int getTransferID()
public ForceFileOwnershipConfig getForceFileOwnerConfig()
public void syncFileType(FileListDataItem aFile)
public void registerReportListener(MultiTransferHandler<?> mth)
public AutoDetectData getAutoDetectData()
public boolean hasAutoDetectData()
public void setAutoDetectData(FCClient fcClient)
public static FCClienEngineSpeedCache getSpeedcache()
public FCClientControlSocketBridge ctrlClient()
public int numFTPStreams()
public void numFTPStreams(int streams)
public void lastValidReply(FCReply validateReply)
public FCReply lastValidReply()
public void close()
throws java.lang.Exception
java.lang.Exceptionpublic void isAborted(boolean isAborted)
public void abortAck(boolean abortAck)
public boolean getDone()
public void getDone(boolean isDone)
public int readTimeout()
public void readTimeout(int readTimeout)
public void putDone(boolean putDone)
public boolean putDone()
public void waitingForAbortAck(boolean waitingForAbortAck)
public void setSslSocketProducer(FCSSLSocketProducerImpl sslSocketProducer)
public void setCurrentFilesMatch(FilesMatch filesMatch)