Package | Description |
---|---|
org.waarp.openr66.client |
Classes implementing Clients
|
org.waarp.openr66.configuration |
Classes implementing Configuration loading from database or files
|
org.waarp.openr66.context |
Classes implementing Session, Result and ErrorCode
|
org.waarp.openr66.context.filesystem |
Classes implementing Filesystem
|
org.waarp.openr66.database.data |
Classes implementing Database Data model
|
org.waarp.openr66.protocol.localhandler |
Classes implementing LocalHandlers (real work)
|
org.waarp.openr66.proxy.network |
Network Package for Proxy R66
|
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 |
---|---|
static DbRule |
RuleFileBasedConfiguration.getFromFile(File file)
Load and update a Rule from a file
|
static List<DbRule> |
RuleFileBasedConfiguration.getMultipleFromFile(File file)
Load and update multiple Rules from one file
|
static void |
RuleFileBasedConfiguration.importRules(File configDirectory)
Import all Rule files into the HashTable of Rules
|
static String |
RuleFileBasedConfiguration.writeOneXml(String directory,
String hostname)
Write to directory 1 file prefixed by hostname all Rules from database
|
static void |
AuthenticationFileBasedConfiguration.writeXML(Configuration config,
String filename)
Write all authentication to a file with filename
|
static void |
RuleFileBasedConfiguration.writeXml(String directory,
String hostname)
Write to directory files prefixed by hostname all Rules from database
|
Modifier and Type | Method and Description |
---|---|
void |
R66Session.setFinalizeTransfer(boolean status,
R66Result finalValue)
Finalize the transfer step by running the error or post operation
according
to the status.
|
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 |
---|---|
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.
|
String |
DbRule.setArchivePath(String filename)
Get the full path from archivePath
|
String |
DbRule.setRecvPath(String filename)
Get the full path from RecvPath (used only in copy MODETRANS)
|
String |
DbRule.setSendPath(String filename)
Get the full path from sendPath
|
String |
DbRule.setWorkingPath(String filename)
Get the full path from workPath
|
Modifier and Type | Method and Description |
---|---|
ConfigImportResponseJsonPacket |
ServerActions.configImport(ConfigImportJsonPacket json)
Import configuration from files as parameter
|
LocalChannelReference |
LocalTransaction.createNewClient(NetworkChannelReference networkChannelReference,
Integer remoteId,
R66Future futureRequest,
boolean fromSsl)
Create a new Client
|
void |
TransferActions.endTransfer(EndTransferPacket packet)
Receive an End of Transfer
|
void |
ConnectionActions.errorMesg(ErrorPacket packet)
Receive a remote error
|
LocalChannelReference |
LocalTransaction.getClient(Integer remoteId,
Integer localId)
Get the corresponding LocalChannelReference and set the remoteId if
different
|
void |
ServerActions.jsonCommand(JsonCommandPacket packet)
Receive a json request
|
void |
TransferActions.request(RequestPacket packet)
Receive a request of Transfer
|
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 |
ProxyEntry.add(SocketAddress localAddress,
boolean localIsSsl,
SocketAddress remoteAddress,
boolean remoteIsSsl) |
Copyright © 2009–2020 Waarp. All rights reserved.