Package | Description |
---|---|
org.apache.zookeeper.audit | |
org.apache.zookeeper.server |
ZooKeeper server theory of operation
ZooKeeperServer is designed to work in standalone mode and also
be extensible so that it can be used to implement the quorum based
version of ZooKeeper.
|
org.apache.zookeeper.server.persistence | |
org.apache.zookeeper.server.quorum | |
org.apache.zookeeper.server.util |
Modifier and Type | Method and Description |
---|---|
static void |
AuditHelper.addAuditLog(Request request,
DataTree.ProcessTxnResult rc) |
static void |
AuditHelper.addAuditLog(Request request,
DataTree.ProcessTxnResult txnResult,
boolean failedTxn)
Add audit log if audit log is enabled and operation is of type which to be audit logged.
|
Modifier and Type | Field and Description |
---|---|
static Request |
Request.requestOfDeath |
Modifier and Type | Method and Description |
---|---|
void |
ZKDatabase.addCommittedProposal(Request request)
maintains a list of last committedLog
or so committed requests.
|
boolean |
ZKDatabase.append(Request si)
append to the underlying transaction log
|
boolean |
ZooKeeperServer.authWriteRequest(Request request)
Check Write Requests for Potential Access Restrictions
Before a request is being proposed to the quorum, lets check it
against local ACLs.
|
void |
ZooKeeperServer.enqueueRequest(Request si) |
static void |
ZooTrace.logRequest(org.slf4j.Logger log,
long mask,
char rp,
Request request,
String header) |
protected void |
ContainerManager.postDeleteRequest(Request request) |
protected void |
PrepRequestProcessor.pRequest(Request request)
This method will be called inside the ProcessRequestThread, which is a
singleton, so there will be a single thread calling this code.
|
protected void |
PrepRequestProcessor.pRequest2Txn(int type,
long zxid,
Request request,
Record record,
boolean deserialize)
This method will be called inside the ProcessRequestThread, which is a
singleton, so there will be a single thread calling this code.
|
void |
PrepRequestProcessor.processRequest(Request request) |
void |
UnimplementedRequestProcessor.processRequest(Request request) |
void |
SyncRequestProcessor.processRequest(Request request) |
void |
FinalRequestProcessor.processRequest(Request request) |
void |
RequestProcessor.processRequest(Request request) |
DataTree.ProcessTxnResult |
ZooKeeperServer.processTxn(Request request) |
void |
ZooKeeperServer.requestFinished(Request request) |
protected void |
ZooKeeperServer.setLocalSessionFlag(Request si)
If the underlying Zookeeper server support local session, this method
will set a isLocalSession to true if a request is associated with
a local session.
|
void |
RequestThrottler.submitRequest(Request request) |
void |
ZooKeeperServer.submitRequest(Request si) |
void |
ZooKeeperServer.submitRequestNow(Request si) |
void |
ServerStats.updateLatency(Request request,
long currentTime)
Update request statistic.
|
Modifier and Type | Method and Description |
---|---|
boolean |
FileTxnSnapLog.append(Request si)
append the request to the transaction logs
|
Modifier and Type | Class and Description |
---|---|
class |
LearnerSyncRequest |
Modifier and Type | Field and Description |
---|---|
Request |
Leader.Proposal.request |
Modifier and Type | Field and Description |
---|---|
protected LinkedBlockingQueue<Request> |
CommitProcessor.committedRequests
Requests that have been committed.
|
protected Map<Long,Deque<Request>> |
CommitProcessor.pendingRequests
Requests that we are holding until commit comes in.
|
protected LinkedBlockingQueue<Request> |
CommitProcessor.queuedRequests
Incoming requests.
|
protected LinkedBlockingQueue<Request> |
CommitProcessor.queuedWriteRequests
Incoming requests that are waiting on a commit,
contained in order of arrival
|
Modifier and Type | Method and Description |
---|---|
Request |
QuorumZooKeeperServer.checkUpgradeSession(Request request) |
Modifier and Type | Method and Description |
---|---|
Request |
QuorumZooKeeperServer.checkUpgradeSession(Request request) |
void |
CommitProcessor.commit(Request request) |
void |
ObserverZooKeeperServer.commitRequest(Request request)
Unlike a Follower, which sees a full request only during the PROPOSAL
phase, Observers get all the data required with the INFORM packet.
|
protected boolean |
CommitProcessor.needCommit(Request request) |
void |
CommitProcessor.processRequest(Request request) |
void |
ProposalRequestProcessor.processRequest(Request request) |
void |
ReadOnlyRequestProcessor.processRequest(Request request) |
void |
LeaderRequestProcessor.processRequest(Request request) |
void |
FollowerRequestProcessor.processRequest(Request request) |
void |
SendAckRequestProcessor.processRequest(Request si) |
void |
ObserverRequestProcessor.processRequest(Request request)
Simply queue the request, which will be processed in FIFO order.
|
Leader.Proposal |
Leader.propose(Request request)
create a proposal and send it out to all the members
|
protected void |
QuorumZooKeeperServer.setLocalSessionFlag(Request si) |
void |
Leader.submitLearnerRequest(Request si) |
void |
LeaderZooKeeperServer.submitLearnerRequest(Request request)
Requests coming from the learner should go directly to
PrepRequestProcessor
|
void |
ObserverMaster.submitLearnerRequest(Request si) |
Modifier and Type | Method and Description |
---|---|
static byte[] |
SerializeUtils.serializeRequest(Request request) |
Copyright © 2008–2020 The Apache Software Foundation. All rights reserved.