Package | Description |
---|---|
org.waarp.openr66.client |
Classes implementing Clients
|
org.waarp.openr66.commander |
Classes implementing Commander, reader of database updates from clients
|
org.waarp.openr66.context.task |
Classes implementing Tasks for pre, post or error operations
Several kind of tasks exist in OpenR66:
LOG, MOVE, MOVERENAME, COPY, COPYRENAME, EXEC, EXECMOVE, LINKRENAME, TRANSFER, VALIDFILEPATH, DELETE Several tasks are possible to run before a transfer starts (pre action), after a transfer is finished correctly (post action) or after an error occurs (either in pre or post action or during transfer: error action). |
org.waarp.openr66.protocol.localhandler |
Classes implementing LocalHandlers (real work)
|
org.waarp.openr66.protocol.networkhandler |
Classes implementing Network Handler (multiplexing local handlers)
|
org.waarp.openr66.proxy.network |
Network Package for Proxy R66
|
org.waarp.openr66.r66gui |
Adaptation to Administrator
|
org.waarp.openr66.server |
Classes implementing Server startup main class or utility classes
|
Modifier and Type | Field and Description |
---|---|
protected R66Future |
AbstractBusinessRequest.future |
protected R66Future |
SpooledDirectoryTransfer.future |
protected R66Future |
AbstractTransfer.future |
Modifier and Type | Method and Description |
---|---|
protected static void |
AbstractTransfer.prepareKoOutputFormat(R66Future future,
OutputFormat outputFormat) |
protected static void |
AbstractTransfer.prepareKoOutputFormat(R66Future future,
R66Result result,
OutputFormat outputFormat) |
protected static void |
AbstractTransfer.prepareSubmitKoOutputFormat(R66Future future,
DbTaskRunner runner,
OutputFormat outputFormat) |
static boolean |
AbstractTransfer.sendValidPacket(DbHostAuth host,
LocalChannelReference localChannelReference,
AbstractLocalPacket packet,
R66Future future) |
static LocalChannelReference |
AbstractTransfer.tryConnect(DbHostAuth host,
R66Future future,
NetworkTransaction networkTransaction)
Helper to connect
|
Constructor and Description |
---|
AbstractBusinessRequest(Class<?> clasz,
R66Future future,
String remoteHost,
NetworkTransaction networkTransaction,
BusinessRequestPacket packet) |
AbstractTransfer(Class<?> clasz,
R66Future future,
String filename,
String rulename,
String fileinfo,
boolean isMD5,
String remoteHost,
int blocksize,
long id,
Timestamp timestart) |
BusinessRequest(NetworkTransaction networkTransaction,
R66Future future,
String remoteHost,
BusinessRequestPacket packet) |
DirectTransfer(R66Future future,
String remoteHost,
String filename,
String rulename,
String fileinfo,
boolean isMD5,
int blocksize,
long id,
NetworkTransaction networkTransaction) |
Message(NetworkTransaction networkTransaction,
R66Future future,
DbHostAuth hostAuth,
TestPacket packet) |
Message(NetworkTransaction networkTransaction,
R66Future future,
String requested,
TestPacket packet) |
MultipleDirectTransfer(R66Future future,
String remoteHost,
String filename,
String rulename,
String fileinfo,
boolean isMD5,
int blocksize,
long id,
NetworkTransaction networkTransaction) |
MultipleSubmitTransfer(R66Future future,
String remoteHost,
String filename,
String rulename,
String fileinfo,
boolean isMD5,
int blocksize,
long id,
Timestamp starttime,
NetworkTransaction networkTransaction) |
ProgressBarTransfer(R66Future future,
String remoteHost,
String filename,
String rulename,
String fileinfo,
boolean isMD5,
int blocksize,
long id,
NetworkTransaction networkTransaction,
long callbackdelay) |
RecvThroughClient(R66Future future,
RecvThroughHandler handler,
String remoteHost,
String filename,
String rulename,
String fileinfo,
boolean isMD5,
int blocksize,
long id,
NetworkTransaction networkTransaction) |
RequestInformation(R66Future future,
String requested,
String rulename,
String filename,
byte request,
long id,
boolean isTo,
NetworkTransaction networkTransaction) |
RequestTransfer(R66Future future,
long specialId,
String requested,
String requester,
boolean cancel,
boolean stop,
boolean restart,
NetworkTransaction networkTransaction) |
RequestTransfer(R66Future future,
long specialId,
String requested,
String requester,
boolean cancel,
boolean stop,
boolean restart,
String restarttime,
NetworkTransaction networkTransaction) |
SendThroughClient(R66Future future,
String remoteHost,
String filename,
String rulename,
String fileinfo,
boolean isMD5,
int blocksize,
long id,
NetworkTransaction networkTransaction) |
SpooledDirectoryTransfer(R66Future future,
SpooledDirectoryTransfer.Arguments arguments,
NetworkTransaction networkTransaction) |
SubmitTransfer(R66Future future,
String remoteHost,
String filename,
String rulename,
String fileinfo,
boolean isMD5,
int blocksize,
long id,
Timestamp starttime) |
Modifier and Type | Method and Description |
---|---|
R66Future |
ClientRunner.finishTransfer(LocalChannelReference localChannelReference)
Finish the transfer (called at the end of runTransfer)
|
R66Future |
ClientRunner.runTransfer()
True transfer run (can be called directly to enable exception outside any
executors)
|
R66Future |
ClientRunner.tryAgainTransferOnOverloaded(boolean retry,
LocalChannelReference localChannelReference)
In case an overloaded signal is returned by the requested
|
Constructor and Description |
---|
ClientRunner(NetworkTransaction networkTransaction,
DbTaskRunner taskRunner,
R66Future futureRequest) |
Modifier and Type | Method and Description |
---|---|
R66Future |
AbstractTask.getFutureCompletion() |
Modifier and Type | Method and Description |
---|---|
R66Future |
ServerActions.businessRequest(boolean isToApplied,
String className,
String arguments,
String extraArguments,
int delay)
Business Request (channel should stay open)
Note: the thread called should manage all writeback informations, as well
as status, channel closing if
needed or not.
|
R66Future |
LocalChannelReference.getFutureEndTransfer() |
R66Future |
LocalChannelReference.getFutureRequest() |
R66Future |
LocalChannelReference.getFutureValidateConnection() |
R66Future |
LocalChannelReference.getFutureValidateStartup() |
R66Future |
LocalChannelReference.getFutureValidRequest() |
Modifier and Type | Method and Description |
---|---|
LocalChannelReference |
LocalTransaction.createNewClient(NetworkChannelReference networkChannelReference,
Integer remoteId,
R66Future futureRequest,
boolean fromSsl)
Create a new Client
|
Constructor and Description |
---|
LocalChannelReference(NetworkChannelReference networkChannelRef,
Integer remoteId,
R66Future futureRequest) |
Modifier and Type | Method and Description |
---|---|
LocalChannelReference |
NetworkTransaction.createConnectionWithRetry(SocketAddress socketAddress,
boolean isSSL,
R66Future futureRequest)
Create a connection to the specified socketAddress with multiple retries
|
LocalChannelReference |
NetworkTransaction.createConnectionWithRetryWithAuthenticationException(SocketAddress socketAddress,
boolean isSSL,
R66Future futureRequest)
Create a connection to the specified socketAddress with multiple retries
|
Modifier and Type | Field and Description |
---|---|
protected R66Future |
NetworkServerHandler.clientFuture
Future to wait for Client to be setup
|
Constructor and Description |
---|
ProgressDirectTransfer(R66Future future,
String remoteHost,
String filename,
String rulename,
String fileinfo,
boolean isMD5,
int blocksize,
long id,
NetworkTransaction networkTransaction,
long callbackdelay,
JProgressBar progressBar,
JEditorPane textFieldStatus) |
Modifier and Type | Field and Description |
---|---|
protected R66Future |
ChangeBandwidthLimits.future |
protected R66Future |
ConfigExport.future |
protected R66Future |
ConfigImport.future |
protected R66Future |
LogExport.future |
protected R66Future |
LogExtendedExport.future |
Modifier and Type | Method and Description |
---|---|
void |
LogExtendedExport.importLog(R66Future future) |
Constructor and Description |
---|
ChangeBandwidthLimits(R66Future future,
long wgl,
long rgl,
long wsl,
long rsl,
NetworkTransaction networkTransaction) |
ConfigExport(R66Future future,
boolean host,
boolean rule,
boolean business,
boolean alias,
boolean role,
NetworkTransaction networkTransaction) |
ConfigExport(R66Future future,
boolean host,
boolean rule,
NetworkTransaction networkTransaction) |
ConfigImport(R66Future future,
boolean hostPurge,
boolean rulePurge,
boolean businessPurge,
boolean aliasPurge,
boolean rolePurge,
String host,
String rule,
String business,
String alias,
String role,
NetworkTransaction networkTransaction) |
ConfigImport(R66Future future,
boolean hostPurge,
boolean rulePurge,
String host,
String rule,
NetworkTransaction networkTransaction) |
LogExport(R66Future future,
boolean purgeLog,
boolean clean,
Timestamp start,
Timestamp stop,
NetworkTransaction networkTransaction) |
LogExtendedExport(R66Future future,
boolean clean,
boolean purgeLog,
Timestamp start,
Timestamp stop,
String startid,
String stopid,
String rule,
String request,
boolean statuspending,
boolean statustransfer,
boolean statusdone,
boolean statuserror,
NetworkTransaction networkTransaction,
DbHostAuth host) |
Copyright © 2009–2020 Waarp. All rights reserved.