Skip to content

Commit 7abde83

Browse files
Biatbe13Biatbe13
committed
Fix
1 parent 666bb5e commit 7abde83

12 files changed

+899
-769
lines changed

‎schedule-logs/scenario-1.txt

+51
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,51 @@
1+
REQUEST from C0 to C with (timestamp: 1737578079298, request: C0/1)
2+
REQUEST from C1 to C with (timestamp: 1737578079298, request: C1/1)
3+
REQUEST from C0 to B with (timestamp: 1737578079298, request: C0/1)
4+
REQUEST from C1 to B with (timestamp: 1737578079298, request: C1/1)
5+
PREPARE from B to A with (seqNum: 1, viewNum: 1, request: C0/1)
6+
PREPARE accepted at A
7+
PREPARE from B to C with (seqNum: 1, viewNum: 1, request: C0/1)
8+
PREPARE accepted at C
9+
PREPARE from B to D with (seqNum: 1, viewNum: 1, request: C1/1)
10+
PREPARE accepted at D
11+
COMMIT from A to D with (seqNum: 1, viewNum: 1, request: C0/1)
12+
COMMIT accepted at D
13+
PREPARE from B to D with (seqNum: 1, viewNum: 1, request: C0/1)
14+
COMMIT from C to D with (seqNum: 1, viewNum: 1, request: C0/1)
15+
COMMIT accepted at D
16+
COMMITED SerializableLogEntry(entry=C1/1) at 1 at replica D
17+
18+
19+
REQUEST from C1 to B with (timestamp: 1737578079298, request: C1/1)
20+
REQUEST from C1 to D with (timestamp: 1737578079298, request: C1/1)
21+
COMMIT from B to A with (seqNum: 1, viewNum: 1, request: C0/1)
22+
COMMIT accepted at A
23+
REQUEST from C0 to A with (timestamp: 1737578079298, request: C0/1)
24+
REQUEST from C0 to B with (timestamp: 1737578079298, request: C0/1)
25+
COMMIT from B to C with (seqNum: 1, viewNum: 1, request: C0/1)
26+
COMMIT accepted at C
27+
REQUEST from C1 to A with (timestamp: 1737578079298, request: C1/1)
28+
PREPARE from B to A with (seqNum: 2, viewNum: 1, request: C1/1)
29+
PREPARE accepted at A
30+
PREPARE from B to C with (seqNum: 2, viewNum: 1, request: C1/1)
31+
PREPARE accepted at C
32+
COMMIT from B to C with (seqNum: 2, viewNum: 1, request: C1/1)
33+
COMMIT accepted at C
34+
COMMIT from B to D with (seqNum: 2, viewNum: 1, request: C1/1)
35+
COMMIT accepted at D
36+
COMMIT from A to B with (seqNum: 1, viewNum: 1, request: C0/1)
37+
COMMIT accepted at B
38+
COMMIT from A to C with (seqNum: 1, viewNum: 1, request: C0/1)
39+
COMMIT accepted at C
40+
COMMITED SerializableLogEntry(entry=C0/1) at 1 at replica C
41+
42+
43+
Scenario path: output\1737578070\hbft-1
44+
AgreementPredicate: Disagreement at index 1
45+
REPLICAS:
46+
A: null
47+
C: SerializableLogEntry(entry=C0/1)
48+
D: SerializableLogEntry(entry=C1/1)
49+
DISTINCT ENTRIES:
50+
SerializableLogEntry(entry=C0/1)
51+
SerializableLogEntry(entry=C1/1)

‎schedule-logs/scenario-2.txt

