Package | Description |
---|---|
org.apache.zookeeper.server |
ZooKeeper server theory of operation
|
org.apache.zookeeper.server.persistence | |
org.apache.zookeeper.server.quorum | |
org.apache.zookeeper.server.util |
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
|
static void |
ZooTrace.logRequest(org.slf4j.Logger log,
long mask,
char rp,
Request request,
String header) |
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 |
FinalRequestProcessor.processRequest(Request request) |
void |
SyncRequestProcessor.processRequest(Request request) |
void |
UnimplementedRequestProcessor.processRequest(Request request) |
void |
PrepRequestProcessor.processRequest(Request request) |
void |
RequestProcessor.processRequest(Request request) |
DataTree.ProcessTxnResult |
ZooKeeperServer.processTxn(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 |
ZooKeeperServer.submitRequest(Request si) |
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 AtomicReference<Request> |
CommitProcessor.nextPending
Request for which we are currently awaiting a commit
|
protected LinkedBlockingQueue<Request> |
CommitProcessor.queuedRequests
Requests that we are holding until the commit comes in.
|
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 |
ReadOnlyRequestProcessor.processRequest(Request request) |
void |
ProposalRequestProcessor.processRequest(Request request) |
void |
ObserverRequestProcessor.processRequest(Request request)
Simply queue the request, which will be processed in FIFO order.
|
void |
LeaderRequestProcessor.processRequest(Request request) |
void |
SendAckRequestProcessor.processRequest(Request si) |
void |
CommitProcessor.processRequest(Request request) |
void |
FollowerRequestProcessor.processRequest(Request request) |
Leader.Proposal |
Leader.propose(Request request)
create a proposal and send it out to all the members
|
protected void |
QuorumZooKeeperServer.setLocalSessionFlag(Request si) |
void |
LeaderZooKeeperServer.submitLearnerRequest(Request request)
Requests coming from the learner should go directly to
PrepRequestProcessor
|
Modifier and Type | Method and Description |
---|---|
static byte[] |
SerializeUtils.serializeRequest(Request request) |
Copyright © 2008–2019 The Apache Software Foundation. All rights reserved.