Uses of Class
openr66.protocol.localhandler.LocalChannelReference

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
 



Copyright © 2009-2012 Frederic Bregier. All Rights Reserved.