Skip to content

Commit

Permalink
(fix) Should use clock time in replicator block method (#16)
Browse files Browse the repository at this point in the history
  • Loading branch information
killme2008 authored and fengjiachun committed Mar 7, 2019
1 parent f3aa4e7 commit b34565d
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -1071,7 +1071,7 @@ static void onRpcReturned(ThreadId id, RequestType reqType, Status status, Messa
r.resetInflights();
r.state = State.Probe;
continueSendEntries = false;
r.block(Utils.monotonicMs(), RaftError.EREQUEST.getNumber());
r.block(Utils.nowMs(), RaftError.EREQUEST.getNumber());
return;
}
try {
Expand Down

0 comments on commit b34565d

Please sign in to comment.