|
||||||||||
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
Constructor Summary | |
---|---|
AbstractAsyncQueueReader(SelectorHandler selectorHandler)
|
Method Summary | |
---|---|
void |
close()
Close AsyncQueueReader and release its resources |
protected abstract SocketAddress |
doRead(ReadableByteChannel channel,
ByteBuffer byteBuffer,
AsyncQueueDataProcessor readPostProcessor)
|
boolean |
isAsyncQueueReaderEnabledFor(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. |
void |
read(SelectionKey key,
ByteBuffer buffer,
AsyncReadCallbackHandler callbackHandler)
|
void |
read(SelectionKey key,
ByteBuffer buffer,
AsyncReadCallbackHandler callbackHandler,
AsyncReadCondition condition)
|
void |
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 |
Constructor Detail |
---|
public AbstractAsyncQueueReader(SelectorHandler selectorHandler)
Method Detail |
---|
public void read(SelectionKey key, ByteBuffer buffer, AsyncReadCallbackHandler callbackHandler) throws IOException
read
in interface AsyncQueueReader
IOException
public void read(SelectionKey key, ByteBuffer buffer, AsyncReadCallbackHandler callbackHandler, AsyncReadCondition condition) throws IOException
read
in interface AsyncQueueReader
IOException
public void read(SelectionKey key, ByteBuffer buffer, AsyncReadCallbackHandler callbackHandler, AsyncReadCondition condition, AsyncQueueDataProcessor readPostProcessor) throws IOException
read
in interface AsyncQueueReader
IOException
public boolean isAsyncQueueReaderEnabledFor(SelectionKey key)
AsyncQueueReader
is registered
for the SelectableChannel
, associated with the given
SelectionKey
isAsyncQueueReaderEnabledFor
in interface AsyncQueueReader
key
- SelectionKey
associated with SelectableChannel
public void onRead(SelectionKey key) throws IOException
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)
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
and release its resources
close
in interface AsyncQueueReader
protected abstract SocketAddress doRead(ReadableByteChannel channel, ByteBuffer byteBuffer, AsyncQueueDataProcessor readPostProcessor) throws IOException
IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |