Package | Description |
---|---|
org.waarp.http.protocol | |
org.waarp.openr66.client |
Classes implementing Clients
|
org.waarp.openr66.commander |
Classes implementing Commander, reader of database updates from clients
|
org.waarp.openr66.context |
Classes implementing Session, Result and ErrorCode
|
org.waarp.openr66.context.filesystem |
Classes implementing Filesystem
|
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.database.data |
Classes implementing Database Data model
|
org.waarp.openr66.protocol.localhandler |
Classes implementing LocalHandlers (real work)
|
org.waarp.openr66.protocol.utils |
Classes implementing Utilities
|
Constructor and Description |
---|
HttpDeleteSession(String identifier,
HttpAuthent authent)
Constructor for reading from database only
|
Modifier and Type | Method and Description |
---|---|
io.netty.channel.ChannelFuture |
SendThroughClient.writeWhenPossible(DataBlock block)
Write the next block when the channel is ready to prevent OOM
|
Modifier and Type | Method and Description |
---|---|
R66Future |
ClientRunner.finishTransfer(LocalChannelReference localChannelReference)
Finish the transfer (called at the end of runTransfer)
|
LocalChannelReference |
ClientRunner.initRequest()
Initialize the request
|
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
|
Modifier and Type | Method and Description |
---|---|
void |
R66BusinessInterface.checkAfterPost(R66Session session)
Called once the post tasks are over in success
|
void |
R66BusinessInterface.checkAfterPreCommand(R66Session session)
Called once the pre tasks are over in success
|
void |
R66BusinessInterface.checkAfterTransfer(R66Session session)
Called once the transfer is done in success but before the post tasks
|
void |
R66BusinessInterface.checkAtAuthentication(R66Session session)
Called once the authentication is done
|
void |
R66BusinessInterface.checkAtChangeFilename(R66Session session)
Called once after pre tasks, while filename could be changed (or not)
|
void |
R66BusinessInterface.checkAtConnection(R66Session session)
Called once the connection is opened
|
void |
R66BusinessInterface.checkAtStartup(R66Session session)
Called once the DbTaskRunner is created/loaded and before pre tasks
|
void |
R66Session.renameReceiverFile(String newFilename)
Rename the current receive file from the very beginning since the sender
has a post action that changes its
name
|
void |
R66Session.setFileAfterPreRunner(boolean createFile)
Set the File from the runner once PRE operation are done
|
void |
R66Session.setFileBeforePreRunner()
Set the File from the runner before PRE operation are done
|
void |
R66Session.setFinalizeTransfer(boolean status,
R66Result finalValue)
Finalize the transfer step by running the error or post operation
according
to the status.
|
void |
R66Session.setRunner(DbTaskRunner runner)
Set the runner, and setup the directory first.
|
void |
R66Session.startup(boolean checkNotExternal)
START from the PreTask if necessary, and prepare the file
|
void |
R66Session.tryFinalizeRequest(R66Result errorValue)
Try to finalize the request if possible
|
Modifier and Type | Method and Description |
---|---|
void |
R66File.retrieveBlocking(AtomicBoolean running)
Start the retrieve (send to the remote host the local file)
|
Modifier and Type | Method and Description |
---|---|
static FtpArgs |
FtpArgs.getFtpArgs(String[] args)
"-file filepath
-to requestedHost -port port -user user -pwd pwd [-account account] [-mode active/passive] [-ssl no/implicit/explicit] [-cwd remotepath] [-digest (crc,md5,sha1)] [-pre extraCommand1 with ',' as separator of arguments] -command command from (get,put,append) [-post extraCommand2 with ',' as separator of arguments]" |
static AbstractTask |
TaskType.getTaskFromId(String name,
String argRule,
int delay,
R66Session session) |
static AbstractTask |
TaskType.getTaskFromId(TaskType type,
String argRule,
int delay,
R66Session session) |
static AbstractTask |
TaskType.getTaskFromIdForBusiness(String name,
String argRule,
int delay,
R66Session session)
For usage in ExecBusinessTask
|
Modifier and Type | Method and Description |
---|---|
void |
DbTaskRunner.finalizeTransfer(LocalChannelReference localChannelReference,
R66File file,
R66Result finalValue,
boolean status)
Once the transfer is over, finalize the Runner by running the error or
post
operation according to the
status.
|
AbstractTask |
DbTaskRunner.getTask(String[] task,
R66Session tempSession) |
void |
DbTaskRunner.run()
Run all task from current status (globalstep and step)
|
void |
DbTaskRunner.saveStatus()
This method is to be called each time an operation is happening on Runner
|
Modifier and Type | Method and Description |
---|---|
void |
TransferActions.endTransfer(EndTransferPacket packet)
Receive an End of Transfer
|
void |
ConnectionActions.errorMesg(ErrorPacket packet)
Receive a remote error
|
void |
ServerActions.jsonCommand(JsonCommandPacket packet)
Receive a json request
|
void |
TransferActions.request(RequestPacket packet)
Receive a request of Transfer
|
void |
TransferActions.requestChangeFileInfo(String newFileInfo)
If newFileInfo is provided and different than current value
|
void |
TransferActions.requestChangeNameSize(String newfilename,
long newSize)
Change the filename and the filesize
|
void |
ConnectionActions.tryFinalizeRequest(R66Result errorValue)
Try to finalize the request if possible
|
void |
ServerActions.valid(ValidPacket packet)
Receive a validation or a special request
|
static io.netty.channel.ChannelFuture |
RetrieveRunner.writeWhenPossible(DataBlock block,
LocalChannelReference localChannelReference)
Write the next block when the channel is ready to prevent OOM
|
Modifier and Type | Method and Description |
---|---|
static void |
TransferUtils.finalizeTaskWithNoSession(DbTaskRunner taskRunner,
LocalChannelReference localChannelReference)
Finalize a local task since only Post action has to be done
|
static R66File |
FileUtils.getFile(WaarpLogger logger,
R66Session session,
String filenameSrc,
boolean isPreStart,
boolean isSender,
boolean isThrough,
R66File file)
Change or create the R66File associated with the context
|
Copyright © 2009–2020 Waarp. All rights reserved.