|
||||||||||
| 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 | |||||||||