org.apache.zookeeper.server
Class NettyServerCnxnFactory

java.lang.Object
  extended by org.apache.zookeeper.server.ServerCnxnFactory
      extended by 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
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
createFactory, createFactory, createFactory, 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


Copyright © 2011 The Apache Software Foundation