Package org.apache.zookeeper

Class ClientCnxnSocketNetty

  • public class ClientCnxnSocketNetty
extends java.lang.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 Summary

      Fields 
      Modifier and Type Field Description
      protected ZKClientConfig clientConfig  
      protected java.nio.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 java.nio.ByteBuffer lenBuffer
      This buffer is only used to read the length of the incoming message.
      protected long now  
      protected java.util.concurrent.LinkedBlockingDeque<org.apache.zookeeper.ClientCnxn.Packet> outgoingQueue  
      protected java.util.concurrent.atomic.AtomicLong recvCount  
      protected org.apache.zookeeper.ClientCnxn.SendThread sendThread  
      protected java.util.concurrent.atomic.AtomicLong sentCount  
      protected long sessionId
      The sessionId is only available here for Log and Exception messages.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected void initProperties()  

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Field Detail

      • initialized

        protected boolean initialized

      • lenBuffer

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

      • incomingBuffer

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

      • sentCount

        protected final java.util.concurrent.atomic.AtomicLong sentCount

      • recvCount

        protected final java.util.concurrent.atomic.AtomicLong recvCount

      • lastHeard

        protected long lastHeard

      • lastSend

        protected long lastSend

      • now

        protected long now

      • sendThread

        protected org.apache.zookeeper.ClientCnxn.SendThread sendThread

      • outgoingQueue

        protected java.util.concurrent.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.

    • Method Detail

      • initProperties

        protected void initProperties()
                       throws java.io.IOException
        Throws:
        java.io.IOException