Package | Description |
---|---|
org.glassfish.grizzly.nio | |
org.glassfish.grizzly.nio.tmpselectors | |
org.glassfish.grizzly.nio.transport |
Modifier and Type | Method and Description |
---|---|
NIOConnection |
DefaultSelectionKeyHandler.getConnectionForKey(SelectionKey selectionKey) |
NIOConnection |
SelectionKeyHandler.getConnectionForKey(SelectionKey selectionKey) |
Modifier and Type | Method and Description |
---|---|
protected void |
NIOTransport.configureNIOConnection(NIOConnection connection) |
protected static void |
NIOConnection.notifyIOEventDisabled(NIOConnection connection,
IOEvent ioEvent)
Notify registered
ConnectionProbe s about the IO Event disabled event. |
protected static void |
NIOConnection.notifyIOEventEnabled(NIOConnection connection,
IOEvent ioEvent)
Notify registered
ConnectionProbe s about the IO Event enabled event. |
protected static void |
NIOConnection.notifyIOEventReady(NIOConnection connection,
IOEvent ioEvent)
Notify registered
ConnectionProbe s about the IO Event ready event. |
protected static void |
NIOConnection.notifyProbesAccept(NIOConnection serverConnection,
NIOConnection clientConnection)
Notify registered
ConnectionProbe s about the accept event. |
protected static void |
NIOConnection.notifyProbesBind(NIOConnection connection)
Notify registered
ConnectionProbe s about the bind event. |
protected static void |
NIOConnection.notifyProbesClose(NIOConnection connection)
Notify registered
ConnectionProbe s about the close event. |
protected static void |
NIOConnection.notifyProbesConnect(NIOConnection connection)
Notify registered
ConnectionProbe s about the connect event. |
protected static void |
NIOConnection.notifyProbesError(NIOConnection connection,
Throwable error)
Notify registered
ConnectionProbe s about the error. |
protected static void |
NIOConnection.notifyProbesRead(NIOConnection connection,
Buffer data,
int size)
Notify registered
ConnectionProbe s about the read event. |
protected static void |
NIOConnection.notifyProbesWrite(NIOConnection connection,
Buffer data,
long size)
Notify registered
ConnectionProbe s about the write event. |
protected abstract void |
AbstractNIOAsyncQueueWriter.onReadyToWrite(NIOConnection connection) |
void |
DefaultSelectionKeyHandler.setConnectionForKey(NIOConnection connection,
SelectionKey selectionKey) |
void |
SelectionKeyHandler.setConnectionForKey(NIOConnection connection,
SelectionKey selectionKey) |
protected abstract RecordWriteResult |
AbstractNIOAsyncQueueWriter.write0(NIOConnection connection,
AsyncWriteQueueRecord queueRecord) |
Modifier and Type | Method and Description |
---|---|
protected int |
TemporarySelectorReader.read0(NIOConnection connection,
ReadResult<Buffer,SocketAddress> currentResult,
Buffer buffer,
long timeout,
TimeUnit timeunit) |
protected abstract int |
TemporarySelectorReader.readNow0(NIOConnection connection,
Buffer buffer,
ReadResult<Buffer,SocketAddress> currentResult) |
protected long |
TemporarySelectorWriter.write0(NIOConnection connection,
SocketAddress dstAddress,
WritableMessage message,
WriteResult<WritableMessage,SocketAddress> currentResult,
long timeout,
TimeUnit timeunit)
Flush the buffer by looping until the
Buffer is empty |
protected abstract long |
TemporarySelectorWriter.writeNow0(NIOConnection connection,
SocketAddress dstAddress,
WritableMessage message,
WriteResult<WritableMessage,SocketAddress> currentResult) |
Modifier and Type | Class and Description |
---|---|
class |
TCPNIOConnection
Connection implementation
for the TCPNIOTransport |
class |
TCPNIOServerConnection |
class |
UDPNIOConnection
Connection implementation
for the UDPNIOTransport |
class |
UDPNIOServerConnection
Server
Connection implementation
for the UDPNIOTransport |
Modifier and Type | Method and Description |
---|---|
protected void |
TCPNIOAsyncQueueWriter.onReadyToWrite(NIOConnection connection) |
protected void |
UDPNIOAsyncQueueWriter.onReadyToWrite(NIOConnection connection) |
protected int |
UDPNIOTemporarySelectorReader.readNow0(NIOConnection connection,
Buffer buffer,
ReadResult<Buffer,SocketAddress> currentResult) |
protected int |
TCPNIOTemporarySelectorReader.readNow0(NIOConnection connection,
Buffer buffer,
ReadResult<Buffer,SocketAddress> currentResult) |
protected RecordWriteResult |
TCPNIOAsyncQueueWriter.write0(NIOConnection connection,
AsyncWriteQueueRecord queueRecord) |
protected RecordWriteResult |
UDPNIOAsyncQueueWriter.write0(NIOConnection connection,
AsyncWriteQueueRecord queueRecord) |
protected long |
TCPNIOAsyncQueueWriter.write0(NIOConnection connection,
WritableMessage message,
WriteResult<WritableMessage,SocketAddress> currentResult) |
protected long |
UDPNIOTemporarySelectorWriter.writeNow0(NIOConnection connection,
SocketAddress dstAddress,
WritableMessage message,
WriteResult<WritableMessage,SocketAddress> currentResult) |
protected long |
TCPNIOTemporarySelectorWriter.writeNow0(NIOConnection connection,
SocketAddress dstAddress,
WritableMessage message,
WriteResult<WritableMessage,SocketAddress> currentResult) |
Copyright © 2015 Oracle Corporation. All rights reserved.