Package org.apache.zookeeper
Class ClientCnxnSocketNIO
java.lang.Object
org.apache.zookeeper.ClientCnxnSocketNIO
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected ZKClientConfigprotected ByteBufferAfter the length is read, a new incomingBuffer is allocated in readLength() to receive the full message.protected booleanprotected longprotected longprotected final ByteBufferThis buffer is only used to read the length of the incoming message.protected longprotected LinkedBlockingDeque<org.apache.zookeeper.ClientCnxn.Packet>protected final AtomicLongprotected org.apache.zookeeper.ClientCnxn.SendThreadprotected final AtomicLongprotected longThe sessionId is only available here for Log and Exception messages. -
Method Summary
-
Field Details
-
initialized
protected boolean initialized -
lenBuffer
This buffer is only used to read the length of the incoming message. -
incomingBuffer
After the length is read, a new incomingBuffer is allocated in readLength() to receive the full message. -
sentCount
-
recvCount
-
lastHeard
protected long lastHeard -
lastSend
protected long lastSend -
now
protected long now -
sendThread
protected org.apache.zookeeper.ClientCnxn.SendThread sendThread -
outgoingQueue
-
clientConfig
-
sessionId
protected long sessionIdThe sessionId is only available here for Log and Exception messages. Otherwise the socket doesn't need to know it.
-
-
Method Details
-
initProperties
- Throws:
IOException
-