public class LeaderZooKeeperServer extends QuorumZooKeeperServer
ZooKeeperServer.BasicDataTreeBuilder, ZooKeeperServer.DataTreeBuilder, ZooKeeperServer.MissingSessionException
self
DEFAULT_TICK_TIME, firstProcessor, hzxid, jmxDataTreeBean, jmxServerBean, LOG, maxSessionTimeout, minSessionTimeout, ok, running, sessionTracker, tickTime
Modifier and Type | Method and Description |
---|---|
void |
createSessionTracker() |
int |
getGlobalOutstandingLimit() |
Leader |
getLeader() |
long |
getServerId()
Returns the id of the associated QuorumPeer, which will do for a unique
id of this server.
|
String |
getState() |
protected void |
registerJMX() |
void |
registerJMX(LeaderBean leaderBean,
LocalPeerBean localPeerBean) |
protected void |
revalidateSession(ServerCnxn cnxn,
long sessionId,
int sessionTimeout) |
protected void |
setupRequestProcessors() |
protected void |
startSessionTracker() |
boolean |
touch(long sess,
int to) |
protected void |
unregisterJMX() |
protected void |
unregisterJMX(Leader leader) |
dumpConf
checkPasswd, closeSession, closeSession, decInProcess, dumpEphemerals, expire, finishSessionInit, getClientPort, getInProcess, getLastProcessedZxid, getMaxSessionTimeout, getMinSessionTimeout, getNumAliveConnections, getOutstandingRequests, getServerCnxnFactory, getSnapCount, getTickTime, getTxnLogFactory, getZKDatabase, getZxid, incInProcess, isRunning, killSession, loadData, processConnectRequest, processPacket, processTxn, reopenSession, serverStats, setMaxSessionTimeout, setMinSessionTimeout, setOwner, setServerCnxnFactory, setTickTime, setTxnLogFactory, setZKDatabase, setZxid, shouldThrottle, shutdown, startdata, startup, submitRequest, takeSnapshot, truncateLog
public Leader getLeader()
protected void setupRequestProcessors()
setupRequestProcessors
in class ZooKeeperServer
public int getGlobalOutstandingLimit()
getGlobalOutstandingLimit
in class ZooKeeperServer
public void createSessionTracker()
createSessionTracker
in class ZooKeeperServer
protected void startSessionTracker()
startSessionTracker
in class ZooKeeperServer
public boolean touch(long sess, int to)
protected void registerJMX()
registerJMX
in class ZooKeeperServer
public void registerJMX(LeaderBean leaderBean, LocalPeerBean localPeerBean)
protected void unregisterJMX()
unregisterJMX
in class ZooKeeperServer
protected void unregisterJMX(Leader leader)
public String getState()
getState
in interface ServerStats.Provider
getState
in class ZooKeeperServer
public long getServerId()
getServerId
in interface SessionTracker.SessionExpirer
getServerId
in class ZooKeeperServer
protected void revalidateSession(ServerCnxn cnxn, long sessionId, int sessionTimeout) throws IOException
revalidateSession
in class ZooKeeperServer
IOException
Copyright © 2014 The Apache Software Foundation