Package | Description |
---|---|
org.glassfish.grizzly.asyncqueue | |
org.glassfish.grizzly.nio | |
org.glassfish.grizzly.nio.transport |
Modifier and Type | Field and Description |
---|---|
protected AsyncWriteQueueRecord |
PushBackContext.queueRecord
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static AsyncWriteQueueRecord |
AsyncWriteQueueRecord.create(Connection connection,
WritableMessage message,
CompletionHandler completionHandler,
Object dstAddress,
PushBackHandler pushbackHandler,
boolean isUncountable) |
Constructor and Description |
---|
PushBackContext(AsyncWriteQueueRecord queueRecord)
Deprecated.
|
Modifier and Type | Field and Description |
---|---|
protected TaskQueue<AsyncWriteQueueRecord> |
NIOConnection.asyncWriteQueue |
Modifier and Type | Method and Description |
---|---|
protected AsyncWriteQueueRecord |
AbstractNIOAsyncQueueWriter.aggregate(TaskQueue<AsyncWriteQueueRecord> connectionQueue)
Aggregates records in a queue to be written as one chunk.
|
protected AsyncWriteQueueRecord |
AbstractNIOAsyncQueueWriter.createRecord(Connection connection,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
SocketAddress dstAddress,
PushBackHandler pushBackHandler,
boolean isUncountable) |
Modifier and Type | Method and Description |
---|---|
TaskQueue<AsyncWriteQueueRecord> |
NIOConnection.getAsyncWriteQueue() |
Modifier and Type | Method and Description |
---|---|
protected static void |
AbstractNIOAsyncQueueWriter.onWriteFailure(Connection connection,
AsyncWriteQueueRecord failedRecord,
Throwable e) |
protected abstract RecordWriteResult |
AbstractNIOAsyncQueueWriter.write0(NIOConnection connection,
AsyncWriteQueueRecord queueRecord) |
Modifier and Type | Method and Description |
---|---|
protected AsyncWriteQueueRecord |
AbstractNIOAsyncQueueWriter.aggregate(TaskQueue<AsyncWriteQueueRecord> connectionQueue)
Aggregates records in a queue to be written as one chunk.
|
Modifier and Type | Method and Description |
---|---|
protected AsyncWriteQueueRecord |
TCPNIOAsyncQueueWriter.aggregate(TaskQueue<AsyncWriteQueueRecord> writeTaskQueue)
Aggregates records in a queue to be written as one chunk.
|
Modifier and Type | Method and Description |
---|---|
protected RecordWriteResult |
TCPNIOAsyncQueueWriter.write0(NIOConnection connection,
AsyncWriteQueueRecord queueRecord) |
protected RecordWriteResult |
UDPNIOAsyncQueueWriter.write0(NIOConnection connection,
AsyncWriteQueueRecord queueRecord) |
Modifier and Type | Method and Description |
---|---|
protected AsyncWriteQueueRecord |
TCPNIOAsyncQueueWriter.aggregate(TaskQueue<AsyncWriteQueueRecord> writeTaskQueue)
Aggregates records in a queue to be written as one chunk.
|
Copyright © 2015 Oracle Corporation. All rights reserved.