public final class TCPNIOAsyncQueueWriter extends AbstractNIOAsyncQueueWriter
AsyncQueueWriter
implementation, based on
the Java NIOWriter.Reentrant
AsyncQueue.AsyncResult
EMPTY_RECORD_SPACE_VALUE, maxPendingBytes, maxWriteReentrants, transport
AUTO_SIZE, UNLIMITED_SIZE
EXPECTING_MORE_OPTION
Constructor and Description |
---|
TCPNIOAsyncQueueWriter(NIOTransport transport) |
Modifier and Type | Method and Description |
---|---|
protected AsyncWriteQueueRecord |
aggregate(TaskQueue<AsyncWriteQueueRecord> writeTaskQueue)
Aggregates records in a queue to be written as one chunk.
|
protected static void |
offerToTaskQueue(NIOConnection nioConnection,
AsyncWriteQueueRecord queueRecord,
TaskQueue<AsyncWriteQueueRecord> taskQueue) |
protected void |
onReadyToWrite(NIOConnection connection) |
protected long |
write0(NIOConnection connection,
AsyncWriteQueueRecord queueRecord) |
canWrite, canWrite, close, createRecord, getMaxPendingBytesPerConnection, isAllowDirectWrite, isReady, notifyWritePossible, notifyWritePossible, onClose, onWriteFailure, processAsync, setAllowDirectWrite, setMaxPendingBytesPerConnection, write, write, write
write, write, write, write
public TCPNIOAsyncQueueWriter(NIOTransport transport)
protected long write0(NIOConnection connection, AsyncWriteQueueRecord queueRecord) throws IOException
write0
in class AbstractNIOAsyncQueueWriter
IOException
protected final void onReadyToWrite(NIOConnection connection) throws IOException
onReadyToWrite
in class AbstractNIOAsyncQueueWriter
IOException
protected AsyncWriteQueueRecord aggregate(TaskQueue<AsyncWriteQueueRecord> writeTaskQueue)
aggregate
in class AbstractNIOAsyncQueueWriter
protected static void offerToTaskQueue(NIOConnection nioConnection, AsyncWriteQueueRecord queueRecord, TaskQueue<AsyncWriteQueueRecord> taskQueue)
Copyright © 2014 Oracle Corporation. All rights reserved.