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 |
Classes implementing Session, Result and ErrorCode
|
org.waarp.openr66.database.data |
Classes implementing Database Data model
|
org.waarp.openr66.protocol.localhandler |
Classes implementing LocalHandlers (real work)
|
org.waarp.openr66.protocol.localhandler.packet |
Classes implementing Packet for Local Handlers
|
org.waarp.openr66.protocol.networkhandler |
Classes implementing Network Handler (multiplexing local handlers)
|
org.waarp.openr66.protocol.networkhandler.packet |
Classes implementing Packet for Network Handler
|
org.waarp.openr66.protocol.utils |
Classes implementing Utilities
|
Modifier and Type | Field and Description |
---|---|
protected LocalChannelReference |
RecvThroughClient.localChannelReference |
protected LocalChannelReference |
SendThroughClient.localChannelReference |
Modifier and Type | Method and Description |
---|---|
static LocalChannelReference |
AbstractTransfer.tryConnect(DbHostAuth host,
R66Future future,
NetworkTransaction networkTransaction)
Helper to connect
|
Modifier and Type | Method and Description |
---|---|
static boolean |
AbstractTransfer.sendValidPacket(DbHostAuth host,
LocalChannelReference localChannelReference,
AbstractLocalPacket packet,
R66Future future) |
Modifier and Type | Method and Description |
---|---|
LocalChannelReference |
ClientRunner.getLocalChannelReference() |
LocalChannelReference |
ClientRunner.initRequest()
Initialize the request
|
Modifier and Type | Method and Description |
---|---|
R66Future |
ClientRunner.finishTransfer(LocalChannelReference localChannelReference)
Finish the transfer (called at the end of runTransfer)
|
R66Future |
ClientRunner.tryAgainTransferOnOverloaded(boolean retry,
LocalChannelReference localChannelReference)
In case an overloaded signal is returned by the requested
|
Modifier and Type | Method and Description |
---|---|
LocalChannelReference |
R66Session.getLocalChannelReference() |
Modifier and Type | Method and Description |
---|---|
void |
R66Session.setLocalChannelReference(LocalChannelReference localChannelReference) |
void |
R66Session.setNoSessionRunner(DbTaskRunner runner,
LocalChannelReference localChannelReference)
To be called in case of No Session not from a valid LocalChannelHandler
|
Modifier and Type | Method and Description |
---|---|
LocalChannelReference |
DbTaskRunner.getLocalChannelReference() |
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.
|
void |
DbTaskRunner.setLocalChannelReference(LocalChannelReference localChannelReference)
Set a localChannelReference
|
Modifier and Type | Field and Description |
---|---|
protected LocalChannelReference |
ConnectionActions.localChannelReference
Local Channel Reference
|
Modifier and Type | Method and Description |
---|---|
LocalChannelReference |
LocalTransaction.createNewClient(NetworkChannelReference networkChannelReference,
Integer remoteId,
R66Future futureRequest,
boolean fromSsl)
Create a new Client
|
LocalChannelReference |
LocalTransaction.getClient(Integer remoteId,
Integer localId)
Get the corresponding LocalChannelReference and set the remoteId if
different
|
LocalChannelReference |
LocalTransaction.getFromId(Integer id) |
LocalChannelReference |
LocalTransaction.getFromRequest(String key) |
LocalChannelReference |
ConnectionActions.getLocalChannelReference() |
Modifier and Type | Method and Description |
---|---|
static void |
LocalServerHandler.channelRead0(LocalChannelReference localChannelReference,
AbstractLocalPacket msg) |
static void |
LocalServerHandler.channelRead0(LocalChannelReference localChannelReference,
NetworkPacket networkPacket)
Replacement for local channels
|
static void |
LocalServerHandler.channelRead1(LocalChannelReference localChannelReference,
AbstractLocalPacket packet) |
protected void |
LocalTransaction.remove(LocalChannelReference localChannelReference)
Remove one local channel
|
void |
LocalTransaction.setFromId(DbTaskRunner runner,
LocalChannelReference lcr) |
protected void |
ConnectionActions.setLocalChannelReference(LocalChannelReference localChannelReference) |
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 LocalChannelReference |
NetworkTransaction.createConnectionFromNetworkChannelStartup(NetworkChannelReference networkChannelReference,
NetworkPacket startupPacket,
boolean fromSsl)
Create the LocalChannelReference when a remote local channel starts its
connection
|
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 | Method and Description |
---|---|
void |
NetworkChannelReference.add(LocalChannelReference localChannel) |
static int |
NetworkTransaction.checkClosingNetworkChannel(NetworkChannelReference networkChannelReference,
LocalChannelReference localChannelReference)
Check if closing of the localChannel will bring future closing of
NetworkChannel
|
void |
NetworkChannelReference.closeAndRemove(LocalChannelReference localChannel)
Remove one LocalChanelReference, closing it if necessary.
|
static void |
NetworkTransaction.normalEndRetrieve(LocalChannelReference localChannelReference)
Normal end of a Retrieve Operation
|
void |
NetworkChannelReference.remove(LocalChannelReference localChannel)
Remove one LocalChanelReference
|
static void |
NetworkTransaction.stopRetrieve(LocalChannelReference localChannelReference)
Stop a retrieve operation
|
Constructor and Description |
---|
NetworkPacket(int localId,
int remoteId,
AbstractLocalPacket packet,
LocalChannelReference lcr) |
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 R66Result |
TransferUtils.restartTransfer(DbTaskRunner taskRunner,
LocalChannelReference lcr)
Try to restart one Transfer Runner Task
|
static io.netty.channel.ChannelFuture |
ChannelUtils.writeAbstractLocalPacket(LocalChannelReference localChannelReference,
AbstractLocalPacket packet,
boolean wait)
Write an AbstractLocalPacket to the network Channel
|
static io.netty.channel.ChannelFuture |
ChannelUtils.writeBackDataBlock(LocalChannelReference localChannelReference,
DataBlock block) |
static void |
ChannelUtils.writeEndTransfer(LocalChannelReference localChannelReference)
Write the EndTransfer
|
static void |
ChannelUtils.writeEndTransfer(LocalChannelReference localChannelReference,
String hash)
Write the EndTransfer plus Global Hash
|
Copyright © 2009–2020 Waarp. All rights reserved.