|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Channel
connections.AppendedPacket.join(Packet, Packet)
instead.
Packet
objects
to a registered org.activeio.ChannelConsumer
.AsyncChannel
and AsyncChannelServer
objects.Packet
objects.Channel
objects
and then delivers those objects to a org.activeio.AcceptConsumer
.RequestChannel
out of a SyncChannel
.RequestChannel
out of a AsyncChannel
.RequestChannel
out of a AsyncChannel
.AsyncChannel
so that it provides an
org.activeio.SynchChannel
interface.#adapt(AsyncChannel)
#adapt(AsyncChannel, Channel)
AsyncChannelServer
so that it provides an
org.activeio.SynchChannelServer
interface.AsyncToSyncChannelServer.adapt(ChannelServer)
AsyncToSyncChannelServer.adapt(ChannelServer, EDU.oswego.cs.dl.util.concurrent.Channel)
byte[]
.ByteBuffer
bufferCount
ByteBuffers that are
directly allocated being bufferSize
big.
byte
.ChannelFactory
uses the requested URI's scheme to determine the
actual org.activeio.SynchChannelFactory
or
AsyncChannelFactory
implementation to use to create it's
Channel
s and ChannelServer
s.ClassLoading
helper classorg.activeio.AsyncChannelFilter
that counts the number bytes that been sent down and up through the channel.org.activeio.SynchChannel
implementation that uses
TCP to talk to the network.org.activeio.net.TcpSynchChannel
and org.activeio.net.TcpSynchChannelServer
objects.byte[0]
.AsyncChannel
and it's org.activeio.ChannelConsumer
.AsyncChannel
and it's org.activeio.ChannelConsumer
.org.activeio.SynchChannel
Most org.activeio.SynchChannel
that are not directly accessing the network will
extends the SynchChannelFilter since they act as a filter between the client and the network.org.activeio.SynchChannel
Most org.activeio.SynchChannel
that are not directly accessing the network will
extends the SynchChannelFilter since they act as a filter between the client and the network.location
that
is in the journal.
Packet
objects
to a registered AsyncChannelListener
.read
method to get Packet
objects when they arrive from the peer.org.activeio.net.TcpSynchChannel
and org.activeio.net.TcpSynchChannelServer
objects that use SSL.org.activeio.net.TcpAsyncChannel
and org.activeio.net.TcpAsyncChannelServer
objects.org.activeio.net.TcpSynchChannel
objects from accepted
tcp socket connections.org.activeio.SynchChannel
implementation that uses a SocketChannel
to talk to the network.org.activeio.net.TcpSynchChannel
and org.activeio.net.TcpSynchChannelServer
objects.org.activeio.net.TcpSynchChannel
objects from accepted
tcp socket connections.AsyncChannelServer
will call this method to when a new channel connection has been
accepted.
AsyncChannelServer
will call this method when a async failure occurs when accepting
a connection.
AsyncChannel
will call this method to deliver an 'up' packet to a consumer.
AsyncChannel
will call this method when a async failure occurs in the channel.
RequestChannel
will call this method when a new request arrives.
RequestChannel
will call this method when a async failure occurs when receiving a request.
Journal.put()
method call.RequestChannel
Exception
.
ChannelConsumer
that the protcol will use to deliver packets
coming 'up' the channel.
JournalEventListener
that will receive notifications from the Journal.
location
is no longer
needed and can be reclaimed for reuse.
RequestListener
that the protcol will use to deliver request packets
comming 'up' the channel.
StreamChannel
implementation that uses a Socket
to talk to the network.org.activeio.net.TcpStreamChannel
and org.activeio.net.TcpStreamChannelServer
objects.org.activeio.net.TcpStreamChannel
objects from accepted
tcp socket connections.org.activeio.SynchChannel
implementation that uses a Socket
to talk to the network.org.activeio.net.TcpSynchChannel
and org.activeio.net.TcpSynchChannelServer
objects.org.activeio.net.TcpSynchChannel
objects from accepted
TCP socket connections.org.activeio.net.TcpSynchChannel
and org.activeio.net.TcpSynchChannelServer
objects that use SSL.StreamChannel
and StreamChannelServer
objects.accept
method to synchronously
accept and create org.activeio.channel.Channel
objects.receiveUpPacket
method to get 'up' Packet
objects when they arrive.org.activeio.SynchChannel
and org.activeio.SynchChannelServer
objects.accept
method to synchronously
accept and create Channel
objects.Socket
interface to a org.activeio.SynchChannel
.org.activeio.SynchChannel
so that it provides an
AsyncChannel
interface.#adapt(SynchChannel)
#adapt(SynchChannel, Executor)
SyncToAsyncChannelFactory.adapt(SyncChannelFactory)
SyncToAsyncChannelFactory.adapt(SyncChannelFactory, Executor)
org.activeio,SynchChannelServer
so that it provides an
AsyncChannelServer
interface.Packet
of data to the journal.
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |