Package | Description |
---|---|
org.glassfish.grizzly.asyncqueue | |
org.glassfish.grizzly.nio | |
org.glassfish.grizzly.nio.transport |
Modifier and Type | Method and Description |
---|---|
static <E extends AsyncQueueRecord> |
TaskQueue.createTaskQueue(TaskQueue.MutableMaxQueueSize maxQueueSizeHolder) |
Modifier and Type | Field and Description |
---|---|
protected TaskQueue<AsyncReadQueueRecord> |
NIOConnection.asyncReadQueue |
protected TaskQueue<AsyncWriteQueueRecord> |
NIOConnection.asyncWriteQueue |
Modifier and Type | Method and Description |
---|---|
TaskQueue<AsyncReadQueueRecord> |
NIOConnection.getAsyncReadQueue() |
TaskQueue<AsyncWriteQueueRecord> |
NIOConnection.getAsyncWriteQueue() |
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.
|
protected static void |
TCPNIOAsyncQueueWriter.offerToTaskQueue(NIOConnection nioConnection,
AsyncWriteQueueRecord queueRecord,
TaskQueue<AsyncWriteQueueRecord> taskQueue) |
Copyright © 2014 Oracle Corporation. All rights reserved.