Package | Description |
---|---|
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 |
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,
org.apache.jute.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 |
RequestProcessor.processRequest(Request request) |
void |
SyncRequestProcessor.processRequest(Request request) |
void |
FinalRequestProcessor.processRequest(Request request) |
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 | Method and Description |
---|---|
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.
|
void |
ProposalRequestProcessor.processRequest(Request request) |
void |
SendAckRequestProcessor.processRequest(Request si) |
void |
ReadOnlyRequestProcessor.processRequest(Request request) |
void |
ObserverRequestProcessor.processRequest(Request request)
Simply queue the request, which will be processed in FIFO order.
|
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
|
Copyright © 2017 The Apache Software Foundation