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,
WriteResult currentResult,
CompletionHandler completionHandler,
Object dstAddress,
PushBackHandler pushbackHandler,
boolean isEmptyRecord) |
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,
WriteResult<WritableMessage,SocketAddress> currentResult,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
SocketAddress dstAddress,
PushBackHandler pushBackHandler,
boolean isEmptyRecord) |
Modifier and Type | Method and Description |
---|---|
TaskQueue<AsyncWriteQueueRecord> |
NIOConnection.getAsyncWriteQueue() |
Modifier and Type | Method and Description |
---|---|
protected static void |
AbstractNIOAsyncQueueWriter.offerToTaskQueue(NIOConnection nioConnection,
AsyncWriteQueueRecord queueRecord,
TaskQueue<AsyncWriteQueueRecord> taskQueue) |
protected static void |
AbstractNIOAsyncQueueWriter.onWriteFailure(Connection connection,
AsyncWriteQueueRecord failedRecord,
Throwable e) |
protected abstract long |
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.
|
protected static void |
AbstractNIOAsyncQueueWriter.offerToTaskQueue(NIOConnection nioConnection,
AsyncWriteQueueRecord queueRecord,
TaskQueue<AsyncWriteQueueRecord> taskQueue) |
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 static void |
TCPNIOAsyncQueueWriter.offerToTaskQueue(NIOConnection nioConnection,
AsyncWriteQueueRecord queueRecord,
TaskQueue<AsyncWriteQueueRecord> taskQueue) |
protected long |
UDPNIOAsyncQueueWriter.write0(NIOConnection connection,
AsyncWriteQueueRecord queueRecord) |
protected long |
TCPNIOAsyncQueueWriter.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.
|
protected static void |
TCPNIOAsyncQueueWriter.offerToTaskQueue(NIOConnection nioConnection,
AsyncWriteQueueRecord queueRecord,
TaskQueue<AsyncWriteQueueRecord> taskQueue) |
Copyright © 2014 Oracle Corporation. All rights reserved.