+23
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
REQUEST from C0 to B with (timestamp: 1737579775439, request: C0/1)
2+
REQUEST from C1 to B with (timestamp: 1737579775439, request: C1/1)
3+
PREPARE from B to C with (seqNum: 1, viewNum: 1, request: C0/1)
4+
Checking prepare message
5+
PREPARE accepted at C
6+
Ticket [PrepareMessage(viewNumber=1, sequenceNumber=1, digest=[62, 62, -30, -17, -61, 36, 69, -65, 50, 4, 7, 69, -24, 54, -127, 23, 67, 74, -49, -99], request=RequestMessage(operation=C0/1, timestamp=1737579775439, clientId=C0)), ReplyMessage(viewNumber=1, timestamp=1737579775439, sequenceNumber=1, clientId=C0, replicaId=C, result=SerializableLogEntry(entry=C0/1), speculativeHistory=SpeculativeHistory(history={})), CommitMessage(viewNumber=1, sequenceNumber=1, digest=[62, 62, -30, -17, -61, 36, 69, -65, 50, 4, 7, 69, -24, 54, -127, 23, 67, 74, -49, -99], request=RequestMessage(operation=C0/1, timestamp=1737579775439, clientId=C0), replicaId=C, speculativeHistory=SpeculativeHistory(history={}))]
7+
PREPARE from B to A with (seqNum: 1, viewNum: 1, request: C0/1)
8+
Checking prepare message
9+
PREPARE accepted at A
10+
Ticket [PrepareMessage(viewNumber=1, sequenceNumber=1, digest=[62, 62, -30, -17, -61, 36, 69, -65, 50, 4, 7, 69, -24, 54, -127, 23, 67, 74, -49, -99], request=RequestMessage(operation=C0/1, timestamp=1737579775439, clientId=C0)), ReplyMessage(viewNumber=1, timestamp=1737579775439, sequenceNumber=1, clientId=C0, replicaId=A, result=SerializableLogEntry(entry=C0/1), speculativeHistory=SpeculativeHistory(history={})), CommitMessage(viewNumber=1, sequenceNumber=1, digest=[62, 62, -30, -17, -61, 36, 69, -65, 50, 4, 7, 69, -24, 54, -127, 23, 67, 74, -49, -99], request=RequestMessage(operation=C0/1, timestamp=1737579775439, clientId=C0), replicaId=A, speculativeHistory=SpeculativeHistory(history={}))]
11+
PREPARE from B to D with (seqNum: 1, viewNum: 1, request: C1/1)
12+
Checking prepare message
13+
PREPARE accepted at D
14+
Ticket [PrepareMessage(viewNumber=1, sequenceNumber=1, digest=[-113, -80, -38, 77, 68, -56, 25, -97, 125, 124, -71, -11, -101, -103, -117, -7, 66, 109, -53, 123], request=RequestMessage(operation=C1/1, timestamp=1737579775439, clientId=C1)), ReplyMessage(viewNumber=1, timestamp=1737579775439, sequenceNumber=1, clientId=C1, replicaId=D, result=SerializableLogEntry(entry=C1/1), speculativeHistory=SpeculativeHistory(history={})), CommitMessage(viewNumber=1, sequenceNumber=1, digest=[-113, -80, -38, 77, 68, -56, 25, -97, 125, 124, -71, -11, -101, -103, -117, -7, 66, 109, -53, 123], request=RequestMessage(operation=C1/1, timestamp=1737579775439, clientId=C1), replicaId=D, speculativeHistory=SpeculativeHistory(history={}))]
15+
COMMIT from C to D with (seqNum: 1, viewNum: 1, request: C0/1)
16+
COMMIT accepted at D
17+
Ticket [PrepareMessage(viewNumber=1, sequenceNumber=1, digest=[-113, -80, -38, 77, 68, -56, 25, -97, 125, 124, -71, -11, -101, -103, -117, -7, 66, 109, -53, 123], request=RequestMessage(operation=C1/1, timestamp=1737579775439, clientId=C1)), ReplyMessage(viewNumber=1, timestamp=1737579775439, sequenceNumber=1, clientId=C1, replicaId=D, result=SerializableLogEntry(entry=C1/1), speculativeHistory=SpeculativeHistory(history={})), CommitMessage(viewNumber=1, sequenceNumber=1, digest=[-113, -80, -38, 77, 68, -56, 25, -97, 125, 124, -71, -11, -101, -103, -117, -7, 66, 109, -53, 123], request=RequestMessage(operation=C1/1, timestamp=1737579775439, clientId=C1), replicaId=D, speculativeHistory=SpeculativeHistory(history={})), CommitMessage(viewNumber=1, sequenceNumber=1, digest=[62, 62, -30, -17, -61, 36, 69, -65, 50, 4, 7, 69, -24, 54, -127, 23, 67, 74, -49, -99], request=RequestMessage(operation=C0/1, timestamp=1737579775439, clientId=C0), replicaId=C, speculativeHistory=SpeculativeHistory(history={}))]
18+
PREPARE from B to D with (seqNum: 1, viewNum: 1, request: C0/1)
19+
COMMIT from A to D with (seqNum: 1, viewNum: 1, request: C0/1)
20+
COMMIT accepted at D
21+
Ticket [PrepareMessage(viewNumber=1, sequenceNumber=1, digest=[-113, -80, -38, 77, 68, -56, 25, -97, 125, 124, -71, -11, -101, -103, -117, -7, 66, 109, -53, 123], request=RequestMessage(operation=C1/1, timestamp=1737579775439, clientId=C1)), ReplyMessage(viewNumber=1, timestamp=1737579775439, sequenceNumber=1, clientId=C1, replicaId=D, result=SerializableLogEntry(entry=C1/1), speculativeHistory=SpeculativeHistory(history={})), CommitMessage(viewNumber=1, sequenceNumber=1, digest=[-113, -80, -38, 77, 68, -56, 25, -97, 125, 124, -71, -11, -101, -103, -117, -7, 66, 109, -53, 123], request=RequestMessage(operation=C1/1, timestamp=1737579775439, clientId=C1), replicaId=D, speculativeHistory=SpeculativeHistory(history={})), CommitMessage(viewNumber=1, sequenceNumber=1, digest=[62, 62, -30, -17, -61, 36, 69, -65, 50, 4, 7, 69, -24, 54, -127, 23, 67, 74, -49, -99], request=RequestMessage(operation=C0/1, timestamp=1737579775439, clientId=C0), replicaId=C, speculativeHistory=SpeculativeHistory(history={})), CommitMessage(viewNumber=1, sequenceNumber=1, digest=[62, 62, -30, -17, -61, 36, 69, -65, 50, 4, 7, 69, -24, 54, -127, 23, 67, 74, -49, -99], request=RequestMessage(operation=C0/1, timestamp=1737579775439, clientId=C0), replicaId=A, speculativeHistory=SpeculativeHistory(history={}))]
22+
Request RequestMessage(operation=C1/1, timestamp=1737579775439, clientId=C1)
23+
COMMITED SerializableLogEntry(entry=C1/1) at 1 at replica D

