|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.sun.grizzly.async.AbstractAsyncQueueReader
public abstract class AbstractAsyncQueueReader
Field Summary | |
---|---|
protected SelectorHandler |
selectorHandler
|
Constructor Summary | |
---|---|
AbstractAsyncQueueReader(SelectorHandler selectorHandler)
|
Method Summary | |
---|---|
void |
close()
Close AsyncQueueReader and release its resources |
protected abstract OperationResult |
doRead(ReadableByteChannel channel,
ByteBuffer byteBuffer,
AsyncQueueDataProcessor readPostProcessor,
OperationResult dstResult)
|
AsyncQueue.AsyncQueueEntry |
getAsyncQueue(SelectionKey key)
Gets ready asynchronous queue elements to be read from the SelectableChannel , associated with the
given SelectionKey |
boolean |
isReady(SelectionKey key)
Checks whether AsyncQueueReader is registered
for the SelectableChannel , associated with the given
SelectionKey |
void |
onClose(SelectableChannel channel)
Callback method, which should be called by SelectorHandler to
notify, that given SelectableChannel is going to be closed, so
related data could be released from
AsyncQueueReader |
void |
onRead(SelectionKey key)
Callback method, which should be called by SelectorHandler to
notify, that SelectableChannel , associated with the given
SelectableChannel has ready data for reading. |
Future<AsyncQueueReadUnit> |
read(SelectionKey key,
ByteBuffer buffer,
AsyncReadCallbackHandler callbackHandler)
|
Future<AsyncQueueReadUnit> |
read(SelectionKey key,
ByteBuffer buffer,
AsyncReadCallbackHandler callbackHandler,
AsyncReadCondition condition)
|
Future<AsyncQueueReadUnit> |
read(SelectionKey key,
ByteBuffer buffer,
AsyncReadCallbackHandler callbackHandler,
AsyncReadCondition condition,
AsyncQueueDataProcessor readPostProcessor)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected final SelectorHandler selectorHandler
Constructor Detail |
---|
public AbstractAsyncQueueReader(SelectorHandler selectorHandler)
Method Detail |
---|
public Future<AsyncQueueReadUnit> read(SelectionKey key, ByteBuffer buffer, AsyncReadCallbackHandler callbackHandler) throws IOException
read
in interface AsyncQueueReader
IOException
public Future<AsyncQueueReadUnit> read(SelectionKey key, ByteBuffer buffer, AsyncReadCallbackHandler callbackHandler, AsyncReadCondition condition) throws IOException
read
in interface AsyncQueueReader
IOException
public Future<AsyncQueueReadUnit> read(SelectionKey key, ByteBuffer buffer, AsyncReadCallbackHandler callbackHandler, AsyncReadCondition condition, AsyncQueueDataProcessor readPostProcessor) throws IOException
read
in interface AsyncQueueReader
IOException
public boolean isReady(SelectionKey key)
AsyncQueueReader
AsyncQueueReader
is registered
for the SelectableChannel
, associated with the given
SelectionKey
isReady
in interface AsyncQueueReader
key
- SelectionKey
associated with SelectableChannel
public AsyncQueue.AsyncQueueEntry getAsyncQueue(SelectionKey key)
AsyncQueueReader
SelectableChannel
, associated with the
given SelectionKey
getAsyncQueue
in interface AsyncQueueReader
key
- SelectionKey
associated with SelectableChannel
SelectableChannel
, associated with the
given SelectionKey
/public void onRead(SelectionKey key) throws IOException
AsyncQueueReader
SelectorHandler
to
notify, that SelectableChannel
, associated with the given
SelectableChannel
has ready data for reading.
onRead
in interface AsyncQueueReader
key
- SelectionKey
associated with SelectableChannel
IOException
public void onClose(SelectableChannel channel)
AsyncQueueReader
SelectorHandler
to
notify, that given SelectableChannel
is going to be closed, so
related data could be released from
AsyncQueueReader
onClose
in interface AsyncQueueReader
public void close()
AsyncQueueReader
AsyncQueueReader
and release its resources
close
in interface AsyncQueueReader
protected abstract OperationResult doRead(ReadableByteChannel channel, ByteBuffer byteBuffer, AsyncQueueDataProcessor readPostProcessor, OperationResult dstResult) throws IOException
IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |