Package | Description |
---|---|
org.apache.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.apache.activeio.journal |
Provides the API for storing and accessing record based binary data in sequential log files.
|
org.apache.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.apache.activeio.oneport |
This package provides the implementing classes that allow you to run multiple protocols
from a sigle port.
|
org.apache.activeio.packet |
Implementations of the Packet class.
|
Modifier and Type | Method | Description |
---|---|---|
protected Packet |
PacketByteArrayOutputStream.allocate() |
|
Packet |
PacketByteArrayOutputStream.getPacket() |
Constructor | Description |
---|---|
PacketInputStream(Packet packet) |
Deprecated.
|
PacketOutputStream(Packet packet) |
|
PacketToInputStream(Packet packet) |
Modifier and Type | Method | Description |
---|---|---|
Packet |
Journal.read(RecordLocation location) |
Reads a previously written record from the journal.
|
Modifier and Type | Method | Description |
---|---|---|
RecordLocation |
Journal.write(Packet packet,
boolean sync) |
Writes a {@see Packet} of data to the journal.
|
Modifier and Type | Method | Description |
---|---|---|
Packet |
ControlFile.getControlData() |
|
Packet |
BatchedWrite.getPacket() |
|
Packet |
Record.getPayload() |
|
Packet |
JournalImpl.read(RecordLocation l) |
|
Packet |
LogFileManager.readPacket(Location location) |
Modifier and Type | Method | Description |
---|---|---|
void |
Record.read(Packet packet) |
|
static Location |
Location.readFromPacket(Packet packet) |
|
boolean |
Record.readFromPacket(Packet packet) |
|
RecordLocation |
JournalImpl.write(Packet data,
boolean sync) |
|
void |
Location.writeToPacket(Packet packet) |
Constructor | Description |
---|---|
BatchedWrite(Packet packet) |
|
Record(byte recordType,
Packet payload,
Location mark) |
|
Record(Location location,
byte recordType,
Packet payload,
Location mark) |
Modifier and Type | Method | Description |
---|---|---|
boolean |
HttpRecognizer.recognizes(Packet packet) |
|
boolean |
IIOPRecognizer.recognizes(Packet packet) |
|
boolean |
ProtocolRecognizer.recognizes(Packet packet) |
Modifier and Type | Class | Description |
---|---|---|
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 {@see java.nio.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 |
Modifier and Type | Field | Description |
---|---|---|
protected Packet |
FilterPacket.next |
Modifier and Type | Method | Description |
---|---|---|
protected Packet |
ByteBufferPacketPool.allocateNewPacket() |
|
protected abstract Packet |
PacketPool.allocateNewPacket() |
|
Packet |
ByteBufferPacket.compact() |
|
Packet |
AppendedPacket.duplicate() |
|
Packet |
ByteArrayPacket.duplicate() |
|
Packet |
ByteBufferPacket.duplicate() |
|
Packet |
BytePacket.duplicate() |
|
Packet |
EmptyPacket.duplicate() |
|
Packet |
EOSPacket.duplicate() |
|
Packet |
FilterPacket.duplicate() |
|
Packet |
Packet.duplicate() |
|
abstract Packet |
FilterPacket.filter(Packet packet) |
|
Packet |
PacketPool.PooledPacket.filter(Packet packet) |
|
Packet |
PacketPool.getPacket() |
Blocks until a ByteBuffer can be retreived from the pool.
|
static Packet |
AppendedPacket.join(Packet first,
Packet last) |
|
Packet |
ByteBufferPacket.mark() |
|
Packet |
AppendedPacket.slice() |
|
Packet |
ByteArrayPacket.slice() |
|
Packet |
ByteBufferPacket.slice() |
|
Packet |
BytePacket.slice() |
|
Packet |
EmptyPacket.slice() |
|
Packet |
EOSPacket.slice() |
|
Packet |
FilterPacket.slice() |
|
Packet |
Packet.slice() |
Modifier and Type | Method | Description |
---|---|---|
abstract Packet |
FilterPacket.filter(Packet packet) |
|
Packet |
PacketPool.PooledPacket.filter(Packet packet) |
|
static Packet |
AppendedPacket.join(Packet first,
Packet last) |
|
int |
AppendedPacket.read(Packet dest) |
|
int |
ByteArrayPacket.read(Packet dest) |
|
int |
ByteBufferPacket.read(Packet dest) |
|
int |
BytePacket.read(Packet dest) |
|
int |
EmptyPacket.read(Packet dest) |
|
int |
EOSPacket.read(Packet dest) |
|
int |
FilterPacket.read(Packet dest) |
|
int |
Packet.read(Packet dest) |
|
static boolean |
PacketData.readBoolean(Packet packet) |
|
static byte |
PacketData.readByte(Packet packet) |
|
static char |
PacketData.readCharBig(Packet packet) |
|
static char |
PacketData.readCharLittle(Packet packet) |
|
static double |
PacketData.readDoubleBig(Packet packet) |
|
static double |
PacketData.readDoubleLittle(Packet packet) |
|
static float |
PacketData.readFloatBig(Packet packet) |
|
static float |
PacketData.readFloatLittle(Packet packet) |
|
static void |
PacketData.readFully(Packet packet,
byte[] b) |
|
static void |
PacketData.readFully(Packet packet,
byte[] b,
int off,
int len) |
|
static int |
PacketData.readIntBig(Packet packet) |
|
static int |
PacketData.readIntLittle(Packet packet) |
|
static long |
PacketData.readLongBig(Packet packet) |
|
static long |
PacketData.readLongLittle(Packet packet) |
|
static short |
PacketData.readShortBig(Packet packet) |
|
static short |
PacketData.readShortLittle(Packet packet) |
|
static int |
PacketData.readUnsignedByte(Packet packet) |
|
static int |
PacketData.readUnsignedShortBig(Packet packet) |
|
static int |
PacketData.readUnsignedShortLittle(Packet packet) |
|
static int |
PacketData.skipBytes(Packet packet,
int n) |
|
static void |
PacketData.write(Packet packet,
byte[] b) |
|
static void |
PacketData.write(Packet packet,
byte[] b,
int off,
int len) |
|
static void |
PacketData.write(Packet packet,
int b) |
|
static void |
PacketData.writeBoolean(Packet packet,
boolean v) |
|
static void |
PacketData.writeByte(Packet packet,
int v) |
|
static void |
PacketData.writeCharBig(Packet packet,
int v) |
|
static void |
PacketData.writeCharLittle(Packet packet,
int v) |
|
static void |
PacketData.writeDoubleBig(Packet packet,
double v) |
|
static void |
PacketData.writeDoubleLittle(Packet packet,
double v) |
|
static void |
PacketData.writeFloatBig(Packet packet,
float v) |
|
static void |
PacketData.writeFloatLittle(Packet packet,
float v) |
|
static void |
PacketData.writeIntBig(Packet packet,
int v) |
|
static void |
PacketData.writeIntLittle(Packet packet,
int v) |
|
static void |
PacketData.writeLongBig(Packet packet,
long v) |
|
static void |
PacketData.writeLongLittle(Packet packet,
long v) |
|
static void |
PacketData.writeRawDoubleBig(Packet packet,
double v) |
|
static void |
PacketData.writeRawDoubleLittle(Packet packet,
double v) |
|
static void |
PacketData.writeRawFloatBig(Packet packet,
float v) |
|
static void |
PacketData.writeRawFloatLittle(Packet packet,
float v) |
|
static void |
PacketData.writeShortBig(Packet packet,
int v) |
|
static void |
PacketData.writeShortLittle(Packet packet,
int v) |
Constructor | Description |
---|---|
AppendedPacket(Packet first,
Packet second) |
Deprecated.
use {@see #join(Packet, Packet)} instead.
|
FilterPacket(Packet next) |
|
PacketData(Packet packet) |
|
PacketData(Packet packet,
boolean bigEndian) |
|
PooledPacket(Packet next) |
Copyright © 2005–2018. All rights reserved.