An EndPoint implementation based on SocketChannel.
| Modifier and Type | Field and Description |
|---|---|
| private static final Logger |
| Access | Constructor and Description |
|---|---|
| public | SocketChannelEndPoint(SocketChannel channel, ManagedSelector selector, SelectionKey key, Scheduler scheduler)
|
| Modifier and Type | Method and Description |
|---|---|
| protected void | |
| public int | fill(ByteBuffer
The buffer to fill. The position and limit are modified during the fill. After the
operation, the position is unchanged and the limit is increased to reflect the new data filled. buffer)Overrides default org. Fill the passed buffer with data from this endpoint. |
| public boolean | flush(ByteBuffer...
the buffers to flush buffers)Overrides default org. Flush data from the passed header/buffer to this endpoint. |
| public SocketChannel | |
| public SocketAddress | getRemoteSocketAddress()
Overrides default org. Implements abstract org.
|
| LOG | back to summary |
|---|---|
| private static final Logger LOG | |
| SocketChannelEndPoint | back to summary |
|---|---|
| public SocketChannelEndPoint(SocketChannel channel, ManagedSelector selector, SelectionKey key, Scheduler scheduler) | |
| doShutdownOutput | back to summary |
|---|---|
| protected void doShutdownOutput() Overrides org.
| |
| fill | back to summary |
|---|---|
| public int fill(ByteBuffer buffer) throws IOException Overrides default org. Doc from org. Fill the passed buffer with data from this endpoint. The bytes are appended to any data already in the buffer by writing from the buffers limit up to it's capacity. The limit is updated to include the filled bytes.
| |
| flush | back to summary |
|---|---|
| public boolean flush(ByteBuffer... buffers) throws IOException Overrides default org. Doc from org. Flush data from the passed header/buffer to this endpoint. As many bytes as can be consumed are taken from the header/buffer position up until the buffer limit. The header/buffers position is updated to indicate how many bytes have been consumed.
| |
| getChannel | back to summary |
|---|---|
| public SocketChannel getChannel() Overrides org.
| |
| getRemoteSocketAddress | back to summary |
|---|---|
| public SocketAddress getRemoteSocketAddress() Overrides default org. Implements abstract org.
| |