Skip to content

Commit

Permalink
checkstyle fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
dunkymole committed Dec 3, 2019
1 parent 0028518 commit fe5847c
Showing 1 changed file with 6 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -473,7 +473,8 @@ public void onRequestVote(
}
else if (candidateTermId > leadershipTermId)
{
ctx.countedErrorHandler().onError(new ClusterException("unexpected vote request", AeronException.Category.WARN));
ctx.countedErrorHandler().onError(new ClusterException("unexpected vote request",
AeronException.Category.WARN));
enterElection(clusterTimeUnit.toNanos(clusterClock.time()));
election.onRequestVote(logLeadershipTermId, logPosition, candidateTermId, candidateId);
}
Expand Down Expand Up @@ -509,7 +510,8 @@ public void onNewLeadershipTerm(
}
else if (leadershipTermId > this.leadershipTermId)
{
ctx.countedErrorHandler().onError(new ClusterException("unexpected new leadership term", AeronException.Category.WARN));
ctx.countedErrorHandler().onError(new ClusterException("unexpected new leadership term",
AeronException.Category.WARN));
enterElection(clusterTimeUnit.toNanos(clusterClock.time()));
}
}
Expand Down Expand Up @@ -1915,7 +1917,8 @@ else if (Cluster.Role.FOLLOWER == role &&
{
ctx.countedErrorHandler().onError(new ClusterException(
"no leader connection: logPosition=" + logPosition() + " commitPosition=" + commitPosition.get() +
" leadershipTermId=" + leadershipTermId + " leaderId=" + leaderMember.id(), AeronException.Category.WARN));
" leadershipTermId=" + leadershipTermId + " leaderId=" + leaderMember.id(),
AeronException.Category.WARN));
enterElection(nowNs);
return 1;
}
Expand Down

0 comments on commit fe5847c

Please sign in to comment.