Skip to content

Commit 5f5cf52

Browse files
committed
Fixed client
1 parent b8a9b32 commit 5f5cf52

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

simulator/src/main/java/byzzbench/simulator/protocols/fab2/FastByzantineClient.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -107,7 +107,7 @@ public void handleMessage(String senderId, MessagePayload reply) {
107107
this.replies.add(reply);
108108
if (learnersList.contains(senderId)) {
109109
learners.incrementAndGet();
110-
if (learners.get() == 4) {
110+
if (learners.get() == 3) {
111111
for (String proposer : proposersList) {
112112
this.sendRequest(proposer);
113113
}

simulator/src/main/java/byzzbench/simulator/protocols/fab2/FastByzantineReplica.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -444,7 +444,8 @@ private void handleLearnMessageProposer(String sender, LearnMessage learnMessage
444444
}
445445

446446
// Leader is ready to move to the next request.
447-
if (isLeader() && !requests.isEmpty()) {
447+
if (isLeader() && !requests.isEmpty()
448+
&& messageLog.getProposersWithLearnedValue().size() >= p) {
448449
Serializable request = requests.poll();
449450
this.proposalNumber++;
450451
log.info("Increasing proposal number: " + this.proposalNumber);

0 commit comments

Comments
 (0)