‎schedule-logs/scenario-3.txt

+23
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
REQUEST from C0 to B with (timestamp: 1737579974436, request: C0/1)
2+
REQUEST from C1 to B with (timestamp: 1737579974436, request: C1/1)
3+
PREPARE from B to A with (seqNum: 1, viewNum: 1, request: C0/1)
4+
Checking prepare message
5+
PREPARE accepted at A
6+
Ticket [PrepareMessage(viewNumber=1, sequenceNumber=1, digest=[37, 125, 121, -93, 55, -96, -95, -62, 116, 107, 108, -62, -40, -119, -69, 97, -36, 115, -76, -11], request=RequestMessage(operation=C0/1, timestamp=1737579974436, clientId=C0)), ReplyMessage(viewNumber=1, timestamp=1737579974436, sequenceNumber=1, clientId=C0, replicaId=A, result=SerializableLogEntry(entry=C0/1), speculativeHistory=SpeculativeHistory(history={})), CommitMessage(viewNumber=1, sequenceNumber=1, digest=[37, 125, 121, -93, 55, -96, -95, -62, 116, 107, 108, -62, -40, -119, -69, 97, -36, 115, -76, -11], request=RequestMessage(operation=C0/1, timestamp=1737579974436, clientId=C0), replicaId=A, speculativeHistory=SpeculativeHistory(history={}))]
7+
PREPARE from B to C with (seqNum: 1, viewNum: 1, request: C0/1)
8+
Checking prepare message
9+
PREPARE accepted at C
10+
Ticket [PrepareMessage(viewNumber=1, sequenceNumber=1, digest=[37, 125, 121, -93, 55, -96, -95, -62, 116, 107, 108, -62, -40, -119, -69, 97, -36, 115, -76, -11], request=RequestMessage(operation=C0/1, timestamp=1737579974436, clientId=C0)), ReplyMessage(viewNumber=1, timestamp=1737579974436, sequenceNumber=1, clientId=C0, replicaId=C, result=SerializableLogEntry(entry=C0/1), speculativeHistory=SpeculativeHistory(history={})), CommitMessage(viewNumber=1, sequenceNumber=1, digest=[37, 125, 121, -93, 55, -96, -95, -62, 116, 107, 108, -62, -40, -119, -69, 97, -36, 115, -76, -11], request=RequestMessage(operation=C0/1, timestamp=1737579974436, clientId=C0), replicaId=C, speculativeHistory=SpeculativeHistory(history={}))]
11+
PREPARE from B to D with (seqNum: 3, viewNum: 1, request: C1/1)
12+
COMMIT from A to D with (seqNum: 1, viewNum: 1, request: C0/1)
13+
COMMIT accepted at D
14+
PREPARE from B to D with (seqNum: 1, viewNum: 1, request: C0/1)
15+
Checking prepare message
16+
Ticket messages: CommitMessage(viewNumber=1, sequenceNumber=1, digest=[37, 125, 121, -93, 55, -96, -95, -62, 116, 107, 108, -62, -40, -119, -69, 97, -36, 115, -76, -11], request=RequestMessage(operation=C0/1, timestamp=1737579974436, clientId=C0), replicaId=A, speculativeHistory=SpeculativeHistory(history={}))
17+
PREPARE accepted at D
18+
Ticket [CommitMessage(viewNumber=1, sequenceNumber=1, digest=[37, 125, 121, -93, 55, -96, -95, -62, 116, 107, 108, -62, -40, -119, -69, 97, -36, 115, -76, -11], request=RequestMessage(operation=C0/1, timestamp=1737579974436, clientId=C0), replicaId=A, speculativeHistory=SpeculativeHistory(history={})), PrepareMessage(viewNumber=1, sequenceNumber=1, digest=[37, 125, 121, -93, 55, -96, -95, -62, 116, 107, 108, -62, -40, -119, -69, 97, -36, 115, -76, -11], request=RequestMessage(operation=C0/1, timestamp=1737579974436, clientId=C0)), ReplyMessage(viewNumber=1, timestamp=1737579974436, sequenceNumber=1, clientId=C0, replicaId=D, result=SerializableLogEntry(entry=C0/1), speculativeHistory=SpeculativeHistory(history={})), CommitMessage(viewNumber=1, sequenceNumber=1, digest=[37, 125, 121, -93, 55, -96, -95, -62, 116, 107, 108, -62, -40, -119, -69, 97, -36, 115, -76, -11], request=RequestMessage(operation=C0/1, timestamp=1737579974436, clientId=C0), replicaId=D, speculativeHistory=SpeculativeHistory(history={}))]
19+
COMMIT from C to D with (seqNum: 1, viewNum: 1, request: C0/1)
20+
COMMIT accepted at D
21+
Ticket [CommitMessage(viewNumber=1, sequenceNumber=1, digest=[37, 125, 121, -93, 55, -96, -95, -62, 116, 107, 108, -62, -40, -119, -69, 97, -36, 115, -76, -11], request=RequestMessage(operation=C0/1, timestamp=1737579974436, clientId=C0), replicaId=A, speculativeHistory=SpeculativeHistory(history={})), PrepareMessage(viewNumber=1, sequenceNumber=1, digest=[37, 125, 121, -93, 55, -96, -95, -62, 116, 107, 108, -62, -40, -119, -69, 97, -36, 115, -76, -11], request=RequestMessage(operation=C0/1, timestamp=1737579974436, clientId=C0)), ReplyMessage(viewNumber=1, timestamp=1737579974436, sequenceNumber=1, clientId=C0, replicaId=D, result=SerializableLogEntry(entry=C0/1), speculativeHistory=SpeculativeHistory(history={})), CommitMessage(viewNumber=1, sequenceNumber=1, digest=[37, 125, 121, -93, 55, -96, -95, -62, 116, 107, 108, -62, -40, -119, -69, 97, -36, 115, -76, -11], request=RequestMessage(operation=C0/1, timestamp=1737579974436, clientId=C0), replicaId=D, speculativeHistory=SpeculativeHistory(history={})), CommitMessage(viewNumber=1, sequenceNumber=1, digest=[37, 125, 121, -93, 55, -96, -95, -62, 116, 107, 108, -62, -40, -119, -69, 97, -36, 115, -76, -11], request=RequestMessage(operation=C0/1, timestamp=1737579974436, clientId=C0), replicaId=C, speculativeHistory=SpeculativeHistory(history={}))]
22+
Request RequestMessage(operation=C0/1, timestamp=1737579974436, clientId=C0)
23+
COMMITED SerializableLogEntry(entry=C0/1) at 1 at replica D

