Skip to content

Commit

Permalink
chore: rename
Browse files Browse the repository at this point in the history
  • Loading branch information
areyouok committed Dec 13, 2024
1 parent 1b0ebd1 commit e0c81f3
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -69,15 +69,15 @@ public FrameCallResult execute(Void input) {
RaftStatusImpl raftStatus = CommitManager.this.raftStatus;
long idx = syncForce ? raftStatus.getLastForceLogIndex() : raftStatus.getLastWriteLogIndex();
if (idx > raftStatus.getCommitIndex()) {
CommitManager.this.finish(idx);
CommitManager.this.logFinish(idx);
}
FiberCondition c = syncForce ? raftStatus.getLogForceFinishCondition()
: raftStatus.getLogWriteFinishCondition();
return c.await(1000, this);
}
}

public void finish(long lastPersistIndex) {
private void logFinish(long lastPersistIndex) {
RaftStatusImpl raftStatus = this.raftStatus;
if (lastPersistIndex > raftStatus.getLastLogIndex()) {
throw Fiber.fatal(new RaftException("lastPersistIndex > lastLogIndex. lastPersistIndex="
Expand Down Expand Up @@ -140,7 +140,7 @@ private static boolean needCommit(long recentMatchIndex, RaftStatusImpl raftStat


@SuppressWarnings("ForLoopReplaceableByForEach")
public static boolean needCommit(long currentCommitIndex, long recentMatchIndex,
private static boolean needCommit(long currentCommitIndex, long recentMatchIndex,
List<RaftMember> servers, int rwQuorum) {
if (recentMatchIndex < currentCommitIndex) {
return false;
Expand Down

0 comments on commit e0c81f3

Please sign in to comment.