org.apache.zookeeper.server
Class NettyServerCnxnFactory

java.lang.Object
  org.apache.zookeeper.server.ServerCnxnFactory
      org.apache.zookeeper.server.NettyServerCnxnFactory

public class NettyServerCnxnFactory
extends ServerCnxnFactory

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.zookeeper.server.ServerCnxnFactory

ServerCnxnFactory.PacketProcessor

Field Summary

Fields inherited from class org.apache.zookeeper.server.ServerCnxnFactory

cnxns, login, saslServerCallbackHandler, zkServer, ZOOKEEPER_SERVER_CNXN_FACTORY

Method Summary

void	closeAll()
void	closeSession(long sessionId)
void	configure(InetSocketAddress addr, int maxClientCnxns)
Iterable<ServerCnxn>	getConnections()
InetSocketAddress	getLocalAddress()
int	getLocalPort()
int	getMaxClientCnxnsPerHost() Maximum number of connections allowed from particular host (ip)
void	join()
void	setMaxClientCnxnsPerHost(int max) Maximum number of connections allowed from particular host (ip)
void	shutdown()
void	start()
void	startup(ZooKeeperServer zks)

Methods inherited from class org.apache.zookeeper.server.ServerCnxnFactory

configureSaslLogin, createFactory, createFactory, createFactory, getNumAliveConnections, registerConnection, setZooKeeperServer, unregisterConnection

Methods inherited from class java.lang.Object

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

Method Detail

closeAll

public void closeAll()

Specified by:

closeAll in class ServerCnxnFactory

closeSession

public void closeSession(long sessionId)

Specified by:

closeSession in class ServerCnxnFactory

configure

public void configure(InetSocketAddress addr,
                      int maxClientCnxns)
               throws IOException

Specified by:

configure in class ServerCnxnFactory

Throws:

IOException

getMaxClientCnxnsPerHost

public int getMaxClientCnxnsPerHost()

Maximum number of connections allowed from particular host (ip)

Specified by:

getMaxClientCnxnsPerHost in class ServerCnxnFactory

setMaxClientCnxnsPerHost

public void setMaxClientCnxnsPerHost(int max)

Maximum number of connections allowed from particular host (ip)

Specified by:

setMaxClientCnxnsPerHost in class ServerCnxnFactory

getLocalPort

public int getLocalPort()

Specified by:

getLocalPort in class ServerCnxnFactory

join

public void join()
          throws InterruptedException

Specified by:

join in class ServerCnxnFactory

Throws:

InterruptedException

shutdown

public void shutdown()

Specified by:

shutdown in class ServerCnxnFactory

start

public void start()

Specified by:

start in class ServerCnxnFactory

startup

public void startup(ZooKeeperServer zks)
             throws IOException,
                    InterruptedException

Specified by:

startup in class ServerCnxnFactory

Throws:

IOException

InterruptedException

getConnections

public Iterable<ServerCnxn> getConnections()

Specified by:

getConnections in class ServerCnxnFactory

getLocalAddress

public InetSocketAddress getLocalAddress()

Specified by:

getLocalAddress in class ServerCnxnFactory