public abstract class LearnerZooKeeperServer extends QuorumZooKeeperServer
ZooKeeperServer.BasicDataTreeBuilder, ZooKeeperServer.DataTreeBuilder, ZooKeeperServer.MissingSessionException
self
DEFAULT_TICK_TIME, firstProcessor, hzxid, jmxDataTreeBean, jmxServerBean, LOG, maxSessionTimeout, minSessionTimeout, ok, running, sessionTracker, tickTime
Constructor and Description |
---|
LearnerZooKeeperServer(FileTxnSnapLog logFactory,
int tickTime,
int minSessionTimeout,
int maxSessionTimeout,
ZooKeeperServer.DataTreeBuilder treeBuilder,
ZKDatabase zkDb,
QuorumPeer self) |
Modifier and Type | Method and Description |
---|---|
void |
createSessionTracker() |
abstract Learner |
getLearner()
Abstract method to return the learner associated with this server.
|
long |
getServerId()
Returns the id of the associated QuorumPeer, which will do for a unique
id of this server.
|
protected java.util.HashMap<java.lang.Long,java.lang.Integer> |
getTouchSnapshot()
Returns the current state of the session tracker.
|
protected void |
registerJMX() |
void |
registerJMX(ZooKeeperServerBean serverBean,
LocalPeerBean localPeerBean) |
protected void |
revalidateSession(ServerCnxn cnxn,
long sessionId,
int sessionTimeout) |
protected void |
startSessionTracker() |
protected void |
unregisterJMX() |
protected void |
unregisterJMX(Learner peer) |
dumpConf
checkPasswd, closeSession, closeSession, decInProcess, dumpEphemerals, expire, finishSessionInit, getClientPort, getGlobalOutstandingLimit, getInProcess, getLastProcessedZxid, getMaxSessionTimeout, getMinSessionTimeout, getNumAliveConnections, getOutstandingRequests, getServerCnxnFactory, getSnapCount, getState, getTickTime, getTxnLogFactory, getZKDatabase, getZxid, incInProcess, isRunning, killSession, loadData, processConnectRequest, processPacket, processTxn, reopenSession, serverStats, setMaxSessionTimeout, setMinSessionTimeout, setOwner, setServerCnxnFactory, setTickTime, setTxnLogFactory, setupRequestProcessors, setZKDatabase, setZxid, shouldThrottle, shutdown, startdata, startup, submitRequest, takeSnapshot, truncateLog
public LearnerZooKeeperServer(FileTxnSnapLog logFactory, int tickTime, int minSessionTimeout, int maxSessionTimeout, ZooKeeperServer.DataTreeBuilder treeBuilder, ZKDatabase zkDb, QuorumPeer self) throws java.io.IOException
java.io.IOException
public abstract Learner getLearner()
protected java.util.HashMap<java.lang.Long,java.lang.Integer> getTouchSnapshot()
public long getServerId()
getServerId
in interface SessionTracker.SessionExpirer
getServerId
in class ZooKeeperServer
public void createSessionTracker()
createSessionTracker
in class ZooKeeperServer
protected void startSessionTracker()
startSessionTracker
in class ZooKeeperServer
protected void revalidateSession(ServerCnxn cnxn, long sessionId, int sessionTimeout) throws java.io.IOException
revalidateSession
in class ZooKeeperServer
java.io.IOException
protected void registerJMX()
registerJMX
in class ZooKeeperServer
public void registerJMX(ZooKeeperServerBean serverBean, LocalPeerBean localPeerBean)
protected void unregisterJMX()
unregisterJMX
in class ZooKeeperServer
protected void unregisterJMX(Learner peer)
Copyright © 2013 The Apache Software Foundation