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.KeyProcessor
void 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)