Skip to content

Commit

Permalink
tiny improve
Browse files Browse the repository at this point in the history
Change-Id: Ifc12c9b408ee24583e42fcd4842915ec2a71e554
  • Loading branch information
Linary committed Apr 13, 2021
1 parent 2bc2ab8 commit 3b7837f
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -286,7 +286,6 @@ public void onError(PeerId peer, Status status) {
}

// NOTE: Jraft itself doesn't have this callback, it's added by us
// @Override
public void onBusy(PeerId peer, Status status) {
int count = RaftNode.this.busyCounter.incrementAndGet();
LOG.info("Increase busy counter: [{}]", count);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -124,7 +124,6 @@ public void onApply(Iterator iter) {
} else {
// Follower need readMutation data
byte[] bytes = iter.getData().array();
// Follower seems no way to wait future
// Let the backend thread do it directly
futures.add(this.context.backendExecutor().submit(() -> {
BytesBuffer buffer = LZ4Util.decompress(bytes,
Expand Down

0 comments on commit 3b7837f

Please sign in to comment.