public class NettyServerCnxnFactory extends ServerCnxnFactory
ServerCnxnFactory.PacketProcessor
cnxns, login, saslServerCallbackHandler, sessionMap, zkServer, ZOOKEEPER_SERVER_CNXN_FACTORY
Modifier and Type | Method | Description |
---|---|---|
void |
closeAll() |
|
void |
closeSession(long sessionId) |
|
void |
configure(java.net.InetSocketAddress addr,
int maxClientCnxns) |
|
java.lang.Iterable<ServerCnxn> |
getConnections() |
|
java.net.InetSocketAddress |
getLocalAddress() |
|
int |
getLocalPort() |
|
int |
getMaxClientCnxnsPerHost() |
Maximum number of connections allowed from particular host (ip)
|
void |
join() |
|
void |
removeCnxn(ServerCnxn cnxn) |
|
void |
setMaxClientCnxnsPerHost(int max) |
Maximum number of connections allowed from particular host (ip)
|
void |
shutdown() |
|
void |
start() |
|
void |
startup(ZooKeeperServer zks) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addSession, configureSaslLogin, createFactory, createFactory, createFactory, getNumAliveConnections, registerConnection, setZooKeeperServer, unregisterConnection
public void closeAll()
closeAll
in class ServerCnxnFactory
public void closeSession(long sessionId)
closeSession
in class ServerCnxnFactory
public void configure(java.net.InetSocketAddress addr, int maxClientCnxns) throws java.io.IOException
configure
in class ServerCnxnFactory
java.io.IOException
public int getMaxClientCnxnsPerHost()
getMaxClientCnxnsPerHost
in class ServerCnxnFactory
public void setMaxClientCnxnsPerHost(int max)
setMaxClientCnxnsPerHost
in class ServerCnxnFactory
public int getLocalPort()
getLocalPort
in class ServerCnxnFactory
public void join() throws java.lang.InterruptedException
join
in class ServerCnxnFactory
java.lang.InterruptedException
public void shutdown()
shutdown
in class ServerCnxnFactory
public void start()
start
in class ServerCnxnFactory
public void startup(ZooKeeperServer zks) throws java.io.IOException, java.lang.InterruptedException
startup
in class ServerCnxnFactory
java.io.IOException
java.lang.InterruptedException
public java.lang.Iterable<ServerCnxn> getConnections()
getConnections
in class ServerCnxnFactory
public java.net.InetSocketAddress getLocalAddress()
getLocalAddress
in class ServerCnxnFactory
public void removeCnxn(ServerCnxn cnxn)
Copyright © 2018 The Apache Software Foundation