Package | Description |
---|---|
bftsmart.paxosatwar.executionmanager | |
bftsmart.paxosatwar.messages | |
bftsmart.paxosatwar.roles | |
bftsmart.tom.leaderchange |
Modifier and Type | Field and Description |
---|---|
java.util.HashSet<PaxosMessage> |
Round.proof |
Modifier and Type | Method and Description |
---|---|
java.util.Set<PaxosMessage> |
Round.getProof() |
java.util.Queue<PaxosMessage> |
ExecutionManager.getStoppedMsgs() |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionManager.addOutOfContextMessage(PaxosMessage m)
Stores a message established as being out of context (a message that
doesn't belong to current executing consensus).
|
void |
Round.addToProof(PaxosMessage pm) |
boolean |
ExecutionManager.checkLimits(PaxosMessage msg)
Checks if this message can execute now.
|
Modifier and Type | Method and Description |
---|---|
PaxosMessage |
MessageFactory.createCollect(int id,
int round,
java.lang.Object proof)
Creates a COLLECT message to be sent by this process
|
PaxosMessage |
MessageFactory.createDecide(int id,
int round,
byte[] value)
Creates a DECIDE message to be sent by this process
|
PaxosMessage |
MessageFactory.createFreeze(int id,
int round)
Creates a FREEZE message to be sent by this process
|
PaxosMessage |
MessageFactory.createPropose(int id,
int round,
byte[] value,
java.lang.Object proof)
Creates a PROPOSE message to be sent by this process
|
PaxosMessage |
MessageFactory.createStrong(int id,
int round,
byte[] value)
Creates a STRONG message to be sent by this process
|
PaxosMessage |
MessageFactory.createWeak(int id,
int round,
byte[] value)
Creates a WEAK message to be sent by this process
|
Modifier and Type | Method and Description |
---|---|
void |
Acceptor.deliver(PaxosMessage msg)
Called by communication layer to delivery Paxos messages.
|
void |
Acceptor.processMessage(PaxosMessage msg)
Called when a Paxos message is received or when a out of context message must be processed.
|
void |
Acceptor.proposeReceived(Round round,
PaxosMessage msg)
Called when a PROPOSE message is received or when processing a formerly out of context propose which
is know belongs to the current execution.
|
Modifier and Type | Method and Description |
---|---|
java.util.Set<PaxosMessage> |
LastEidData.getEidProof()
Get proof of the decision
|
Constructor and Description |
---|
LastEidData(int pid,
int eid,
byte[] eidDecision,
java.util.Set<PaxosMessage> eidProof)
Constructor
|