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.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.http.rest.handler |
Http Rest method handlers for R66
|
org.waarp.openr66.protocol.localhandler |
Classes implementing LocalHandlers (real work)
|
org.waarp.openr66.protocol.localhandler.packet.json | |
org.waarp.openr66.protocol.snmp |
Classes implementing SNMP elements for OpenR66
|
org.waarp.openr66.protocol.utils |
Classes implementing Utilities
|
Modifier and Type | Method and Description |
---|---|
DbTaskRunner |
HttpSessionAbstract.getDbTaskRunner() |
protected DbTaskRunner |
HttpSessionAbstract.getDbTaskRunner(String user,
String filename,
String rulename,
long identifier,
String comment,
int chunkSize,
R66BusinessInterface business,
boolean uploadMode)
Initialize the DbTaskRunner for this user and rulename
|
Modifier and Type | Method and Description |
---|---|
protected void |
HttpSessionAbstract.preTasks(R66BusinessInterface business,
DbTaskRunner runner)
Runs pre tasks
|
protected void |
HttpSessionAbstract.startTransfer(DbTaskRunner runner)
Set the transfer to be starting
|
Modifier and Type | Field and Description |
---|---|
protected DbTaskRunner |
SendThroughClient.taskRunner |
Modifier and Type | Method and Description |
---|---|
protected DbTaskRunner |
AbstractTransfer.initRequest()
Initiate the Request and return a potential DbTaskRunner
|
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractTransfer.finalizeInErrorTransferRequest(ClientRunner runner,
DbTaskRunner taskRunner,
ErrorCode code)
Shared code for finalize one Transfer request in error
|
protected static void |
AbstractTransfer.prepareSubmitKoOutputFormat(R66Future future,
DbTaskRunner runner,
OutputFormat outputFormat) |
protected static void |
AbstractTransfer.prepareSubmitOkOutputFormat(DbTaskRunner runner,
OutputFormat outputFormat) |
Modifier and Type | Method and Description |
---|---|
DbTaskRunner |
ClientRunner.getTaskRunner() |
Modifier and Type | Method and Description |
---|---|
boolean |
ClientRunner.incrementTaskRunnerTry(DbTaskRunner runner,
int limit) |
void |
InternalRunner.submitTaskRunner(DbTaskRunner taskRunner)
Submit a task
|
Constructor and Description |
---|
ClientRunner(NetworkTransaction networkTransaction,
DbTaskRunner taskRunner,
R66Future futureRequest) |
Modifier and Type | Method and Description |
---|---|
DbTaskRunner |
R66Result.getRunner() |
DbTaskRunner |
R66Session.getRunner() |
Modifier and Type | Method and Description |
---|---|
void |
R66Session.setBadRunner(DbTaskRunner runner,
ErrorCode code)
To be used when a request comes with a bad code so it cannot be set
normally
|
void |
R66Session.setNoSessionRunner(DbTaskRunner runner,
LocalChannelReference localChannelReference)
To be called in case of No Session not from a valid LocalChannelHandler
|
void |
R66Result.setRunner(DbTaskRunner runner) |
void |
R66Session.setRunner(DbTaskRunner runner)
Set the runner, and setup the directory first.
|
Constructor and Description |
---|
R66Result(OpenR66Exception exception,
R66Session session,
boolean isAnswered,
ErrorCode code,
DbTaskRunner runner) |
R66Result(R66Session session,
boolean isAnswered,
ErrorCode code,
DbTaskRunner runner) |
Modifier and Type | Field and Description |
---|---|
protected DbTaskRunner |
RescheduleTransferTask.runner |
Modifier and Type | Method and Description |
---|---|
static DbTaskRunner |
DbTaskRunner.fromStringXml(String xml,
boolean reverse)
Reload a to submitted runner from a remote partner's log (so reversing
isSender should be true)
|
static DbTaskRunner |
DbTaskRunner.getFromStatement(DbPreparedStatement preparedStatement)
For instance from Commander when getting updated information
|
static DbTaskRunner |
DbTaskRunner.getFromStatementNoDbRule(DbPreparedStatement preparedStatement)
For REST interface, to prevent DbRule issue
|
static DbTaskRunner |
DbTaskRunner.getFromStatementNoRule(DbPreparedStatement preparedStatement)
For instance from Commander when getting updated information
This version tries to load DbRule but will not make any error if not found!
|
static DbTaskRunner[] |
DbTaskRunner.getSelectFromInfoPrepareStatement(AbstractDbData.UpdatedInfo info,
boolean orderByStart,
int limit) |
Modifier and Type | Method and Description |
---|---|
void |
DbTaskRunner.setFrom(DbTaskRunner runner)
Partial set from another runner (infostatus, rank, status, step, stop,
filename, globallastep, globalstep,
isFileMoved)
|
Modifier and Type | Method and Description |
---|---|
protected DbTaskRunner |
DbTaskRunnerR66RestMethodHandler.createItem(HttpRestHandler handler,
RestArgument arguments,
RestArgument result,
Object body) |
protected DbTaskRunner |
DbTaskRunnerR66RestMethodHandler.getItem(HttpRestHandler handler,
RestArgument arguments,
RestArgument result,
Object body) |
protected DbTaskRunner |
DbTaskRunnerR66RestMethodHandler.getItemPreparedStatement(DbPreparedStatement statement) |
Modifier and Type | Method and Description |
---|---|
void |
LocalTransaction.setFromId(DbTaskRunner runner,
LocalChannelReference lcr) |
Modifier and Type | Method and Description |
---|---|
void |
TransferRequestJsonPacket.setFromDbTaskRunner(DbTaskRunner runner)
Update the JsonPacket from runner (blocksize, rank, specialid)
|
Modifier and Type | Method and Description |
---|---|
void |
R66PrivateMib.notifyInfoTask(String message,
DbTaskRunner runner)
Send a notification (trap or inform) for Warning/Error event on a single
Transfer Task
|
void |
R66PrivateMib.notifyInternalTask(String message,
DbTaskRunner runner)
Send a notification (trap or inform)
|
void |
R66PrivateMib.notifyTask(String message,
DbTaskRunner runner)
Send a notification (trap or inform) for all events on a single Transfer
Task
|
Modifier and Type | Method and Description |
---|---|
DbTaskRunner |
R66Future.getRunner() |
Modifier and Type | Method and Description |
---|---|
static void |
TransferUtils.cleanOneTransfer(DbTaskRunner taskRunner,
Object map,
R66Session session,
String body)
Method to delete the temporary file
|
static void |
TransferUtils.finalizeTaskWithNoSession(DbTaskRunner taskRunner,
LocalChannelReference localChannelReference)
Finalize a local task since only Post action has to be done
|
static R66Result |
TransferUtils.restartTransfer(DbTaskRunner taskRunner,
LocalChannelReference lcr)
Try to restart one Transfer Runner Task
|
void |
R66Future.setRunner(DbTaskRunner runner) |
Copyright © 2009–2020 Waarp. All rights reserved.