Package org.apache.zookeeper
Class ClientCnxnSocketNIO
java.lang.Object
org.apache.zookeeper.ClientCnxnSocketNIO
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected ZKClientConfig
protected ByteBuffer
After the length is read, a new incomingBuffer is allocated in readLength() to receive the full message.protected boolean
protected long
protected long
protected final ByteBuffer
This buffer is only used to read the length of the incoming message.protected long
protected LinkedBlockingDeque
<org.apache.zookeeper.ClientCnxn.Packet> protected final AtomicLong
protected org.apache.zookeeper.ClientCnxn.SendThread
protected final AtomicLong
protected long
The 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
-