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.protocol.localhandler |
Classes implementing LocalHandlers (real work)
|
org.waarp.openr66.protocol.localhandler.packet |
Classes implementing Packet for Local Handlers
|
org.waarp.openr66.protocol.localhandler.packet.json | |
org.waarp.openr66.protocol.networkhandler.packet |
Classes implementing Packet for Network Handler
|
org.waarp.openr66.protocol.utils |
Classes implementing Utilities
|
org.waarp.openr66.server |
Classes implementing Server startup main class or utility classes
|
Modifier and Type | Method and Description |
---|---|
io.netty.channel.ChannelFuture |
SendThroughClient.writeWhenPossible(DataBlock block)
Write the next block when the channel is ready to prevent OOM
|
Modifier and Type | Method and Description |
---|---|
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
|
Modifier and Type | Method and Description |
---|---|
void |
ConnectionActions.authent(AuthentPacket packet,
boolean isSsl)
Authentication
|
void |
ServerActions.blockRequest(BlockRequestPacket packet)
Block/Unblock Request
|
R66Future |
ServerActions.businessRequest(boolean isToApplied,
String className,
String arguments,
String extraArguments,
int delay)
Business Request (channel should stay open)
Note: the thread called should manage all writeback informations, as well
as status, channel closing if
needed or not.
|
void |
ServerActions.businessRequest(BusinessRequestPacket packet)
Business Request (channel should stay open)
Note: the thread called should manage all writeback informations, as well
as status, channel closing if
needed or not.
|
void |
TransferActions.data(DataPacket packet)
Receive a data block
|
void |
ServerActions.information(InformationPacket packet)
Receive a request of information
|
ValidPacket |
ServerActions.informationFile(byte request,
String rulename,
String filename,
boolean jsonOutput)
Receive a request of information (Transfer information or File listing)
|
ValidPacket |
ServerActions.informationRequest(long id,
boolean isTo,
String remoteHost,
boolean jsonOutput)
Receive a request of information (Transfer information or File listing)
|
void |
ServerActions.jsonCommand(JsonCommandPacket packet)
Receive a json request
|
void |
TransferActions.request(RequestPacket packet)
Receive a request of Transfer
|
void |
ConnectionActions.startup(StartupPacket packet)
Startup of the session and the local channel reference
|
void |
ServerActions.test(TestPacket packet)
Test reception
|
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 |
---|---|
abstract void |
AbstractLocalPacket.createEnd(LocalChannelReference lcr)
Prepare the End buffer
|
void |
AuthentPacket.createEnd(LocalChannelReference lcr) |
void |
BlockRequestPacket.createEnd(LocalChannelReference lcr) |
void |
BusinessRequestPacket.createEnd(LocalChannelReference lcr) |
void |
ConnectionErrorPacket.createEnd(LocalChannelReference lcr) |
void |
DataPacket.createEnd(LocalChannelReference lcr) |
void |
ErrorPacket.createEnd(LocalChannelReference lcr) |
void |
JsonCommandPacket.createEnd(LocalChannelReference lcr) |
void |
RequestPacket.createEnd(LocalChannelReference lcr) |
void |
ShutdownPacket.createEnd(LocalChannelReference lcr) |
void |
StartupPacket.createEnd(LocalChannelReference lcr) |
void |
TestPacket.createEnd(LocalChannelReference lcr) |
void |
ValidPacket.createEnd(LocalChannelReference lcr) |
static AuthentPacket |
AuthentPacket.createFromBuffer(int headerLength,
int middleLength,
int endLength,
io.netty.buffer.ByteBuf buf) |
static BlockRequestPacket |
BlockRequestPacket.createFromBuffer(int headerLength,
int middleLength,
int endLength,
io.netty.buffer.ByteBuf buf) |
static BusinessRequestPacket |
BusinessRequestPacket.createFromBuffer(int headerLength,
int middleLength,
int endLength,
io.netty.buffer.ByteBuf buf) |
static ConnectionErrorPacket |
ConnectionErrorPacket.createFromBuffer(int headerLength,
int middleLength,
int endLength,
io.netty.buffer.ByteBuf buf) |
static DataPacket |
DataPacket.createFromBuffer(int headerLength,
int middleLength,
int endLength,
io.netty.buffer.ByteBuf buf) |
static EndRequestPacket |
EndRequestPacket.createFromBuffer(int headerLength,
int middleLength,
int endLength,
io.netty.buffer.ByteBuf buf) |
static EndTransferPacket |
EndTransferPacket.createFromBuffer(int headerLength,
int middleLength,
int endLength,
io.netty.buffer.ByteBuf buf) |
static ErrorPacket |
ErrorPacket.createFromBuffer(int headerLength,
int middleLength,
int endLength,
io.netty.buffer.ByteBuf buf) |
static InformationPacket |
InformationPacket.createFromBuffer(int headerLength,
int middleLength,
int endLength,
io.netty.buffer.ByteBuf buf) |
static KeepAlivePacket |
KeepAlivePacket.createFromBuffer(int headerLength,
int middleLength,
int endLength,
io.netty.buffer.ByteBuf buf) |
static NoOpPacket |
NoOpPacket.createFromBuffer(int headerLength,
int middleLength,
int endLength,
io.netty.buffer.ByteBuf buf) |
static RequestPacket |
RequestPacket.createFromBuffer(int headerLength,
int middleLength,
int endLength,
io.netty.buffer.ByteBuf buf) |
static ShutdownPacket |
ShutdownPacket.createFromBuffer(int headerLength,
int middleLength,
int endLength,
io.netty.buffer.ByteBuf buf) |
abstract void |
AbstractLocalPacket.createHeader(LocalChannelReference lcr)
Prepare the Header buffer
|
void |
AuthentPacket.createHeader(LocalChannelReference lcr) |
void |
BlockRequestPacket.createHeader(LocalChannelReference lcr) |
void |
BusinessRequestPacket.createHeader(LocalChannelReference lcr) |
void |
ConnectionErrorPacket.createHeader(LocalChannelReference lcr) |
void |
DataPacket.createHeader(LocalChannelReference lcr) |
void |
ErrorPacket.createHeader(LocalChannelReference lcr) |
void |
InformationPacket.createHeader(LocalChannelReference lcr) |
void |
JsonCommandPacket.createHeader(LocalChannelReference lcr) |
void |
RequestPacket.createHeader(LocalChannelReference lcr) |
void |
ShutdownPacket.createHeader(LocalChannelReference lcr) |
void |
StartupPacket.createHeader(LocalChannelReference lcr) |
void |
TestPacket.createHeader(LocalChannelReference lcr) |
void |
ValidPacket.createHeader(LocalChannelReference lcr) |
abstract void |
AbstractLocalPacket.createMiddle(LocalChannelReference lcr)
Prepare the Middle buffer
|
void |
AuthentPacket.createMiddle(LocalChannelReference lcr) |
void |
BlockRequestPacket.createMiddle(LocalChannelReference lcr) |
void |
BusinessRequestPacket.createMiddle(LocalChannelReference lcr) |
void |
ConnectionErrorPacket.createMiddle(LocalChannelReference lcr) |
void |
DataPacket.createMiddle(LocalChannelReference lcr) |
void |
ErrorPacket.createMiddle(LocalChannelReference lcr) |
void |
JsonCommandPacket.createMiddle(LocalChannelReference lcr) |
void |
RequestPacket.createMiddle(LocalChannelReference lcr) |
void |
ShutdownPacket.createMiddle(LocalChannelReference lcr) |
void |
StartupPacket.createMiddle(LocalChannelReference lcr) |
void |
TestPacket.createMiddle(LocalChannelReference lcr) |
void |
ValidPacket.createMiddle(LocalChannelReference lcr) |
static AbstractLocalPacket |
LocalPacketFactory.createPacketFromByteBuf(int headerLength,
int middleLength,
int endLength,
io.netty.buffer.ByteBuf buf)
This method create a Packet from the ByteBuf.
|
static AbstractLocalPacket |
LocalPacketCodec.decodeNetworkPacket(io.netty.buffer.ByteBuf buf) |
io.netty.buffer.ByteBuf |
AbstractLocalPacket.getLocalPacket(LocalChannelReference lcr) |
Modifier and Type | Method and Description |
---|---|
com.fasterxml.jackson.databind.node.ObjectNode |
JsonPacket.createObjectNode() |
Constructor and Description |
---|
NetworkPacket(int localId,
int remoteId,
AbstractLocalPacket packet,
LocalChannelReference lcr) |
Modifier and Type | Method and Description |
---|---|
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
|
Modifier and Type | Method and Description |
---|---|
static void |
ServerShutdown.main(String[] args) |
static void |
R66Server.main(String[] args) |
Copyright © 2009–2020 Waarp. All rights reserved.