org.apache.zookeeper.server

Class ServerCnxnFactory

java.lang.Object

org.apache.zookeeper.server.ServerCnxnFactory

Direct Known Subclasses:

NettyServerCnxnFactory, NIOServerCnxnFactory

public abstract class ServerCnxnFactory
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected Set<ServerCnxn>	cnxns
Login	login
protected SaslServerCallbackHandler	saslServerCallbackHandler
protected boolean	secure
protected ZooKeeperServer	zkServer
static String	ZOOKEEPER_SERVER_CNXN_FACTORY

Constructor Summary

Constructors

Constructor and Description
ServerCnxnFactory()

Method Summary

Modifier and Type	Method and Description
abstract void	closeAll()
abstract boolean	closeSession(long sessionId)
void	configure(InetSocketAddress addr, int maxcc)
abstract void	configure(InetSocketAddress addr, int maxcc, boolean secure)
protected void	configureSaslLogin() Initialize the server SASL if specified.
static ServerCnxnFactory	createFactory()
static ServerCnxnFactory	createFactory(InetSocketAddress addr, int maxClientCnxns)
static ServerCnxnFactory	createFactory(int clientPort, int maxClientCnxns)
abstract Iterable<Map<String,Object>>	getAllConnectionInfo(boolean brief)
abstract Iterable<ServerCnxn>	getConnections()
abstract InetSocketAddress	getLocalAddress()
abstract int	getLocalPort()
abstract int	getMaxClientCnxnsPerHost() Maximum number of connections allowed from particular host (ip)
int	getNumAliveConnections()
ZooKeeperServer	getZooKeeperServer()
boolean	isSecure()
abstract void	join()
abstract void	reconfigure(InetSocketAddress addr)
void	registerConnection(ServerCnxn serverCnxn)
abstract void	resetAllConnectionStats()
abstract void	setMaxClientCnxnsPerHost(int max) Maximum number of connections allowed from particular host (ip)
void	setZooKeeperServer(ZooKeeperServer zks)
abstract void	shutdown()
abstract void	start()
void	startup(ZooKeeperServer zkServer)
abstract void	startup(ZooKeeperServer zkServer, boolean startServer)
void	unregisterConnection(ServerCnxn serverCnxn)

Methods inherited from class java.lang.Object

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

Field Detail

ZOOKEEPER_SERVER_CNXN_FACTORY

public static final String ZOOKEEPER_SERVER_CNXN_FACTORY

See Also:

Constant Field Values

secure

protected boolean secure

saslServerCallbackHandler

protected SaslServerCallbackHandler saslServerCallbackHandler

login

public Login login

zkServer

protected ZooKeeperServer zkServer

cnxns

protected final Set<ServerCnxn> cnxns

Constructor Detail

ServerCnxnFactory

public ServerCnxnFactory()

Method Detail

getLocalPort

public abstract int getLocalPort()

getConnections

public abstract Iterable<ServerCnxn> getConnections()

getNumAliveConnections

public int getNumAliveConnections()

getZooKeeperServer

public ZooKeeperServer getZooKeeperServer()

closeSession

public abstract boolean closeSession(long sessionId)

Returns:

true if the cnxn that contains the sessionId exists in this ServerCnxnFactory and it's closed. Otherwise false.

configure

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

Throws:

IOException

configure

public abstract void configure(InetSocketAddress addr,
                               int maxcc,
                               boolean secure)
                        throws IOException

Throws:

IOException

reconfigure

public abstract void reconfigure(InetSocketAddress addr)

getMaxClientCnxnsPerHost

public abstract int getMaxClientCnxnsPerHost()

Maximum number of connections allowed from particular host (ip)

setMaxClientCnxnsPerHost

public abstract void setMaxClientCnxnsPerHost(int max)

Maximum number of connections allowed from particular host (ip)

isSecure

public boolean isSecure()

startup

public void startup(ZooKeeperServer zkServer)
             throws IOException,
                    InterruptedException

Throws:

IOException

InterruptedException

startup

public abstract void startup(ZooKeeperServer zkServer,
                             boolean startServer)
                      throws IOException,
                             InterruptedException

Throws:

IOException

InterruptedException

join

public abstract void join()
                   throws InterruptedException

Throws:

InterruptedException

shutdown

public abstract void shutdown()

start

public abstract void start()

setZooKeeperServer

public final void setZooKeeperServer(ZooKeeperServer zks)

closeAll

public abstract void closeAll()

createFactory

public static ServerCnxnFactory createFactory()
                                       throws IOException

Throws:

IOException

createFactory

public static ServerCnxnFactory createFactory(int clientPort,
                                              int maxClientCnxns)
                                       throws IOException

Throws:

IOException

createFactory

public static ServerCnxnFactory createFactory(InetSocketAddress addr,
                                              int maxClientCnxns)
                                       throws IOException

Throws:

IOException

getLocalAddress

public abstract InetSocketAddress getLocalAddress()

resetAllConnectionStats

public abstract void resetAllConnectionStats()

getAllConnectionInfo

public abstract Iterable<Map<String,Object>> getAllConnectionInfo(boolean brief)

unregisterConnection

public void unregisterConnection(ServerCnxn serverCnxn)

registerConnection

public void registerConnection(ServerCnxn serverCnxn)

configureSaslLogin

protected void configureSaslLogin()
                           throws IOException

Initialize the server SASL if specified. If the user has specified a "ZooKeeperServer.LOGIN_CONTEXT_NAME_KEY" or a jaas.conf using "java.security.auth.login.config" the authentication is required and an exception is raised. Otherwise no authentication is configured and no exception is raised.

Throws:

IOException - if jaas.conf is missing or there's an error in it.