|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use OpenR66ProtocolPacketException | |
---|---|
openr66.client | Classes implementing Clients |
openr66.commander | Classes implementing Commander, reader of database updates from clients |
openr66.database.data | Classes implementing Database Data model |
openr66.protocol.localhandler | Classes implementing LocalHandlers (real work) |
openr66.protocol.localhandler.packet | Classes implementing Packet for Local Handlers |
openr66.protocol.networkhandler.packet | Classes implementing Packet for Network Handler |
openr66.protocol.utils | Classes implementing Utilities |
openr66.server | Classes implementing Server startup main class or utility classes |
Uses of OpenR66ProtocolPacketException in openr66.client |
---|
Methods in openr66.client that throw OpenR66ProtocolPacketException | |
---|---|
org.jboss.netty.channel.ChannelFuture |
SendThroughClient.writeWhenPossible(goldengate.common.file.DataBlock block)
Write the next block when the channel is ready to prevent OOM |
Uses of OpenR66ProtocolPacketException in openr66.commander |
---|
Methods in openr66.commander that throw OpenR66ProtocolPacketException | |
---|---|
LocalChannelReference |
ClientRunner.initRequest()
Initialize the request |
R66Future |
ClientRunner.runTransfer()
True transfer run (can be called directly to enable exception outside any executors) |
R66Future |
ClientRunner.tryAgainTransferOnOverloaded(boolean retry,
LocalChannelReference localChannelReference)
In case an overloaded signal is returned by the requested |
Uses of OpenR66ProtocolPacketException in openr66.database.data |
---|
Methods in openr66.database.data that throw OpenR66ProtocolPacketException | |
---|---|
void |
DbTaskRunner.incrementRank()
Increment the rank of the transfer |
Uses of OpenR66ProtocolPacketException in openr66.protocol.localhandler |
---|
Methods in openr66.protocol.localhandler that throw OpenR66ProtocolPacketException | |
---|---|
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 OpenR66ProtocolPacketException in openr66.protocol.localhandler.packet |
---|
Methods in openr66.protocol.localhandler.packet that throw OpenR66ProtocolPacketException | |
---|---|
void |
ValidPacket.createEnd()
|
void |
TestPacket.createEnd()
|
void |
StartupPacket.createEnd()
|
void |
ShutdownPacket.createEnd()
|
void |
RequestPacket.createEnd()
|
void |
ErrorPacket.createEnd()
|
void |
DataPacket.createEnd()
|
void |
ConnectionErrorPacket.createEnd()
|
void |
BusinessRequestPacket.createEnd()
|
void |
AuthentPacket.createEnd()
|
abstract void |
AbstractLocalPacket.createEnd()
Prepare the End buffer |
static ShutdownPacket |
ShutdownPacket.createFromBuffer(int headerLength,
int middleLength,
int endLength,
org.jboss.netty.buffer.ChannelBuffer buf)
|
static RequestPacket |
RequestPacket.createFromBuffer(int headerLength,
int middleLength,
int endLength,
org.jboss.netty.buffer.ChannelBuffer buf)
|
static NoOpPacket |
NoOpPacket.createFromBuffer(int headerLength,
int middleLength,
int endLength,
org.jboss.netty.buffer.ChannelBuffer buf)
|
static KeepAlivePacket |
KeepAlivePacket.createFromBuffer(int headerLength,
int middleLength,
int endLength,
org.jboss.netty.buffer.ChannelBuffer buf)
|
static InformationPacket |
InformationPacket.createFromBuffer(int headerLength,
int middleLength,
int endLength,
org.jboss.netty.buffer.ChannelBuffer buf)
|
static ErrorPacket |
ErrorPacket.createFromBuffer(int headerLength,
int middleLength,
int endLength,
org.jboss.netty.buffer.ChannelBuffer buf)
|
static EndTransferPacket |
EndTransferPacket.createFromBuffer(int headerLength,
int middleLength,
int endLength,
org.jboss.netty.buffer.ChannelBuffer buf)
|
static EndRequestPacket |
EndRequestPacket.createFromBuffer(int headerLength,
int middleLength,
int endLength,
org.jboss.netty.buffer.ChannelBuffer buf)
|
static DataPacket |
DataPacket.createFromBuffer(int headerLength,
int middleLength,
int endLength,
org.jboss.netty.buffer.ChannelBuffer buf)
|
static ConnectionErrorPacket |
ConnectionErrorPacket.createFromBuffer(int headerLength,
int middleLength,
int endLength,
org.jboss.netty.buffer.ChannelBuffer buf)
|
static BusinessRequestPacket |
BusinessRequestPacket.createFromBuffer(int headerLength,
int middleLength,
int endLength,
org.jboss.netty.buffer.ChannelBuffer buf)
|
static AuthentPacket |
AuthentPacket.createFromBuffer(int headerLength,
int middleLength,
int endLength,
org.jboss.netty.buffer.ChannelBuffer buf)
|
void |
ValidPacket.createHeader()
|
void |
TestPacket.createHeader()
|
void |
StartupPacket.createHeader()
|
void |
ShutdownPacket.createHeader()
|
void |
RequestPacket.createHeader()
|
void |
InformationPacket.createHeader()
|
void |
ErrorPacket.createHeader()
|
void |
DataPacket.createHeader()
|
void |
ConnectionErrorPacket.createHeader()
|
void |
BusinessRequestPacket.createHeader()
|
void |
AuthentPacket.createHeader()
|
abstract void |
AbstractLocalPacket.createHeader()
Prepare the Header buffer |
void |
ValidPacket.createMiddle()
|
void |
TestPacket.createMiddle()
|
void |
StartupPacket.createMiddle()
|
void |
ShutdownPacket.createMiddle()
|
void |
RequestPacket.createMiddle()
|
void |
ErrorPacket.createMiddle()
|
void |
DataPacket.createMiddle()
|
void |
ConnectionErrorPacket.createMiddle()
|
void |
BusinessRequestPacket.createMiddle()
|
void |
AuthentPacket.createMiddle()
|
abstract void |
AbstractLocalPacket.createMiddle()
Prepare the Middle buffer |
static AbstractLocalPacket |
LocalPacketFactory.createPacketFromChannelBuffer(int headerLength,
int middleLength,
int endLength,
org.jboss.netty.buffer.ChannelBuffer buf)
This method create a Packet from the ChannelBuffer. |
static AbstractLocalPacket |
LocalPacketCodec.decodeNetworkPacket(org.jboss.netty.buffer.ChannelBuffer buf)
|
org.jboss.netty.buffer.ChannelBuffer |
AbstractLocalPacket.getLocalPacket()
|
Uses of OpenR66ProtocolPacketException in openr66.protocol.networkhandler.packet |
---|
Constructors in openr66.protocol.networkhandler.packet that throw OpenR66ProtocolPacketException | |
---|---|
NetworkPacket(int localId,
int remoteId,
AbstractLocalPacket packet)
|
Uses of OpenR66ProtocolPacketException in openr66.protocol.utils |
---|
Methods in openr66.protocol.utils that throw OpenR66ProtocolPacketException | |
---|---|
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 |
Uses of OpenR66ProtocolPacketException in openr66.server |
---|
Methods in openr66.server that throw OpenR66ProtocolPacketException | |
---|---|
static void |
ServerShutdown.main(String[] args)
|
static void |
R66Server.main(String[] args)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |