|
||||||||||
| 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[].ByteBufferbufferCount ByteBuffers that are
directly allocated being bufferSize big.
byte.ChannelFactoryuses the requested URI's scheme to determine the
actual org.activeio.SynchChannelFactoryor
AsyncChannelFactoryimplementation to use to create it's
Channels and ChannelServers.ClassLoading helper classorg.activeio.AsyncChannelFilter
that counts the number bytes that been sent down and up through the channel.org.activeio.SynchChannelimplementation 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.TcpSynchChannelobjects 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.TcpSynchChannelobjects 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.RequestChannelException.
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.TcpStreamChannelobjects 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.TcpSynchChannelobjects 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 | |||||||||