org.apache.zookeeper.server.quorum

Class ReadOnlyZooKeeperServer

java.lang.Object

org.apache.zookeeper.server.ZooKeeperServer

org.apache.zookeeper.server.quorum.ReadOnlyZooKeeperServer

All Implemented Interfaces:

ServerStats.Provider, SessionTracker.SessionExpirer

public class ReadOnlyZooKeeperServer
extends ZooKeeperServer

A ZooKeeperServer which comes into play when peer is partitioned from the majority. Handles read-only clients, but drops connections from not-read-only ones.

The very first processor in the chain of request processors is a ReadOnlyRequestProcessor which drops state-changing requests.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.zookeeper.server.ZooKeeperServer

ZooKeeperServer.MissingSessionException, ZooKeeperServer.State

Field Summary

Fields

Modifier and Type	Field and Description
protected QuorumPeer	self

Fields inherited from class org.apache.zookeeper.server.ZooKeeperServer

DEFAULT_TICK_TIME, firstProcessor, jmxDataTreeBean, jmxServerBean, LOG, maxSessionTimeout, minSessionTimeout, ok, secureServerCnxnFactory, serverCnxnFactory, sessionTracker, state, tickTime

Method Summary

Modifier and Type	Method and Description
void	dumpConf(PrintWriter pwriter)
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(ZooKeeperServerBean serverBean, LocalPeerBean localPeerBean)
protected void	setState(ZooKeeperServer.State state) Sets the state of ZooKeeper server.
protected void	setupRequestProcessors()
void	shutdown()
void	startup()
protected void	unregisterJMX()
protected void	unregisterJMX(ZooKeeperServer zks)

Methods inherited from class org.apache.zookeeper.server.ZooKeeperServer

canShutdown, checkPasswd, closeSession, closeSession, createSessionTracker, decInProcess, dumpEphemerals, expire, finishSessionInit, getClientPort, getConf, getDataDirSize, getEphemerals, getGlobalOutstandingLimit, getInProcess, getLastProcessedZxid, getLogDirSize, getMaxClientCnxnsPerHost, getMaxSessionTimeout, getMinSessionTimeout, getNumAliveConnections, getOutstandingRequests, getSecureClientPort, getSecureServerCnxnFactory, getServerCnxnFactory, getSessionExpiryMap, getSessionTracker, getSnapCount, getTickTime, getTxnLogElapsedSyncTime, getTxnLogFactory, getZKDatabase, getZooKeeperServerListener, getZxid, incInProcess, isRunning, killSession, loadData, processConnectRequest, processPacket, processTxn, processTxn, reopenSession, revalidateSession, serverStats, setCreateSessionTrackerServerId, setLocalSessionFlag, setMaxSessionTimeout, setMinSessionTimeout, setOwner, setSecureServerCnxnFactory, setServerCnxnFactory, setTickTime, setTxnLogFactory, setZKDatabase, setZxid, shouldThrottle, shutdown, startdata, startSessionTracker, submitRequest, takeSnapshot, truncateLog

Methods inherited from class java.lang.Object

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

Field Detail

self

protected final QuorumPeer self

Method Detail

setupRequestProcessors

protected void setupRequestProcessors()

Overrides:

setupRequestProcessors in class ZooKeeperServer

startup

public void startup()

Overrides:

startup in class ZooKeeperServer

registerJMX

protected void registerJMX()

Overrides:

registerJMX in class ZooKeeperServer

registerJMX

public void registerJMX(ZooKeeperServerBean serverBean,
                        LocalPeerBean localPeerBean)

unregisterJMX

protected void unregisterJMX()

Overrides:

unregisterJMX in class ZooKeeperServer

unregisterJMX

protected void unregisterJMX(ZooKeeperServer zks)

getState

public String getState()

Specified by:

getState in interface ServerStats.Provider

Overrides:

getState in class ZooKeeperServer

getServerId

public long getServerId()

Returns the id of the associated QuorumPeer, which will do for a unique id of this server.

Specified by:

getServerId in interface SessionTracker.SessionExpirer

Overrides:

getServerId in class ZooKeeperServer

shutdown

public void shutdown()

Overrides:

shutdown in class ZooKeeperServer

dumpConf

public void dumpConf(PrintWriter pwriter)

Overrides:

dumpConf in class ZooKeeperServer

setState

protected void setState(ZooKeeperServer.State state)

Description copied from class: ZooKeeperServer

Sets the state of ZooKeeper server. After changing the state, it notifies the server state change to a registered shutdown handler, if any.

The following are the server state transitions:

During startup the server will be in the INITIAL state. After successfully starting, the server sets the state to RUNNING. The server transitions to the ERROR state if it hits an internal error. ZooKeeperServerListenerImpl notifies any critical resource error events, e.g., SyncRequestProcessor not being able to write a txn to disk. During shutdown the server sets the state to SHUTDOWN, which corresponds to the server not running.

Overrides:

setState in class ZooKeeperServer

Parameters:

state - new server state.