Package org.apache.zookeeper
Class ClientCnxnSocketNetty
- java.lang.Object
- 
- org.apache.zookeeper.ClientCnxnSocketNetty
 
- 
 public class ClientCnxnSocketNetty extends Object ClientCnxnSocketNetty implements ClientCnxnSocket abstract methods. It's responsible for connecting to server, reading/writing network traffic and being a layer between network data and higher level packets.
- 
- 
Field SummaryFields Modifier and Type Field Description protected ZKClientConfigclientConfigprotected ByteBufferincomingBufferAfter the length is read, a new incomingBuffer is allocated in readLength() to receive the full message.protected booleaninitializedprotected longlastHeardprotected longlastSendprotected ByteBufferlenBufferThis buffer is only used to read the length of the incoming message.protected longnowprotected LinkedBlockingDeque<org.apache.zookeeper.ClientCnxn.Packet>outgoingQueueprotected AtomicLongrecvCountprotected org.apache.zookeeper.ClientCnxn.SendThreadsendThreadprotected AtomicLongsentCountprotected longsessionIdThe sessionId is only available here for Log and Exception messages.
 - 
Method SummaryAll Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidinitProperties()
 
- 
- 
- 
Field Detail- 
initializedprotected boolean initialized 
 - 
lenBufferprotected final ByteBuffer lenBuffer This buffer is only used to read the length of the incoming message.
 - 
incomingBufferprotected ByteBuffer incomingBuffer After the length is read, a new incomingBuffer is allocated in readLength() to receive the full message.
 - 
sentCountprotected final AtomicLong sentCount 
 - 
recvCountprotected final AtomicLong recvCount 
 - 
lastHeardprotected long lastHeard 
 - 
lastSendprotected long lastSend 
 - 
nowprotected long now 
 - 
sendThreadprotected org.apache.zookeeper.ClientCnxn.SendThread sendThread 
 - 
outgoingQueueprotected LinkedBlockingDeque<org.apache.zookeeper.ClientCnxn.Packet> outgoingQueue 
 - 
clientConfigprotected ZKClientConfig clientConfig 
 - 
sessionIdprotected long sessionId The sessionId is only available here for Log and Exception messages. Otherwise the socket doesn't need to know it.
 
- 
 - 
Method Detail- 
initPropertiesprotected void initProperties() throws IOException- Throws:
- IOException
 
 
- 
 
-