|
|||||||||||
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.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 |
FilterSynchChannel.read(long timeout)
|
Packet |
InputSynchChannel.read(long timeout)
Used to synchonously receive a packet of information going 'up' the channel. |
Packet |
Packet.slice()
|
Packet |
Packet.duplicate()
|
Packet |
RequestListener.onRequest(Packet request)
A RequestChannel will call this method when a new request arrives. |
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. |
Methods in org.activeio with parameters of type Packet | |
void |
FilterSynchChannel.write(Packet packet)
|
void |
FilterAsynchChannel.write(Packet packet)
|
void |
FilterAsynchChannel.onPacket(Packet packet)
|
int |
Packet.read(Packet dest)
|
Packet |
RequestListener.onRequest(Packet request)
A RequestChannel will call this method when a new request arrives. |
void |
OutputChannel.write(Packet packet)
Sends a packet down the channel towards the media. |
void |
AsynchChannelListener.onPacket(Packet packet)
A AsynchChannel will call this method to deliver an 'up' packet to a consumer. |
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. |
Constructors in org.activeio with parameters of type Packet | |
PacketData(Packet packet)
|
|
PacketData(Packet packet,
boolean bigEndian)
|
Uses of Packet in org.activeio.adapter |
Fields in org.activeio.adapter declared as Packet | |
(package private) Packet |
PacketOutputStream.packet
|
(package private) Packet |
PacketInputStream.packet
|
Methods in org.activeio.adapter that return Packet | |
Packet |
AsynchToSynchChannelAdapter.read(long timeout)
|
protected Packet |
PacketByteArrayOutputStream.allocate()
|
Packet |
PacketByteArrayOutputStream.getPacket()
|
Packet |
AsynchChannelToClientRequestChannel.request(Packet request,
long timeout)
|
Packet |
AsynchChannelToConcurrentRequestChannel.request(Packet request,
long timeout)
|
Packet |
AsynchChannelToServerRequestChannel.request(Packet request,
long timeout)
|
Methods in org.activeio.adapter with parameters of type Packet | |
void |
SynchToAsynchChannelAdapter.write(Packet packet)
|
void |
AsynchToSynchChannelAdapter.write(Packet packet)
|
void |
AsynchToSynchChannelAdapter.onPacket(Packet packet)
|
Packet |
AsynchChannelToClientRequestChannel.request(Packet request,
long timeout)
|
void |
AsynchChannelToConcurrentRequestChannel.write(Packet packet)
|
void |
AsynchChannelToConcurrentRequestChannel.onPacket(Packet packet)
|
Packet |
AsynchChannelToConcurrentRequestChannel.request(Packet request,
long timeout)
|
void |
AsynchWriteAsynchChannelAdapter.write(Packet packet)
|
Packet |
AsynchChannelToServerRequestChannel.request(Packet request,
long timeout)
|
void |
AsynchChannelToServerRequestChannel.onPacket(Packet packet)
|
Constructors in org.activeio.adapter with parameters of type Packet | |
PacketOutputStream(Packet packet)
|
|
PacketInputStream(Packet packet)
|
Uses of Packet in org.activeio.filter |
Fields in org.activeio.filter declared as Packet | |
(package private) Packet |
PacketAggregator.incompleteUpPacket
|
Methods in org.activeio.filter that return Packet | |
Packet |
PushbackSynchChannel.read(long timeout)
|
Packet |
SynchornizedSynchChannel.read(long timeout)
|
Packet |
PacketAggregator.getHeader(Packet packet)
|
Packet |
PacketAggregatingSynchChannel.read(long timeout)
|
Methods in org.activeio.filter with parameters of type Packet | |
void |
SynchornizedAsynchChannel.write(Packet packet)
|
void |
PushbackSynchChannel.putback(Packet packet)
|
void |
SynchornizedSynchChannel.write(Packet packet)
|
void |
WriteBufferedAsynchChannel.write(Packet packet)
|
void |
WriteBufferedSynchChannel.write(Packet packet)
|
void |
PacketAggregatingAsynchChannel.onPacket(Packet packet)
|
void |
PacketAggregatingAsynchChannel.write(Packet packet)
|
void |
CounterAsyncChannel.onPacket(Packet packet)
|
void |
CounterAsyncChannel.write(Packet packet)
|
void |
PacketAggregator.addRawPacket(Packet packet)
|
protected abstract void |
PacketAggregator.packetAssembled(Packet packet)
|
Packet |
PacketAggregator.getHeader(Packet packet)
|
void |
PacketAggregatingSynchChannel.write(Packet packet)
|
Constructors in org.activeio.filter with parameters of type Packet | |
PushbackSynchChannel(SynchChannel next,
Packet putback)
|
|
WriteBufferedAsynchChannel(AsynchChannel channel,
Packet buffer)
|
|
WriteBufferedAsynchChannel(AsynchChannel channel,
Packet buffer,
boolean enableDirectWrites)
|
|
WriteBufferedSynchChannel(SynchChannel channel,
Packet buffer)
|
|
WriteBufferedSynchChannel(SynchChannel 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 |
JournalImpl.read(RecordLocation l)
|
Packet |
LogFileManager.readPacket(Location location)
|
Packet |
ControlFile.getControlData()
|
Packet |
Record.getPayload()
|
Packet |
BatchedWrite.getPacket()
|
Methods in org.activeio.journal.active with parameters of type Packet | |
RecordLocation |
JournalImpl.write(Packet data,
boolean sync)
|
boolean |
Record.readFromPacket(Packet packet)
|
void |
Record.read(Packet packet)
|
void |
Location.writeToPacket(Packet packet)
|
static Location |
Location.readFromPacket(Packet packet)
|
Constructors in org.activeio.journal.active with parameters of type Packet | |
Record(byte recordType,
Packet payload,
Location mark)
|
|
Record(Location location,
byte recordType,
Packet payload,
Location mark)
|
|
BatchedWrite(Packet packet)
|
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 |
DatagramSocketSynchChannel.read(long timeout)
|
Packet |
SocketSynchChannel.read(long timeout)
|
Packet |
NIOSynchChannel.read(long timeout)
|
Methods in org.activeio.net with parameters of type Packet | |
void |
VMPipeAsynchChannelFactory.ClassloaderAsynchChannelAdapter.write(Packet packet)
|
void |
DatagramSocketSynchChannel.write(Packet packet)
|
void |
SocketSynchChannel.write(Packet packet)
|
void |
NIOAsynchChannel.write(Packet packet)
|
void |
NIOSynchChannel.write(Packet packet)
|
void |
VMPipeAsynchChannelPipe.PipeChannel.write(Packet packet)
|
void |
AIOAsynchChannel.write(Packet packet)
|
Uses of Packet in org.activeio.oneport |
Methods in org.activeio.oneport with parameters of type Packet | |
boolean |
IIOPRecognizer.recognizes(Packet packet)
|
boolean |
HttpRecognizer.recognizes(Packet packet)
|
boolean |
UnknownRecognizer.recognizes(Packet packet)
|
boolean |
ProtocolRecognizer.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 |
EOSPacket.slice()
|
Packet |
EOSPacket.duplicate()
|
Packet |
BytePacket.slice()
|
Packet |
BytePacket.duplicate()
|
static Packet |
AppendedPacket.join(Packet first,
Packet last)
|
Packet |
AppendedPacket.slice()
|
Packet |
AppendedPacket.duplicate()
|
Packet |
EmptyPacket.slice()
|
Packet |
EmptyPacket.duplicate()
|
Packet |
ByteBufferPacket.compact()
|
Packet |
ByteBufferPacket.mark()
|
Packet |
ByteBufferPacket.slice()
|
Packet |
ByteBufferPacket.duplicate()
|
Packet |
PacketPool.getPacket()
Blocks until a ByteBuffer can be retreived from the pool. |
protected abstract Packet |
PacketPool.allocateNewPacket()
|
Packet |
PacketPool.PooledPacket.filter(Packet packet)
|
protected Packet |
ByteBufferPacketPool.allocateNewPacket()
|
Packet |
FilterPacket.duplicate()
|
Packet |
FilterPacket.slice()
|
abstract Packet |
FilterPacket.filter(Packet packet)
|
Packet |
ByteArrayPacket.slice()
|
Packet |
ByteArrayPacket.duplicate()
|
Methods in org.activeio.packet with parameters of type Packet | |
int |
EOSPacket.read(Packet dest)
|
int |
BytePacket.read(Packet dest)
|
static Packet |
AppendedPacket.join(Packet first,
Packet last)
|
int |
AppendedPacket.read(Packet dest)
|
int |
EmptyPacket.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)
|
int |
ByteArrayPacket.read(Packet dest)
|
Constructors in org.activeio.packet with parameters of type Packet | |
AppendedPacket(Packet first,
Packet second)
Deprecated. use AppendedPacket.join(Packet, Packet) instead. |
|
PacketPool.PooledPacket(Packet next)
|
|
FilterPacket(Packet next)
|
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |