}
@Override
- public long decrNextIndex() {
- return nextIndex--;
+ public boolean decrNextIndex() {
+ if (nextIndex >= 0) {
+ nextIndex--;
+ return true;
+ }
+
+ return false;
}
@Override
return true;
}
- private void resetLastReplicated(){
+ private void resetLastReplicated() {
lastReplicatedIndex = getNextIndex();
if (lastReplicatedStopwatch.isRunning()) {
lastReplicatedStopwatch.reset();
@Override
public void clearLeaderInstallSnapshotState() {
+ Preconditions.checkState(installSnapshotState != null);
+ installSnapshotState.close();
installSnapshotState = null;
}