‎schedule-logs/scenario-4.txt

+22
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
REQUEST from C0 to B with (timestamp: 1737580055583, request: C0/1)
2+
REQUEST from C1 to B with (timestamp: 1737580055583, request: C1/1)
3+
PREPARE from B to A with (seqNum: 1, viewNum: 1, request: C0/1)
4+
Checking prepare message
5+
PREPARE accepted at A
6+
Ticket [PrepareMessage(viewNumber=1, sequenceNumber=1, digest=[-122, -12, -26, 54, -7, -6, 48, 70, 67, -64, -94, 66, 97, 20, -98, 18, 126, -65, 63, -114], request=RequestMessage(operation=C0/1, timestamp=1737580055583, clientId=C0)), ReplyMessage(viewNumber=1, timestamp=1737580055583, sequenceNumber=1, clientId=C0, replicaId=A, result=SerializableLogEntry(entry=C0/1), speculativeHistory=SpeculativeHistory(history={})), CommitMessage(viewNumber=1, sequenceNumber=1, digest=[-122, -12, -26, 54, -7, -6, 48, 70, 67, -64, -94, 66, 97, 20, -98, 18, 126, -65, 63, -114], request=RequestMessage(operation=C0/1, timestamp=1737580055583, clientId=C0), replicaId=A, speculativeHistory=SpeculativeHistory(history={}))]
7+
PREPARE from B to C with (seqNum: 1, viewNum: 1, request: C0/1)
8+
Checking prepare message
9+
PREPARE accepted at C
10+
Ticket [PrepareMessage(viewNumber=1, sequenceNumber=1, digest=[-122, -12, -26, 54, -7, -6, 48, 70, 67, -64, -94, 66, 97, 20, -98, 18, 126, -65, 63, -114], request=RequestMessage(operation=C0/1, timestamp=1737580055583, clientId=C0)), ReplyMessage(viewNumber=1, timestamp=1737580055583, sequenceNumber=1, clientId=C0, replicaId=C, result=SerializableLogEntry(entry=C0/1), speculativeHistory=SpeculativeHistory(history={})), CommitMessage(viewNumber=1, sequenceNumber=1, digest=[-122, -12, -26, 54, -7, -6, 48, 70, 67, -64, -94, 66, 97, 20, -98, 18, 126, -65, 63, -114], request=RequestMessage(operation=C0/1, timestamp=1737580055583, clientId=C0), replicaId=C, speculativeHistory=SpeculativeHistory(history={}))]
11+
PREPARE from B to D with (seqNum: 1, viewNum: 1, request: C1/1)
12+
Checking prepare message
13+
PREPARE accepted at D
14+
Ticket [PrepareMessage(viewNumber=1, sequenceNumber=1, digest=[-90, -123, -2, 119, -103, -86, -59, -65, 25, 101, 49, 32, -15, 20, 15, -52, -21, 76, -48, -29], request=RequestMessage(operation=C1/1, timestamp=1737580055583, clientId=C1)), ReplyMessage(viewNumber=1, timestamp=1737580055583, sequenceNumber=1, clientId=C1, replicaId=D, result=SerializableLogEntry(entry=C1/1), speculativeHistory=SpeculativeHistory(history={})), CommitMessage(viewNumber=1, sequenceNumber=1, digest=[-90, -123, -2, 119, -103, -86, -59, -65, 25, 101, 49, 32, -15, 20, 15, -52, -21, 76, -48, -29], request=RequestMessage(operation=C1/1, timestamp=1737580055583, clientId=C1), replicaId=D, speculativeHistory=SpeculativeHistory(history={}))]
15+
COMMIT from A to D with (seqNum: 1, viewNum: 1, request: C0/1)
16+
COMMIT accepted at D
17+
Ticket [PrepareMessage(viewNumber=1, sequenceNumber=1, digest=[-90, -123, -2, 119, -103, -86, -59, -65, 25, 101, 49, 32, -15, 20, 15, -52, -21, 76, -48, -29], request=RequestMessage(operation=C1/1, timestamp=1737580055583, clientId=C1)), ReplyMessage(viewNumber=1, timestamp=1737580055583, sequenceNumber=1, clientId=C1, replicaId=D, result=SerializableLogEntry(entry=C1/1), speculativeHistory=SpeculativeHistory(history={})), CommitMessage(viewNumber=1, sequenceNumber=1, digest=[-90, -123, -2, 119, -103, -86, -59, -65, 25, 101, 49, 32, -15, 20, 15, -52, -21, 76, -48, -29], request=RequestMessage(operation=C1/1, timestamp=1737580055583, clientId=C1), replicaId=D, speculativeHistory=SpeculativeHistory(history={})), CommitMessage(viewNumber=1, sequenceNumber=1, digest=[-122, -12, -26, 54, -7, -6, 48, 70, 67, -64, -94, 66, 97, 20, -98, 18, 126, -65, 63, -114], request=RequestMessage(operation=C0/1, timestamp=1737580055583, clientId=C0), replicaId=A, speculativeHistory=SpeculativeHistory(history={}))]
18+
PREPARE from B to D with (seqNum: 1, viewNum: 1, request: C0/1)
19+
COMMIT from C to D with (seqNum: 1, viewNum: 1, request: C0/1)
20+
COMMIT accepted at D
21+
Ticket [PrepareMessage(viewNumber=1, sequenceNumber=1, digest=[-90, -123, -2, 119, -103, -86, -59, -65, 25, 101, 49, 32, -15, 20, 15, -52, -21, 76, -48, -29], request=RequestMessage(operation=C1/1, timestamp=1737580055583, clientId=C1)), ReplyMessage(viewNumber=1, timestamp=1737580055583, sequenceNumber=1, clientId=C1, replicaId=D, result=SerializableLogEntry(entry=C1/1), speculativeHistory=SpeculativeHistory(history={})), CommitMessage(viewNumber=1, sequenceNumber=1, digest=[-90, -123, -2, 119, -103, -86, -59, -65, 25, 101, 49, 32, -15, 20, 15, -52, -21, 76, -48, -29], request=RequestMessage(operation=C1/1, timestamp=1737580055583, clientId=C1), replicaId=D, speculativeHistory=SpeculativeHistory(history={})), CommitMessage(viewNumber=1, sequenceNumber=1, digest=[-122, -12, -26, 54, -7, -6, 48, 70, 67, -64, -94, 66, 97, 20, -98, 18, 126, -65, 63, -114], request=RequestMessage(operation=C0/1, timestamp=1737580055583, clientId=C0), replicaId=A, speculativeHistory=SpeculativeHistory(history={})), CommitMessage(viewNumber=1, sequenceNumber=1, digest=[-122, -12, -26, 54, -7, -6, 48, 70, 67, -64, -94, 66, 97, 20, -98, 18, 126, -65, 63, -114], request=RequestMessage(operation=C0/1, timestamp=1737580055583, clientId=C0), replicaId=C, speculativeHistory=SpeculativeHistory(history={}))]
22+
Replica D sends VIEW-CHANGE with viewNumber: 2, requestsR: {1=RequestMessage(operation=C1/1, timestamp=1737580055583, clientId=C1)}

