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.journal.howl |
A Journal implemenation using using a high performance transaction log
implemented using Howl
|
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 and Description |
---|---|
protected Packet |
PacketByteArrayOutputStream.allocate() |
Packet |
PacketByteArrayOutputStream.getPacket() |
Constructor and Description |
---|
PacketInputStream(Packet packet)
Deprecated.
|
PacketOutputStream(Packet packet) |
PacketToInputStream(Packet packet) |
Modifier and Type | Method and Description |
---|---|
Packet |
Journal.read(RecordLocation location)
Reads a previously written record from the journal.
|
Modifier and Type | Method and Description |
---|---|
RecordLocation |
Journal.write(Packet packet,
boolean sync)
Writes a
Packet of data to the journal. |
Modifier and Type | Method and Description |
---|---|
Packet |
ControlFile.getControlData() |
Packet |
BatchedWrite.getPacket() |
Packet |
Record.getPayload() |
Packet |
JournalImpl.read(RecordLocation l) |
Packet |
LogFileManager.readPacket(Location location) |
Modifier and Type | Method and Description |
---|---|
void |
Record.read(Packet packet) |
boolean |
Record.readFromPacket(Packet packet) |
static Location |
Location.readFromPacket(Packet packet) |
RecordLocation |
JournalImpl.write(Packet data,
boolean sync) |
void |
Location.writeToPacket(Packet packet) |
Constructor and Description |
---|
BatchedWrite(Packet packet) |
Record(byte recordType,
Packet payload,
Location mark) |
Record(Location location,
byte recordType,
Packet payload,
Location mark) |
Modifier and Type | Method and Description |
---|---|
Packet |
HowlJournal.read(RecordLocation location) |
Modifier and Type | Method and Description |
---|---|
RecordLocation |
HowlJournal.write(Packet packet,
boolean sync) |
Modifier and Type | Method and Description |
---|---|
boolean |
IIOPRecognizer.recognizes(Packet packet) |
boolean |
HttpRecognizer.recognizes(Packet packet) |
boolean |
ProtocolRecognizer.recognizes(Packet packet) |
Modifier and Type | Class and 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
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 and Description |
---|---|
protected Packet |
FilterPacket.next |
Modifier and Type | Method and Description |
---|---|
protected abstract Packet |
PacketPool.allocateNewPacket() |
protected Packet |
ByteBufferPacketPool.allocateNewPacket() |
Packet |
ByteBufferPacket.compact() |
Packet |
EOSPacket.duplicate() |
Packet |
AppendedPacket.duplicate() |
Packet |
ByteBufferPacket.duplicate() |
Packet |
FilterPacket.duplicate() |
Packet |
Packet.duplicate() |
Packet |
EmptyPacket.duplicate() |
Packet |
BytePacket.duplicate() |
Packet |
ByteArrayPacket.duplicate() |
Packet |
PacketPool.PooledPacket.filter(Packet packet) |
abstract Packet |
FilterPacket.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 |
EOSPacket.slice() |
Packet |
AppendedPacket.slice() |
Packet |
ByteBufferPacket.slice() |
Packet |
FilterPacket.slice() |
Packet |
Packet.slice() |
Packet |
EmptyPacket.slice() |
Packet |
BytePacket.slice() |
Packet |
ByteArrayPacket.slice() |
Modifier and Type | Method and Description |
---|---|
Packet |
PacketPool.PooledPacket.filter(Packet packet) |
abstract Packet |
FilterPacket.filter(Packet packet) |
static Packet |
AppendedPacket.join(Packet first,
Packet last) |
int |
EOSPacket.read(Packet dest) |
int |
AppendedPacket.read(Packet dest) |
int |
ByteBufferPacket.read(Packet dest) |
int |
FilterPacket.read(Packet dest) |
int |
Packet.read(Packet dest) |
int |
EmptyPacket.read(Packet dest) |
int |
BytePacket.read(Packet dest) |
int |
ByteArrayPacket.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 and Description |
---|
AppendedPacket(Packet first,
Packet second)
Deprecated.
use
AppendedPacket.join(Packet, Packet) instead. |
FilterPacket(Packet next) |
PacketData(Packet packet) |
PacketData(Packet packet,
boolean bigEndian) |
PacketPool.PooledPacket(Packet next) |
Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.