Class ClientCnxnSocketNIO

java.lang.Object
org.apache.zookeeper.ClientCnxnSocketNIO

public class ClientCnxnSocketNIO extends Object
  • Field Details

    • initialized

      protected boolean initialized
    • lenBuffer

      protected final ByteBuffer lenBuffer
      This buffer is only used to read the length of the incoming message.
    • incomingBuffer

      protected ByteBuffer incomingBuffer
      After the length is read, a new incomingBuffer is allocated in readLength() to receive the full message.
    • sentCount

      protected final AtomicLong sentCount
    • recvCount

      protected final AtomicLong recvCount
    • lastHeard

      protected long lastHeard
    • lastSend

      protected long lastSend
    • now

      protected long now
    • sendThread

      protected org.apache.zookeeper.ClientCnxn.SendThread sendThread
    • outgoingQueue

      protected LinkedBlockingDeque<org.apache.zookeeper.ClientCnxn.Packet> outgoingQueue
    • clientConfig

      protected ZKClientConfig clientConfig
    • sessionId

      protected long sessionId
      The sessionId is only available here for Log and Exception messages. Otherwise the socket doesn't need to know it.
  • Method Details