public class ClientCnxnSocketNetty extends Object
Modifier and Type | Field and Description |
---|---|
protected ZKClientConfig |
clientConfig |
protected ByteBuffer |
incomingBuffer
After the length is read, a new incomingBuffer is allocated in
readLength() to receive the full message.
|
protected boolean |
initialized |
protected long |
lastHeard |
protected long |
lastSend |
protected ByteBuffer |
lenBuffer
This buffer is only used to read the length of the incoming message.
|
protected long |
now |
protected LinkedBlockingDeque<org.apache.zookeeper.ClientCnxn.Packet> |
outgoingQueue |
protected AtomicLong |
recvCount |
protected org.apache.zookeeper.ClientCnxn.SendThread |
sendThread |
protected AtomicLong |
sentCount |
protected long |
sessionId
The sessionId is only available here for Log and Exception messages.
|
Modifier and Type | Method and Description |
---|---|
protected void |
initProperties() |
protected boolean initialized
protected final ByteBuffer lenBuffer
protected ByteBuffer incomingBuffer
protected final AtomicLong sentCount
protected final AtomicLong recvCount
protected long lastHeard
protected long lastSend
protected long now
protected org.apache.zookeeper.ClientCnxn.SendThread sendThread
protected LinkedBlockingDeque<org.apache.zookeeper.ClientCnxn.Packet> outgoingQueue
protected ZKClientConfig clientConfig
protected long sessionId
protected void initProperties() throws IOException
IOException
Copyright © 2008–2021 The Apache Software Foundation. All rights reserved.