Skip to content
Snippets Groups Projects
Commit 9ac551d0 authored by Michael Eischer's avatar Michael Eischer
Browse files

Fix executeAfter seqNr for queue / log client

The first sequence number on the replicas is zero
parent 3ca41bb0
No related branches found
No related tags found
No related merge requests found
......@@ -19,7 +19,7 @@ public class REFITLogClient extends REFITClientThread {
public REFITLogClient(REFITClientLibrary service) {
super(service);
this.lastRequestSeqNr = 0;
this.lastRequestSeqNr = -1;
}
......
......@@ -16,7 +16,7 @@ public class REFITQueueClient extends REFITClientThread {
public REFITQueueClient(REFITClientLibrary service) {
super(service);
this.lastRequestSeqNr = 0;
this.lastRequestSeqNr = -1;
}
......
......@@ -137,7 +137,7 @@ public class REFITClientStage extends REFITStage {
// ignore panic for requests that cannot be executed just yet, the client will resend the panic anyways
if (request.executeAfter >= executionNextSeqNr) {
REFITLogger.logWarning(this, "Ignoring panic with executeAfter "
+ request.executeAfter + " newer than current progress " + executionNextSeqNr);
+ request.executeAfter + " newer than next seqNr" + executionNextSeqNr);
return;
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment