Class NettyServerCnxnFactory

    • Field Detail

      • PORT_UNIFICATION_KEY

        public static final java.lang.String PORT_UNIFICATION_KEY
        Allow client-server sockets to accept both SSL and plaintext connections
        See Also:
        Constant Field Values
      • EARLY_DROP_SECURE_CONNECTION_HANDSHAKES

        public static final java.lang.String EARLY_DROP_SECURE_CONNECTION_HANDSHAKES
        See Also:
        Constant Field Values
      • OUTSTANDING_HANDSHAKE_LIMIT

        public static final java.lang.String OUTSTANDING_HANDSHAKE_LIMIT
        See Also:
        Constant Field Values
      • NETTY_ADVANCED_FLOW_CONTROL

        public static final java.lang.String NETTY_ADVANCED_FLOW_CONTROL
        See Also:
        Constant Field Values
    • Method Detail

      • setOutstandingHandshakeLimit

        public void setOutstandingHandshakeLimit​(int limit)
      • configure

        public void configure​(java.net.InetSocketAddress addr,
                              int maxClientCnxns,
                              int backlog,
                              boolean secure)
                       throws java.io.IOException
        Specified by:
        configure in class ServerCnxnFactory
        Throws:
        java.io.IOException
      • setMaxClientCnxnsPerHost

        public void setMaxClientCnxnsPerHost​(int max)
        Maximum number of connections allowed from particular host (ip)
        Specified by:
        setMaxClientCnxnsPerHost in class ServerCnxnFactory
      • join

        public void join()
                  throws java.lang.InterruptedException
        Specified by:
        join in class ServerCnxnFactory
        Throws:
        java.lang.InterruptedException
      • startup

        public void startup​(ZooKeeperServer zks,
                            boolean startServer)
                     throws java.io.IOException,
                            java.lang.InterruptedException
        Specified by:
        startup in class ServerCnxnFactory
        Throws:
        java.io.IOException
        java.lang.InterruptedException
      • getAllConnectionInfo

        public java.lang.Iterable<java.util.Map<java.lang.String,​java.lang.Object>> getAllConnectionInfo​(boolean brief)
        Specified by:
        getAllConnectionInfo in class ServerCnxnFactory
      • setAdvancedFlowControlEnabled

        public void setAdvancedFlowControlEnabled​(boolean advancedFlowControlEnabled)
      • setSecure

        public void setSecure​(boolean secure)
      • getParentChannel

        public io.netty.channel.Channel getParentChannel()
      • getOutstandingHandshakeNum

        public int getOutstandingHandshakeNum()