|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use LocalChannelReference | |
---|---|
openr66.client | Classes implementing Clients |
openr66.commander | Classes implementing Commander, reader of database updates from clients |
openr66.context | Classes implementing Session, Result and ErrorCode |
openr66.database.data | Classes implementing Database Data model |
openr66.protocol.localhandler | Classes implementing LocalHandlers (real work) |
openr66.protocol.networkhandler | Classes implementing Network Handler (multiplexing local handlers) |
openr66.protocol.utils | Classes implementing Utilities |
Uses of LocalChannelReference in openr66.client |
---|
Fields in openr66.client declared as LocalChannelReference | |
---|---|
protected LocalChannelReference |
SendThroughClient.localChannelReference
|
protected LocalChannelReference |
RecvThroughClient.localChannelReference
|
Uses of LocalChannelReference in openr66.commander |
---|
Methods in openr66.commander that return LocalChannelReference | |
---|---|
LocalChannelReference |
ClientRunner.getLocalChannelReference()
|
LocalChannelReference |
ClientRunner.initRequest()
Initialize the request |
Methods in openr66.commander with parameters of type LocalChannelReference | |
---|---|
R66Future |
ClientRunner.finishTransfer(boolean retry,
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 |
Uses of LocalChannelReference in openr66.context |
---|
Methods in openr66.context that return LocalChannelReference | |
---|---|
LocalChannelReference |
R66Session.getLocalChannelReference()
|
Methods in openr66.context with parameters of type LocalChannelReference | |
---|---|
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 |
Uses of LocalChannelReference in openr66.database.data |
---|
Methods in openr66.database.data that return LocalChannelReference | |
---|---|
LocalChannelReference |
DbTaskRunner.getLocalChannelReference()
|
Methods in openr66.database.data with parameters of type LocalChannelReference | |
---|---|
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.setErrorTask(LocalChannelReference localChannelReference)
Set the Error Task step |
void |
DbTaskRunner.setLocalChannelReference(LocalChannelReference localChannelReference)
Set a localChannelReference |
Uses of LocalChannelReference in openr66.protocol.localhandler |
---|
Methods in openr66.protocol.localhandler that return LocalChannelReference | |
---|---|
LocalChannelReference |
LocalTransaction.createNewClient(org.jboss.netty.channel.Channel networkChannel,
Integer remoteId,
R66Future futureRequest)
Create a new Client |
LocalChannelReference |
LocalTransaction.getClient(Integer remoteId,
Integer localId)
Get the corresponding LocalChannelReference |
LocalChannelReference |
LocalTransaction.getFromId(Integer id)
|
LocalChannelReference |
LocalTransaction.getFromRequest(String key)
|
Methods in openr66.protocol.localhandler with parameters of type LocalChannelReference | |
---|---|
void |
LocalTransaction.setFromId(DbTaskRunner runner,
LocalChannelReference lcr)
|
static org.jboss.netty.channel.ChannelFuture |
RetrieveRunner.writeWhenPossible(goldengate.common.file.DataBlock block,
LocalChannelReference localChannelReference)
Write the next block when the channel is ready to prevent OOM |
Uses of LocalChannelReference in openr66.protocol.networkhandler |
---|
Methods in openr66.protocol.networkhandler that return LocalChannelReference | |
---|---|
LocalChannelReference |
NetworkTransaction.createConnection(SocketAddress socketAddress,
boolean isSSL,
R66Future futureRequest)
Create a connection to the specified socketAddress |
static LocalChannelReference |
NetworkTransaction.createConnectionFromNetworkChannelStartup(org.jboss.netty.channel.Channel channel,
NetworkPacket packet)
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 |
Methods in openr66.protocol.networkhandler with parameters of type LocalChannelReference | |
---|---|
static void |
NetworkTransaction.normalEndRetrieve(LocalChannelReference localChannelReference)
Normal end of a Retrieve Operation |
static void |
NetworkTransaction.stopRetrieve(LocalChannelReference localChannelReference)
Stop a retrieve operation |
Uses of LocalChannelReference in openr66.protocol.utils |
---|
Methods in openr66.protocol.utils with parameters of type LocalChannelReference | |
---|---|
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 long |
ChannelUtils.willBeWaitingWriting(LocalChannelReference localChannelReference,
int size)
Compute Wait for Traffic in Write (ugly turn around) |
static org.jboss.netty.channel.ChannelFuture |
ChannelUtils.writeAbstractLocalPacket(LocalChannelReference localChannelReference,
AbstractLocalPacket packet,
boolean wait)
Write an AbstractLocalPacket to the network Channel |
static org.jboss.netty.channel.ChannelFuture |
ChannelUtils.writeAbstractLocalPacketToLocal(LocalChannelReference localChannelReference,
AbstractLocalPacket packet)
Write an AbstractLocalPacket to the Local Channel |
static org.jboss.netty.channel.ChannelFuture |
ChannelUtils.writeBackDataBlock(LocalChannelReference localChannelReference,
goldengate.common.file.DataBlock block)
|
static void |
ChannelUtils.writeEndTransfer(LocalChannelReference localChannelReference)
Write the EndTransfer |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |