Package org.apache.zookeeper.server

Class NIOServerCnxnFactory

java.lang.Object

org.apache.zookeeper.server.ServerCnxnFactory

org.apache.zookeeper.server.NIOServerCnxnFactory

All Implemented Interfaces:

java.lang.Runnable

public class NIOServerCnxnFactory
extends ServerCnxnFactory
implements java.lang.Runnable

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, sessionMap, zkServer, ZOOKEEPER_SERVER_CNXN_FACTORY

Constructor Summary

Constructors

Constructor	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).

Method Summary

Modifier and Type	Method	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	removeCnxn(NIOServerCnxn cnxn)
void	run()
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

addSession, 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

Constructor Detail

NIOServerCnxnFactory

public NIOServerCnxnFactory()
                     throws java.io.IOException

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). startup(zks) must be called subsequently.

Throws:

java.io.IOException

Method Detail

configure

public void configure(java.net.InetSocketAddress addr,
                      int maxcc)
               throws java.io.IOException

Specified by:

configure in class ServerCnxnFactory

Throws:

java.io.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

start

public void start()

Specified by:

start in class ServerCnxnFactory

startup

public void startup(ZooKeeperServer zks)
             throws java.io.IOException,
                    java.lang.InterruptedException

Specified by:

startup in class ServerCnxnFactory

Throws:

java.io.IOException

java.lang.InterruptedException

getLocalAddress

public java.net.InetSocketAddress getLocalAddress()

Specified by:

getLocalAddress in class ServerCnxnFactory

getLocalPort

public int getLocalPort()

Specified by:

getLocalPort in class ServerCnxnFactory

removeCnxn

public void removeCnxn(NIOServerCnxn cnxn)

createConnection

protected NIOServerCnxn createConnection(java.nio.channels.SocketChannel sock,
                                         java.nio.channels.SelectionKey sk)
                                  throws java.io.IOException

Throws:

java.io.IOException

run

public void run()

Specified by:

run in interface java.lang.Runnable

closeAll

public void closeAll()

clear all the connections in the selector

Specified by:

closeAll in class ServerCnxnFactory

shutdown

public void shutdown()

Specified by:

shutdown in class ServerCnxnFactory

closeSession

public void closeSession(long sessionId)

Specified by:

closeSession in class ServerCnxnFactory

join

public void join()
          throws java.lang.InterruptedException

Specified by:

join in class ServerCnxnFactory

Throws:

java.lang.InterruptedException

getConnections

public java.lang.Iterable<ServerCnxn> getConnections()

Specified by:

getConnections in class ServerCnxnFactory