public class NIOServerCnxnFactory extends ServerCnxnFactory implements java.lang.Runnable
ServerCnxnFactory.PacketProcessor
cnxns, login, saslServerCallbackHandler, zkServer, ZOOKEEPER_SERVER_CNXN_FACTORY
Constructor and Description |
---|
NIOServerCnxnFactory()
Construct a new server connection factory which will accept an unlimited number
of concurrent connections from each client (up to the file descriptor
limits of the operating system).
|
Modifier and Type | Method and Description |
---|---|
void |
closeAll()
clear all the connections in the selector
|
void |
closeSession(long sessionId) |
void |
configure(java.net.InetSocketAddress addr,
int maxcc) |
protected NIOServerCnxn |
createConnection(java.nio.channels.SocketChannel sock,
java.nio.channels.SelectionKey sk) |
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 |
run() |
void |
setMaxClientCnxnsPerHost(int max)
Maximum number of connections allowed from particular host (ip)
|
void |
shutdown() |
void |
start() |
void |
startup(ZooKeeperServer zks) |
configureSaslLogin, createFactory, createFactory, createFactory, getNumAliveConnections, registerConnection, setZooKeeperServer, unregisterConnection
public NIOServerCnxnFactory() throws java.io.IOException
java.io.IOException
public void configure(java.net.InetSocketAddress addr, int maxcc) 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 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.net.InetSocketAddress getLocalAddress()
getLocalAddress
in class ServerCnxnFactory
public int getLocalPort()
getLocalPort
in class ServerCnxnFactory
protected NIOServerCnxn createConnection(java.nio.channels.SocketChannel sock, java.nio.channels.SelectionKey sk) throws java.io.IOException
java.io.IOException
public void run()
run
in interface java.lang.Runnable
public void closeAll()
closeAll
in class ServerCnxnFactory
public void shutdown()
shutdown
in class ServerCnxnFactory
public void closeSession(long sessionId)
closeSession
in class ServerCnxnFactory
public void join() throws java.lang.InterruptedException
join
in class ServerCnxnFactory
java.lang.InterruptedException
public java.lang.Iterable<ServerCnxn> getConnections()
getConnections
in class ServerCnxnFactory
Copyright © 2018 The Apache Software Foundation