Package org.apache.zookeeper.server

Class ServerCnxnFactory

java.lang.Object

org.apache.zookeeper.server.ServerCnxnFactory

Direct Known Subclasses:

NettyServerCnxnFactory, NIOServerCnxnFactory

public abstract class ServerCnxnFactory
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ServerCnxnFactory.PacketProcessor

Field Summary

Fields

Modifier and Type	Field	Description
protected java.util.HashSet<ServerCnxn>	cnxns
Login	login
protected SaslServerCallbackHandler	saslServerCallbackHandler
protected java.util.concurrent.ConcurrentMap<java.lang.Long,ServerCnxn>	sessionMap
protected ZooKeeperServer	zkServer
static java.lang.String	ZOOKEEPER_SERVER_CNXN_FACTORY

Constructor Summary

Constructors

Constructor	Description
ServerCnxnFactory()

Method Summary

Modifier and Type	Method	Description
void	addSession(long sessionId, ServerCnxn cnxn)
abstract void	closeAll()
abstract void	closeSession(long sessionId)
abstract void	configure(java.net.InetSocketAddress addr, int maxClientCnxns)
protected void	configureSaslLogin()	Initialize the server SASL if specified.
static ServerCnxnFactory	createFactory()
static ServerCnxnFactory	createFactory(int clientPort, int maxClientCnxns)
static ServerCnxnFactory	createFactory(java.net.InetSocketAddress addr, int maxClientCnxns)
abstract java.lang.Iterable<ServerCnxn>	getConnections()
abstract java.net.InetSocketAddress	getLocalAddress()
abstract int	getLocalPort()
abstract int	getMaxClientCnxnsPerHost()	Maximum number of connections allowed from particular host (ip)
int	getNumAliveConnections()
abstract void	join()
void	registerConnection(ServerCnxn serverCnxn)
abstract void	setMaxClientCnxnsPerHost(int max)	Maximum number of connections allowed from particular host (ip)
void	setZooKeeperServer(ZooKeeperServer zk)
abstract void	shutdown()
abstract void	start()
abstract void	startup(ZooKeeperServer zkServer)
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 java.lang.String ZOOKEEPER_SERVER_CNXN_FACTORY

See Also:

Constant Field Values

sessionMap

protected final java.util.concurrent.ConcurrentMap<java.lang.Long,ServerCnxn> sessionMap

saslServerCallbackHandler

protected SaslServerCallbackHandler saslServerCallbackHandler

login

public Login login

zkServer

protected ZooKeeperServer zkServer

cnxns

protected final java.util.HashSet<ServerCnxn> cnxns

Constructor Detail

ServerCnxnFactory

public ServerCnxnFactory()

Method Detail

getLocalPort

public abstract int getLocalPort()

getConnections

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

getNumAliveConnections

public int getNumAliveConnections()

closeSession

public abstract void closeSession(long sessionId)

configure

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

Throws:

java.io.IOException

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)

startup

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

Throws:

java.io.IOException

java.lang.InterruptedException

join

public abstract void join()
                   throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

shutdown

public abstract void shutdown()

start

public abstract void start()

setZooKeeperServer

public final void setZooKeeperServer(ZooKeeperServer zk)

closeAll

public abstract void closeAll()

createFactory

public static ServerCnxnFactory createFactory()
                                       throws java.io.IOException

Throws:

java.io.IOException

createFactory

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

Throws:

java.io.IOException

createFactory

public static ServerCnxnFactory createFactory(java.net.InetSocketAddress addr,
                                              int maxClientCnxns)
                                       throws java.io.IOException

Throws:

java.io.IOException

getLocalAddress

public abstract java.net.InetSocketAddress getLocalAddress()

unregisterConnection

public void unregisterConnection(ServerCnxn serverCnxn)

registerConnection

public void registerConnection(ServerCnxn serverCnxn)

addSession

public void addSession(long sessionId,
                       ServerCnxn cnxn)

configureSaslLogin

protected void configureSaslLogin()
                           throws java.io.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:

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