|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Packet | |
org.activeio | The core activeio API is centered around having Channels that move Packets of data. |
org.activeio.adapter | The Adapter package provides classes that make it easy ot bridge between the the SynchChannel, AsyncChannel, InputStream, OutputStream, Socket, and ServerSocket domains. |
org.activeio.command | An API and helper classes for working with Command objects; which are application level objects along with a WireFormat to reader/write directly with the media allowing higher layers to work directly with command objects and WireFormat instances instead of turning things into Packets and byte arrays etc. |
org.activeio.filter | Some simple filters that may be added to your channels. |
org.activeio.journal | Provides the API for storing and accessing record based binary data in sequential log files. |
org.activeio.journal.active | The Active Journal is a high performance Journal implemenation which does not place limits on how big the data being logged can be. |
org.activeio.journal.howl | A Journal implemenation using using a high performance transaction log implemented using Howl |
org.activeio.net | A set of Channel implementations that are implemented using the Socket and DatagramSocket classes. |
org.activeio.oneport | This package provides the implementing classes that allow you to run multiple protocols from a sigle port. |
org.activeio.packet | Implementations of the Packet class. |
Uses of Packet in org.activeio |
Methods in org.activeio that return Packet | |
Packet |
Packet.slice()
|
Packet |
Packet.duplicate()
|
Packet |
InputSyncChannel.read(long timeout)
Used to synchronously receive a packet of information going 'up' the channel. |
Packet |
FilterSyncChannel.read(long timeout)
|
Packet |
RequestChannel.request(Packet request,
long timeout)
Used to send a packet of information going 'down' the channel and wait for it's reponse 'up' packet. |
Packet |
RequestListener.onRequest(Packet request)
A RequestChannel will call this method when a new request arrives. |
Methods in org.activeio with parameters of type Packet | |
void |
OutputChannel.write(Packet packet)
Sends a packet down the channel towards the media. |
void |
AsyncChannelListener.onPacket(Packet packet)
A AsyncChannel will call this method to deliver an 'up' packet to a consumer. |
int |
Packet.read(Packet dest)
|
void |
FilterAsyncChannel.write(Packet packet)
|
void |
FilterAsyncChannel.onPacket(Packet packet)
|
void |
FilterSyncChannel.write(Packet packet)
|
Packet |
RequestChannel.request(Packet request,
long timeout)
Used to send a packet of information going 'down' the channel and wait for it's reponse 'up' packet. |
Packet |
RequestListener.onRequest(Packet request)
A RequestChannel will call this method when a new request arrives. |
Constructors in org.activeio with parameters of type Packet | |
PacketData(Packet packet)
|
|
PacketData(Packet packet,
boolean bigEndian)
|
Uses of Packet in org.activeio.adapter |
Methods in org.activeio.adapter that return Packet | |
Packet |
AsyncChannelToClientRequestChannel.request(Packet request,
long timeout)
|
Packet |
AsyncChannelToConcurrentRequestChannel.request(Packet request,
long timeout)
|
Packet |
AsyncChannelToServerRequestChannel.request(Packet request,
long timeout)
|
Packet |
AsyncToSyncChannel.read(long timeout)
|
protected Packet |
PacketByteArrayOutputStream.allocate()
|
Packet |
PacketByteArrayOutputStream.getPacket()
|
Methods in org.activeio.adapter with parameters of type Packet | |
Packet |
AsyncChannelToClientRequestChannel.request(Packet request,
long timeout)
|
void |
AsyncChannelToConcurrentRequestChannel.write(Packet packet)
|
void |
AsyncChannelToConcurrentRequestChannel.onPacket(Packet packet)
|
Packet |
AsyncChannelToConcurrentRequestChannel.request(Packet request,
long timeout)
|
Packet |
AsyncChannelToServerRequestChannel.request(Packet request,
long timeout)
|
void |
AsyncChannelToServerRequestChannel.onPacket(Packet packet)
|
void |
AsyncToSyncChannel.write(Packet packet)
|
void |
AsyncToSyncChannel.onPacket(Packet packet)
|
void |
SyncToAsyncChannel.write(Packet packet)
|
Constructors in org.activeio.adapter with parameters of type Packet | |
PacketInputStream(Packet packet)
Deprecated. |
|
PacketToInputStream(Packet packet)
|
|
PacketOutputStream(Packet packet)
|
Uses of Packet in org.activeio.command |
Methods in org.activeio.command that return Packet | |
Packet |
WireFormat.marshal(Object command)
Packet based marshaling |
Packet |
DefaultWireFormat.marshal(Object command)
|
Methods in org.activeio.command with parameters of type Packet | |
Object |
WireFormat.unmarshal(Packet packet)
Packet based un-marshaling |
Object |
DefaultWireFormat.unmarshal(Packet packet)
|
Uses of Packet in org.activeio.filter |
Methods in org.activeio.filter that return Packet | |
Packet |
PacketAggregator.getHeader(Packet packet)
|
Packet |
PacketAggregatingSyncChannel.read(long timeout)
|
Packet |
PushbackSyncChannel.read(long timeout)
|
Packet |
SynchornizedSyncChannel.read(long timeout)
|
Methods in org.activeio.filter with parameters of type Packet | |
void |
AsyncWriteAsyncChannel.write(Packet packet)
|
void |
CounterAsyncChannel.onPacket(Packet packet)
|
void |
CounterAsyncChannel.write(Packet packet)
|
void |
PacketAggregatingAsyncChannel.onPacket(Packet packet)
|
void |
PacketAggregatingAsyncChannel.write(Packet packet)
|
void |
PacketAggregator.addRawPacket(Packet packet)
|
protected abstract void |
PacketAggregator.packetAssembled(Packet packet)
|
Packet |
PacketAggregator.getHeader(Packet packet)
|
void |
PacketAggregatingSyncChannel.write(Packet packet)
|
void |
PushbackSyncChannel.putback(Packet packet)
|
void |
SynchornizedAsyncChannel.write(Packet packet)
|
void |
SynchornizedSyncChannel.write(Packet packet)
|
void |
WriteBufferedAsyncChannel.write(Packet packet)
|
void |
WriteBufferedSyncChannel.write(Packet packet)
|
Constructors in org.activeio.filter with parameters of type Packet | |
PushbackSyncChannel(SyncChannel next,
Packet putback)
|
|
WriteBufferedAsyncChannel(AsyncChannel channel,
Packet buffer)
|
|
WriteBufferedAsyncChannel(AsyncChannel channel,
Packet buffer,
boolean enableDirectWrites)
|
|
WriteBufferedSyncChannel(SyncChannel channel,
Packet buffer)
|
|
WriteBufferedSyncChannel(SyncChannel channel,
Packet buffer,
boolean enableDirectWrites)
|
Uses of Packet in org.activeio.journal |
Methods in org.activeio.journal that return Packet | |
Packet |
Journal.read(RecordLocation location)
Reads a previously written record from the journal. |
Methods in org.activeio.journal with parameters of type Packet | |
RecordLocation |
Journal.write(Packet packet,
boolean sync)
Writes a Packet of data to the journal. |
Uses of Packet in org.activeio.journal.active |
Methods in org.activeio.journal.active that return Packet | |
Packet |
BatchedWrite.getPacket()
|
Packet |
Record.getPayload()
|
Packet |
ControlFile.getControlData()
|
Packet |
JournalImpl.read(RecordLocation l)
|
Packet |
LogFileManager.readPacket(Location location)
|
Methods in org.activeio.journal.active with parameters of type Packet | |
void |
Location.writeToPacket(Packet packet)
|
static Location |
Location.readFromPacket(Packet packet)
|
boolean |
Record.readFromPacket(Packet packet)
|
void |
Record.read(Packet packet)
|
RecordLocation |
JournalImpl.write(Packet data,
boolean sync)
|
Constructors in org.activeio.journal.active with parameters of type Packet | |
BatchedWrite(Packet packet)
|
|
Record(byte recordType,
Packet payload,
Location mark)
|
|
Record(Location location,
byte recordType,
Packet payload,
Location mark)
|
Uses of Packet in org.activeio.journal.howl |
Methods in org.activeio.journal.howl that return Packet | |
Packet |
HowlJournal.read(RecordLocation location)
|
Methods in org.activeio.journal.howl with parameters of type Packet | |
RecordLocation |
HowlJournal.write(Packet packet,
boolean sync)
|
Uses of Packet in org.activeio.net |
Methods in org.activeio.net that return Packet | |
Packet |
DatagramSocketSyncChannel.read(long timeout)
|
Packet |
NIOSyncChannel.read(long timeout)
|
Packet |
SocketSyncChannel.read(long timeout)
|
Methods in org.activeio.net with parameters of type Packet | |
void |
DatagramSocketSyncChannel.write(Packet packet)
|
void |
NIOAsyncChannel.write(Packet packet)
|
void |
NIOSyncChannel.write(Packet packet)
|
void |
SocketSyncChannel.write(Packet packet)
|
void |
VMPipeAsyncChannelFactory.ClassloaderAsyncChannelAdapter.write(Packet packet)
|
void |
VMPipeAsyncChannelPipe.PipeChannel.write(Packet packet)
|
Uses of Packet in org.activeio.oneport |
Methods in org.activeio.oneport with parameters of type Packet | |
boolean |
HttpRecognizer.recognizes(Packet packet)
|
boolean |
ProtocolRecognizer.recognizes(Packet packet)
|
boolean |
IIOPRecognizer.recognizes(Packet packet)
|
Uses of Packet in org.activeio.packet |
Classes in org.activeio.packet that implement Packet | |
class |
AppendedPacket
Appends two packets together. |
class |
ByteArrayPacket
Provides a Packet implementation that is directly backed by a byte[] . |
class |
ByteBufferPacket
Provides a Packet implementation that is backed by a ByteBuffer |
class |
BytePacket
Provides a Packet implementation that is directly backed by a byte . |
class |
EmptyPacket
Provides a Packet implementation that is directly backed by a byte[0] . |
class |
EOSPacket
Provides a Packet implementation that is used to represent the end of a stream. |
class |
FilterPacket
Provides a Packet implementation that filters operations to another packet. |
class |
PacketPool.PooledPacket
|
Fields in org.activeio.packet declared as Packet | |
protected Packet |
FilterPacket.next
|
Methods in org.activeio.packet that return Packet | |
Packet |
ByteArrayPacket.slice()
|
Packet |
ByteArrayPacket.duplicate()
|
Packet |
ByteBufferPacket.compact()
|
Packet |
ByteBufferPacket.mark()
|
Packet |
ByteBufferPacket.slice()
|
Packet |
ByteBufferPacket.duplicate()
|
protected Packet |
ByteBufferPacketPool.allocateNewPacket()
|
Packet |
PacketPool.PooledPacket.filter(Packet packet)
|
Packet |
PacketPool.getPacket()
Blocks until a ByteBuffer can be retreived from the pool. |
protected abstract Packet |
PacketPool.allocateNewPacket()
|
Packet |
FilterPacket.duplicate()
|
Packet |
FilterPacket.slice()
|
abstract Packet |
FilterPacket.filter(Packet packet)
|
static Packet |
AppendedPacket.join(Packet first,
Packet last)
|
Packet |
AppendedPacket.slice()
|
Packet |
AppendedPacket.duplicate()
|
Packet |
BytePacket.slice()
|
Packet |
BytePacket.duplicate()
|
Packet |
EOSPacket.slice()
|
Packet |
EOSPacket.duplicate()
|
Packet |
EmptyPacket.slice()
|
Packet |
EmptyPacket.duplicate()
|
Methods in org.activeio.packet with parameters of type Packet | |
int |
ByteArrayPacket.read(Packet dest)
|
int |
ByteBufferPacket.read(Packet dest)
|
Packet |
PacketPool.PooledPacket.filter(Packet packet)
|
int |
FilterPacket.read(Packet dest)
|
abstract Packet |
FilterPacket.filter(Packet packet)
|
static Packet |
AppendedPacket.join(Packet first,
Packet last)
|
int |
AppendedPacket.read(Packet dest)
|
int |
BytePacket.read(Packet dest)
|
int |
EOSPacket.read(Packet dest)
|
int |
EmptyPacket.read(Packet dest)
|
Constructors in org.activeio.packet with parameters of type Packet | |
PacketPool.PooledPacket(Packet next)
|
|
FilterPacket(Packet next)
|
|
AppendedPacket(Packet first,
Packet second)
Deprecated. use AppendedPacket.join(Packet, Packet) instead. |
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |