private static class NioTcpClient.ChannelState extends java.lang.Object implements NioClient.KeyProcessor
| Modifier and Type | Field and Description |
|---|---|
(package private) java.nio.channels.SocketChannel |
channel |
(package private) java.util.Queue<NioTcpClient.Transaction> |
pendingTransactions |
(package private) int |
readState |
(package private) java.nio.ByteBuffer |
responseData |
(package private) java.nio.ByteBuffer |
responseLengthData |
| Modifier | Constructor and Description |
|---|---|
private |
ChannelState() |
| Modifier and Type | Method and Description |
|---|---|
private void |
handleChannelException(java.io.IOException e) |
(package private) void |
handleTransactionException(java.io.IOException e) |
private void |
processConnect(java.nio.channels.SelectionKey key) |
private void |
processRead() |
void |
processReadyKey(java.nio.channels.SelectionKey key) |
private void |
processWrite(java.nio.channels.SelectionKey key) |
final java.nio.channels.SocketChannel channel
final java.util.Queue<NioTcpClient.Transaction> pendingTransactions
java.nio.ByteBuffer responseLengthData
java.nio.ByteBuffer responseData
int readState
public void processReadyKey(java.nio.channels.SelectionKey key)
processReadyKey in interface NioClient.KeyProcessorvoid handleTransactionException(java.io.IOException e)
private void handleChannelException(java.io.IOException e)
private void processConnect(java.nio.channels.SelectionKey key)
private void processRead()
private void processWrite(java.nio.channels.SelectionKey key)