‎simulator/src/main/java/byzzbench/simulator/BaseScenario.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -188,7 +188,7 @@ public final void setupScenario() {
188188
this.markReplicaFaulty(replicaIds.get(i));
189189
}
190190

191-
this.getClients().values().forEach(Client::initialize);
191+
//this.getClients().values().forEach(Client::initialize);
192192
this.getNodes().values().forEach(Node::initialize);
193193
this.scheduler.initializeScenario(this);
194194
}

‎simulator/src/main/java/byzzbench/simulator/protocols/hbft/HbftJavaReplica.java

+4
Original file line numberDiff line numberDiff line change
@@ -471,11 +471,13 @@ public void recvPrepare(PrepareMessage prepare) {
471471
* received OR that the new PREPARE matches the digest of the one
472472
* that was already received.
473473
*/
474+
logger.writeLog(String.format("Checking prepare message"));
474475
Ticket<O, R> ticket = messageLog.getTicket(currentViewNumber, seqNumber);
475476
if (ticket != null) {
476477
// PREPARE has previously been inserted into the log for this
477478
// sequence number - verify the digests match per hBFT 4.1
478479
for (Object message : ticket.getMessages()) {
480+
logger.writeLog(String.format("Ticket messages: " + message));
479481
if (!(message instanceof PrepareMessage prevPrepare)) {
480482
continue;
481483
}
@@ -632,8 +634,10 @@ private void tryAdvanceState(Ticket<O, R> ticket, IPhaseMessage message) {
632634
* if it gets f + 1 conflicting COMMIT messages with its PREPARE
633635
* then it sends a view change message
634636
*/
637+
logger.writeLog("Ticket " + ticket.getMessages().toString());
635638
if (ticket.isCommittedLocal(this.tolerance)) {
636639
RequestMessage request = ticket.getRequest();
640+
logger.writeLog("Request " + request.toString());
637641
if (request != null && !request.equals(this.speculativeHistory.getHistory().get(seqNumber))) {
638642
String clientId = request.getClientId();
639643
long timestamp = request.getTimestamp();

0 commit comments

Comments
 (0)