Class 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 Detail

      • 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.
      • 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
      • sessionId

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