|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
ConnectorHandler
ConnectorHandler
ConnectorHandler
,
which corresponds to the protocol
ConnectorHandler
based on the
Protocol requested.
ConnectorHandler
ConnectorHandler
,
which is the TCPConnectorHandler
Channel
to be processed byReadController
's
SelectorHandler
DefaultProtocolChain.EventHandler
ProtocolFilter
to this ProtocolChain
ProtocolFilter
to the list.
ProtocolFilter
to the list at position 'pos'.
SelectorHandler
ByteBufferType
ByteBuffer
ByteBuffer
s.
ByteBuffer
view
ByteBuffer
view using the default size.
Map
-like collection, maps keys to values, where
single key could have queue of correspondent values.AsyncQueue
data unitAsyncQueueWriter
for pre processing data, which will be sent on a
SelectableChannel
; or by AsyncQueueReader
for
post processing data, which were read from a SelectableChannel
.Future
implementationByteBuffer
asynchronously, using queue.AsyncQueueWriter
AsyncQueueReader
task, which will be executed by
Context
, when Context.execute(ContextTask
)
is called.AsyncQueue
write data unitByteBuffer
data asynchronously,
using queue.AsyncQueueWriter
AsyncQueueWriter
task, which will be executed by
Context
, when Context.execute(ContextTask
)
is called.AsyncQueue
write data unitAsyncQueueReader
to notify
custom code either about completion of specific ByteBuffer
reading
or about IO problem, which occured when reading data to a ByteBuffer
AsyncQueueReader
was able to read new portion of data from
SelectableChannel
, whoch is associated with a
SelectionKey
.AsyncQueueWriter
to notify
custom code either about completion of specific ByteBuffer
writing
or about IO problem, which occured when writing ByteBuffer
Channel
associated with this handler.
Controller
instance
SelectorHandler
instance
Role
, depending on isClient value
ByteBuffer
byteBuffer -
Variable in class com.sun.grizzly.util.WorkerThread
ByteBuffer
used when Task
are executed.
AsyncQueueWriter
, when ByteBuffer
could not be written directly, and will be added to the queue.ByteBuffer
.InputReader
insteadByteBufferFactory.ByteBufferType
ConnectorInstanceHandler
which use a
ConcurrentQueue
to pool CacheableConnectorHandler
CallbackHandler
handler invoked by the UDPSelectorHandler
when a non blocking operation is ready to be processed.
CallbackHandler
task, which will be executed by
Context
, when Context.execute(ContextTask
)
is called.CallbackHandler
descriptor.SelectionKey
attachment, which wraps CallbackHandler
Context.suspend()
ed Context
.
NIOContext.suspend()
ed Context
.
ReadableChannel
and it associated SelectionKey
ByteBuffer
from which views
will be created.
ByteBuffer
,
is read completely, or custom code expects more data.
Copyable
AsyncQueueReader
and release its resources
AsyncQueueWriter
and release its resources
AsyncQueueReader
and release its resources
AsyncQueueWriter
and release its resources
SelectableChannel
SelectableChannel
SelectableChannel
SelectorHandler
does.ObjectPool
implementation based on ConcurrentLinkedQueue
Context
NIOContext.currentOpType
based on the
SelectionKey.readyOps()
values.
SelectorHandler
, ConnectionHandler
or SelectionKeyHandler
close a connection (ConnectionCloseHandler.locallyClosed(java.nio.channels.SelectionKey)
), or when a
remote client close the connection (ConnectionCloseHandler.remotlyClosed(java.nio.channels.SelectionKey)
).ConnectorHandler
sConnectorHandler
instance creation.ProtocolFilter
implementation.SelectionKey
's registration state.SelectionKey
.OP_XXXX.Context
, when
Context.execute(ContextTask
) is called.ControllerStateListener
CallbackHandler
to the SelectionKey
CallbackHandler will not be attached directly, but wrapped with
CallbackHandlerSelectionKeyAttachment
ByteBuffer
if the current instance is null;
Context
.
Context
.
CallbackHandler
implementation that implements the connect
operations, and delegate the read and write operations to its associated
SelectorHandler
ProtocolChain
, like the default
SelectorHandler
is doing server side component.CallbackHandler
that delegate the read and write
operation to the ProtocolChain
associated with the
ConnectorHandler
CallbackHandler
that delegate the read and write
operation to the ProtocolChain
associated with the
ConnectorHandler
.
ByteBuffer
ConnectorHandlerPool
implementationProtocolChain
ThreadPoolExecutor
ReadSelector
SSLEngine
.
SelectionKey
to handle certain operations
SelectionKey
to handle certain operations
DefaultProtocolChain.EventHandler
s, which will be notified about this
ProtocolChain
events
ProtocolFilter
in the ProtocolChain
.
ByteBuffer
and delegate
the processing of them to the next ProtocolFilter in the ProtocolChain.
Context
instance.
SelectionKey
set.
SelectionKey
set.
SelectionKey
set.
SuspendableFilter.suspend(java.lang.String)
)
ByteBuffer
is empty
ByteBuffer
is empty
ByteBuffer
is empty
ByteBuffer
is empty
ByteBuffer
is empty
ByteBuffer
is empty
OutputWriter
OutputWriter
SelectableChannel
, associated with the
given SelectionKey
SelectableChannel
, associated with the
given SelectionKey
SelectableChannel
, associated with the
given SelectionKey
SelectableChannel
, associated with the
given SelectionKey
AsyncQueueReadable
, assciated with the current
Context
.
AsyncQueueReader
associated with this
SelectorHandler
.
AsyncQueueReader
associated with this
SelectorHandler
.
AsyncQueueWritable
, assciated with the current
Context
.
AsyncQueueWritable
, assciated with the current
Context
.
AsyncQueueWriter
associated with this
SelectorHandler
.
AsyncQueueWriter
associated with this
SelectorHandler
.
AttributeHolder
, which corresponds to the
given Context.AttributeScope
>
AttributeHolder
, which corresponds to the
given AttributeScope
>
Map
of attribute name/value pairs.
Map
of attribute name/value pairs.
Map
of attribute name/value pairs.
Map
of attribute name/value pairs.
Map
of attribute name/value pairs.
ByteBuffer
ByteBuffer
shared this thread
ByteBuffer
shared this thread
ByteBufferType
used to create the ByteBuffer
associated with this object.
ConnectionCache
.
ConnectorHandler
's callback handler instance,
which is used to process occuring events
CallbackHandler
.
CallbackHandler
.
CallbackHandler
.
Channel
type.
ConnectionClosedHandler
.
ConnectorHandlerPool
used.
ConnectorInstanceHandler
corresponding to the protocol
Controller
Controller
.
Controller
.
Controller
Controller
Controller
SelectionKey
interest ops this instance is executing.
SelectionKey
interest ops this instance is executing.
SSLEngine
is initialized.
SSLEngine
is initialized.
Interceptor
associated with this algorithm.
Handler
ByteBuffer
used to handle request.
ByteBuffer
used to handle request.
ByteBuffer
.
IOEvent
associated with this
instance.
IOEvent
associated with this
instance.
SelectionKey
's next registration state, or null
if not supported.
SelectionKey
's next registration state.
ByteBuffer
used to handle response.
ByteBuffer
used to handle response.
SelectorHandler
is listening on
Similar to getPort()
, but getting port number directly from
connection (ServerSocket
, DatagramSocket
).
Controller#Protocol
this instance is executing.
Controller#Protocol
this instance is executing.
ProtocolChain
executed by this instance.
ProtocolChain
executed by this instance.
ProtocolChain
instance, which is always
returned via StatelessProtocolChainInstanceHandler#poll()
.
ProtocolChainInstanceHandler
ProtocolChainInstanceListener
associated with this
Context
ProtocolChainInstanceHandler
ProtocolChainInstanceHandler
ReadFilter
will try to read a data
from a channel.
SelectorHandler
current role.
SSLConnectorHandler
's secured input buffer, it
uses for reading data from a socket channel.
SSLConnectorHandler
's secured output buffer, it
uses for writing data to a socket channel.
SelectionKey
or null if
{@link SelectionKey aren't supported.
SelectionKey
.
SelectionKeyHandler
Method is deprecated. Use SelectorHandler.getSelectionKeyHandler() instead
Selector
SelectorHandler
SelectorHandler
, which manages this
ConnectorHandler
SelectorHandler
this instance is executing, or
null if not supported.
SelectorHandler
associated with the protocol.
SelectorHandler
associated
with the Selector
.
SelectorHandler
SelectorHandler
.
SelectorHandler
.
SelectorHandler
.
SelectorHandler
's clone, registered
on thisReadController
SelectorHandler
SSLContext
SSLEngine
SSLEngine
.
SSLEngine
.
Controller
's StateHolder
StateHolder
for this object
StateHolder
for this object
StateHolder
ExecutorService
executing this instance.
ExecutorService
(Thread Pool) used by this Controller.
ExecutorService
executing this instance.
ExecutorService
used to execute this
SelectorHandler
's SelectionKey
ops
ExecutorService
used to execute this
SelectorHandler
's SelectionKey
ops
ConnectorHandler
's underlying channel
SocketChannel
used.
SocketChannel
used.
SocketChannel
used.
ByteBuffer
given
to this ProtocolParser's ProtocolParser#startBuffer()
?
ProtocolParser.getNextMessage()
.
WorkerThread
to
indicate that this Context
should not be
Context.recycle()
or offered back to its pool.
WorkerThread
to
indicate that this Context
should not be
NIOContext.recycle()
or offered back to its pool.
SelectionKey
operation registries
ByteBuffer
.Channel
type is used to avoid invoking the instanceof
operation when registering the Socket|Datagram Channel to the Selector.InputStream
that use a pool of Selector
to execute a blocking read operation.
Suspendable.cancel()
)
AsyncQueueReader
AsyncQueueWriter
ProtocolParser
.
CallbackHandler
with an instance of
this class.ExecutorService
can
re-execute its ProtocolFilter after a successful execution.
ExecutorService
can
re-execute its ProtocolFilter after a successful execution.
ExecutorService
can
re-execute its ProtocolFilter after a successful execution.
ProtocolChain
is enabled.
K
key related queue is empty.
AsyncQueueReader
is registered
for the SelectableChannel
, associated with the given
SelectionKey
AsyncQueue
ready
to be written to the SelectableChannel
, associated with the
given SelectionKey
AsyncQueueReader
is registered
for the SelectableChannel
, associated with the given
SelectionKey
AsyncQueue
ready
to be written to the SelectableChannel
, associated with the
given SelectionKey
#resumed
SelectorHandler
suspend
.
suspend
.
SelectionKey
used by this stream.
SelectionKey
is cancelled locally, e.g. by
one SelectorHandler
, ConnectionHandler
or SelectionKeyHandler
Logger
used by this Controller.
getNextMessage
for
use by downstream filters
SSLEngine
WorkerThread
.
ProtocolFilter
implementation.DefaultProtocolChain.EventHandler
s about exception, which occured
ConnectionCloseHandler
that a remote connection
has been closed.
AsyncQueue
, corresponding to the given
E
key
SelectorHandler
to
notify, that given SelectableChannel
is going to be closed, so
related data could be released from
AsyncQueueReader
SelectorHandler
to
notify, that given SelectableChannel
is going to be closed, so
related SelectableChannel
data could be released from
AsyncQueue
SelectorHandler
to
notify, that given SelectableChannel
is going to be closed, so
related data could be released from
AsyncQueueReader
SelectorHandler
to
notify, that given SelectableChannel
is going to be closed, so
related SelectableChannel
data could be released from
AsyncQueue
AsyncQueueReader
, if
error occured when reading from the SelectableChannel
,
which is associated with SelectionKey
AsyncQueueWriter
, if
error occured when writing ByteBuffer
to the
SelectableChannel
, associated with SelectionKey
SelectorHandler
to
notify, that SelectableChannel
, associated with the given
SelectableChannel
has ready data for reading.
SelectorHandler
to
notify, that SelectableChannel
, associated with the given
SelectableChannel
has ready data for reading.
AsyncQueueReader
, if
data was read to the ByteBuffer
from the
SelectableChannel
, associated with SelectionKey
,
and read data confirms to the user-specific condition (if any was set).
SelectorHandler
s were initialized
SelectorHandler
to
notify, that SelectableChannel
, associated with the given
SelectionKey
is ready to transmit data.
SelectorHandler
to
notify, that SelectableChannel
, associated with the given
SelectionKey
is ready to transmit data.
AsyncQueueWriter
, if
whole ByteBuffer
data was written to the
SelectableChannel
, associated with SelectionKey
SelectionKeyOP
to register next time the
Selector.select is invoked.
ByteBuffer
ByteBuffer
and try to determine if the bytes
stream has been fully read from the SocketChannel
.
Controller
and associated SelectorHandler
s
SelectorHandler
SelectorHandler
E
key related queue.
K
key related queue.
ProtocolChain
instance.
Context
Context
Context
from pool and initializes it.
ByteBuffer
SelectionKey
post process notification
SelectionKey
post process notification
SelectionKey
post process notification
Selector.select(long)
, make sure the ServerSocketChannel
has been created.
SelectionKey
process notification
SelectionKey
process notification
SelectionKey
process notification
ProtocolChain
result attribute name.
ProtocolChain
instance.
ProtocolChain
task, which will be executed by
Context
, when Context.execute(ContextTask
)
is called.ProtocolChainInstruction
contains the instruction for a
ProtocolChain
, how it should continue the invokation.ByteBuffer
.
ByteBuffer
.
ByteBuffer
.
ByteBuffer
.
Controller
,
which is not itself independent.ProtocolFilter
implementation which read the available bytes
and delegate the processing to the next ProtocolFilter
in the ProtocolChain
.ByteBuffer
using async read queue.
ByteBuffer
using async read queue.
ByteBuffer
using async read queue.
ByteBuffer
using async read queue.
ByteBuffer
using async read queue.
ByteBuffer
using async read queue.
ByteBuffer
using async read queue.
ByteBuffer
using async read queue.
ByteBuffer
using async read queue.
ByteBuffer
using async read queue.
ByteBuffer
using async read queue.
ByteBuffer
using async read queue.
Controller
s to be used for reading
SelectableChannel
to
ByteBuffer
.
SelectorHandler
s, which
are ready to process
SelectionKey
on Selector
.
SelectableChannel
on Selector
.
SelectionKey
s.
SelectionKey
s.
SelectionKey
on Selector
.
SelectableChannel
on Selector
.
SelectionKey
on Selector
.
SelectableChannel
on Selector
.
SelectionKey
s.
SelectableChannel
on the Selector
.
ProtocolChain
reinvokation.CacheableConnectorHandler
, however this
CacheableConnectorHandler
will be still interested in getting
expectedResponseCount responses on it.
ConnectorHandler
ConnectorHandler
ProtocolParser#startBuffer()
.
ConnectorHandler
to the pool of ConnectorHandler.
K
key related queue.
DefaultProtocolChain.EventHandler
.
ProtocolFilter
from this chain.
SelectorHandler
and removes it from this
Controller
list
SelectorHandler
's clone, registered
on thisReadController
Context.suspend()
ed Context
.
Controller
and associated SelectorHandler
s
NIOContext.suspend()
ed Context
.
SelectorHandler
SelectorHandler
Suspendable.resume()
)
Context
to its pool if it is not shared.
Selector
to the cache
ByteBuffer
to its previous state in case
an error as occured.
SelectionKeyAttachment
,
and introduces process method, which will be called by framework once
SelectionKey
has some ready event, before actual event processing.SelectionKey
attachment utility class.ContextTask
s, which are dealing with
SelectionKey
sSelector.selectNow()
and returns
the Selector
to the cache
Selector
.SelectorHandler
SelectorHandler
SelectorHandler
s used by this instance.
Map
of attribute name/value pairs.
Map
of attribute name/value pairs.
Map
of attribute name/value pairs.
Map
of attribute name/value pairs.
Map
of attribute name/value pairs.
ByteBuffer
ByteBuffer
shared this thread
ByteBuffer
shared this thread
ByteBufferType
to use when creating the
ByteBuffer
associated with this object.
ConnectorHandler
's callback handler instance,
which is used to process occuring events
CallbackHandler
.
CallbackHandler
.
CallbackHandler
.
Channel
used by this algorithm
Channel
type, which is ocketChannel
or DatagramChannel.
ConnectionClosedHandler
ConnectorHandlerPool
used.
ExecutorService
can
re-execute its ProtocolFilter(s) after a successful execution.
ExecutorService
can
re-execute its ProtocolFilter(s) after a successful execution.
ExecutorService
can
re-execute its ProtocolFilter(s) after a successful execution.
Controller
associated with this instance.
Controller
.
Controller
to use with this instance.
Controller
to use with this instance.
Controller
to use with this instance.
ProtocolChain
true> to enable delagation of the read and write operations
to a ProtocolChain
SSLEngine
is initialized.
SSLEngine
is initialized.
ByteBuffer
used to handle request.
ByteBuffer
used to handle request.
SelectionKey
's next registration state
SelectionKey
's next registration state
ByteBuffer
used to handle response.
ByteBuffer
used to handle response.
port
this algorithm is used.
ProtocolChain
used by this Context
.
ProtocolChain
used by this Context
.
ProtocolChain
instance, which will be always
returned via StatelessProtocolChainInstanceHandler#poll()
.
ProtocolChainInstanceHandler
to use for
creating instance of ProtocolChain
.
ProtocolChainInstanceHandler
to use for
creating instance of ProtocolChain
.
ProtocolChainInstanceHandler
to use for
creating instance of ProtocolChain
.
ReadFilter
will try to read a data
from a channel.
SelectorHandler
current role.
SelectionKey
.
SelectionKey
used to reads bytes.
SelectionKeyHandler
to use for managing the life
cycle of SelectionKey.
Method is deprecated. Use SelectorHandler.setSelectionKeyHandler() instead
Selector
SelectorHandler
SelectorHandler
SelectorHandler
this instance is executing.
SelectorHandler
SSLContext
.
SSLEngine
SSLEngine
.
SSLEngine
.
ExecutorService
that will execute this instance.
ExecutorService
(Thread Pool).
ExecutorService
that will execute this instance.
ExecutorService
used to execute this
SelectorHandler
's SelectionKey
ops
ExecutorService
used to execute this
SelectorHandler
's SelectionKey
ops
SocketChannel
.
SocketChannel
.
ProtocolChainInstanceHandler
.K
key related queue.
SSLContext
associated with the SSL implementation
we are running on.
AsyncQueueWriter
SSLEngine
used to manage the SSL over NIO request.
ByteBuffer
and flush them.Controller
state
SelectorHandler
StateHolder, which is shared among
SelectorHandler and its clones
StateHolder
.
StateHolder
.
EventConditionListener
, and implements notificatation logic,
when condition becomes true.Controller
state listeners, which
will are notified on Controller
state change.
SelectorHandler
s, which stopped
StateHolder
for state controlContext
.
Context
.
ReadableChannel
represented by this SuspendableFilter.KeyHandler
by registering it on secondary Selector.
SuspendableFilter@#suspend
An instance of that class can be used to resume or cancel a suspended connection.ProtocolChain
When a connection is suspended, the framework will not continue the execution
of the ProtocolChain and its associated ProtocolFilter
.DefaultProtocolChain
from position SuspendableFilter.nextFilterPosition
SuspendableHandler
with add some connection
state.Selector
used to keep the state of a suspended
connection (SelectionKey
).SelectionKey
.
AsyncQueueWriter
WorkerThread
.ThreadGroup
used.
ExecutorService
used by this instance.
DefaultThreadPool
on which this thread synchronize.
AsyncQueueWriter
inputBB
to
ByteBuffer
using theSSLEngine
inputBB
to
ByteBuffer
using theSSLEngine
SelectorHandler
s will
not get stopped
Thread
attributes.WorkerThread
DefaultThreadPool
instance.
DefaultThreadPool
instance.
DefaultThreadPool
instance.
DefaultThreadPool
instance.
DefaultThreadPool
instance.
ByteBuffer
to the SelectableChannel
First, if SelectableChannel
associated write queue is empty -
it tries to write ByteBuffer
to the given
SelectableChannel
directly (without putting to the queue).
ByteBuffer
to the SelectableChannel
First, if SelectableChannel
associated write queue is empty -
it tries to write ByteBuffer
to the given
SelectableChannel
directly (without putting to the queue).
ByteBuffer
to the SelectableChannel
First, if SelectableChannel
associated write queue is empty -
it tries to write ByteBuffer
to the given
SelectableChannel
directly (without putting to the queue).
ByteBuffer
to the SelectableChannel
First, if SelectableChannel
associated write queue is empty -
it tries to write ByteBuffer
to the given
SelectableChannel
directly (without putting to the queue).
ByteBuffer
to the SocketAddress
First, if SelectableChannel
associated write queue is empty -
it tries to write ByteBuffer
to the given
SocketAddress
directly (without putting to the queue).
ByteBuffer
to the SocketAddress
First, if SelectableChannel
associated write queue is empty -
it tries to write ByteBuffer
to the given
SocketAddress
directly (without putting to the queue).
ByteBuffer
to the SocketAddress
First, if SelectableChannel
associated write queue is empty -
it tries to write ByteBuffer
to the given
SocketAddress
directly (without putting to the queue).
ByteBuffer
to the SocketAddress
First, if SelectableChannel
associated write queue is empty -
it tries to write ByteBuffer
to the given
SocketAddress
directly (without putting to the queue).
ByteBuffer
to the SelectableChannel
First, if SelectableChannel
associated write queue is empty -
it tries to write ByteBuffer
to the given
SelectableChannel
directly (without putting to the queue).
ByteBuffer
to the SelectableChannel
First, if SelectableChannel
associated write queue is empty -
it tries to write ByteBuffer
to the given
SelectableChannel
directly (without putting to the queue).
ByteBuffer
to the SelectableChannel
First, if SelectableChannel
associated write queue is empty -
it tries to write ByteBuffer
to the given
SelectableChannel
directly (without putting to the queue).
ByteBuffer
to the SelectableChannel
First, if SelectableChannel
associated write queue is empty -
it tries to write ByteBuffer
to the given
SelectableChannel
directly (without putting to the queue).
ByteBuffer
to the SocketAddress
First, if SelectableChannel
associated write queue is empty -
it tries to write ByteBuffer
to the given
SocketAddress
directly (without putting to the queue).
ByteBuffer
to the SocketAddress
First, if SelectableChannel
associated write queue is empty -
it tries to write ByteBuffer
to the given
SocketAddress
directly (without putting to the queue).
ByteBuffer
to the SocketAddress
First, if SelectableChannel
associated write queue is empty -
it tries to write ByteBuffer
to the given
SocketAddress
directly (without putting to the queue).
ByteBuffer
to the SocketAddress
First, if SelectableChannel
associated write queue is empty -
it tries to write ByteBuffer
to the given
SocketAddress
directly (without putting to the queue).
ByteBuffer
to the SocketAddress
First, if SelectableChannel
associated write queue is empty -
it tries to write ByteBuffer
to the given
SocketAddress
directly (without putting to the queue).
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
ByteBuffer
using async write queue.
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |