Package org.apache.zookeeper.server
Class NettyServerCnxnFactory
java.lang.Object
org.apache.zookeeper.server.ServerCnxnFactory
org.apache.zookeeper.server.NettyServerCnxnFactory
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final Stringstatic final Stringstatic final Stringstatic final StringAllow client-server sockets to accept both SSL and plaintext connectionsFields inherited from class org.apache.zookeeper.server.ServerCnxnFactory
cnxns, login, maxCnxns, saslServerCallbackHandler, secure, zkServer, ZOOKEEPER_MAX_CONNECTION_DEFAULT, ZOOKEEPER_SERVER_CNXN_FACTORY -
Method Summary
Modifier and TypeMethodDescriptionvoidcloseAll(ServerCnxn.DisconnectReason reason) voidconfigure(InetSocketAddress addr, int maxClientCnxns, int backlog, boolean secure) getAllConnectionInfo(boolean brief) intintMaximum number of connections allowed from particular host (ip)intio.netty.channel.ChannelintThe maximum queue length of the ZooKeeper server's socketvoidjoin()voidreconfigure(InetSocketAddress addr) voidvoidsetAdvancedFlowControlEnabled(boolean advancedFlowControlEnabled) voidsetMaxClientCnxnsPerHost(int max) Maximum number of connections allowed from particular host (ip)voidsetOutstandingHandshakeLimit(int limit) voidsetSecure(boolean secure) voidshutdown()voidstart()voidstartup(ZooKeeperServer zks, boolean startServer) Methods inherited from class org.apache.zookeeper.server.ServerCnxnFactory
addSession, closeSession, configure, configure, configureSaslLogin, createFactory, createFactory, createFactory, createFactory, createFactory, getMaxCnxns, getNumAliveConnections, getUserName, getZooKeeperServer, initMaxCnxns, isSecure, limitTotalNumberOfCnxns, registerConnection, removeCnxnFromSessionMap, setZooKeeperServer, startup, unregisterConnection
-
Field Details
-
PORT_UNIFICATION_KEY
Allow client-server sockets to accept both SSL and plaintext connections- See Also:
-
EARLY_DROP_SECURE_CONNECTION_HANDSHAKES
- See Also:
-
OUTSTANDING_HANDSHAKE_LIMIT
- See Also:
-
NETTY_ADVANCED_FLOW_CONTROL
- See Also:
-
-
Method Details
-
setOutstandingHandshakeLimit
public void setOutstandingHandshakeLimit(int limit) -
closeAll
- Specified by:
closeAllin classServerCnxnFactory
-
configure
public void configure(InetSocketAddress addr, int maxClientCnxns, int backlog, boolean secure) throws IOException - Specified by:
configurein classServerCnxnFactory- Throws:
IOException
-
getMaxClientCnxnsPerHost
public int getMaxClientCnxnsPerHost()Maximum number of connections allowed from particular host (ip)- Specified by:
getMaxClientCnxnsPerHostin classServerCnxnFactory
-
setMaxClientCnxnsPerHost
public void setMaxClientCnxnsPerHost(int max) Maximum number of connections allowed from particular host (ip)- Specified by:
setMaxClientCnxnsPerHostin classServerCnxnFactory
-
getSocketListenBacklog
public int getSocketListenBacklog()The maximum queue length of the ZooKeeper server's socket- Specified by:
getSocketListenBacklogin classServerCnxnFactory
-
getLocalPort
public int getLocalPort()- Specified by:
getLocalPortin classServerCnxnFactory
-
join
- Specified by:
joinin classServerCnxnFactory- Throws:
InterruptedException
-
shutdown
public void shutdown()- Specified by:
shutdownin classServerCnxnFactory
-
start
public void start()- Specified by:
startin classServerCnxnFactory
-
reconfigure
- Specified by:
reconfigurein classServerCnxnFactory
-
startup
public void startup(ZooKeeperServer zks, boolean startServer) throws IOException, InterruptedException - Specified by:
startupin classServerCnxnFactory- Throws:
IOExceptionInterruptedException
-
getConnections
- Specified by:
getConnectionsin classServerCnxnFactory
-
getLocalAddress
- Specified by:
getLocalAddressin classServerCnxnFactory
-
resetAllConnectionStats
public void resetAllConnectionStats()- Specified by:
resetAllConnectionStatsin classServerCnxnFactory
-
getAllConnectionInfo
- Specified by:
getAllConnectionInfoin classServerCnxnFactory
-
setAdvancedFlowControlEnabled
public void setAdvancedFlowControlEnabled(boolean advancedFlowControlEnabled) -
setSecure
public void setSecure(boolean secure) -
getParentChannel
public io.netty.channel.Channel getParentChannel() -
getOutstandingHandshakeNum
public int getOutstandingHandshakeNum()
-