public class FollowerZooKeeperServer extends LearnerZooKeeperServer
ZooKeeperServer.BasicDataTreeBuilder, ZooKeeperServer.DataTreeBuilder, ZooKeeperServer.MissingSessionException
self
DEFAULT_TICK_TIME, firstProcessor, hzxid, jmxDataTreeBean, jmxServerBean, maxSessionTimeout, minSessionTimeout, ok, running, sessionTracker, tickTime
Modifier and Type | Method and Description |
---|---|
void |
commit(long zxid)
When a COMMIT message is received, eventually this method is called,
which matches up the zxid from the COMMIT with (hopefully) the head of
the pendingTxns queue and hands it to the commitProcessor to commit.
|
Follower |
getFollower() |
int |
getGlobalOutstandingLimit() |
Learner |
getLearner()
Abstract method to return the learner associated with this server.
|
java.lang.String |
getState() |
void |
logRequest(TxnHeader hdr,
org.apache.jute.Record txn) |
protected void |
setupRequestProcessors() |
void |
shutdown() |
void |
sync() |
createSessionTracker, getServerId, getTouchSnapshot, registerJMX, registerJMX, revalidateSession, startSessionTracker, unregisterJMX, unregisterJMX
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, startdata, startup, submitRequest, takeSnapshot, truncateLog
public Follower getFollower()
protected void setupRequestProcessors()
setupRequestProcessors
in class ZooKeeperServer
public void logRequest(TxnHeader hdr, org.apache.jute.Record txn)
public void commit(long zxid)
zxid
- - must correspond to the head of pendingTxns if it existspublic void sync()
public int getGlobalOutstandingLimit()
getGlobalOutstandingLimit
in class ZooKeeperServer
public void shutdown()
shutdown
in class ZooKeeperServer
public java.lang.String getState()
getState
in interface ServerStats.Provider
getState
in class ZooKeeperServer
public Learner getLearner()
LearnerZooKeeperServer
getLearner
in class LearnerZooKeeperServer
Copyright © 2013 The Apache Software Foundation