Skip to content

Commit

Permalink
Apply spotlesscheck
Browse files Browse the repository at this point in the history
Signed-off-by: Rishikesh1159 <rishireddy1159@gmail.com>
  • Loading branch information
Rishikesh1159 committed Jul 20, 2022
1 parent e0ec134 commit 57afbd6
Showing 1 changed file with 2 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -123,10 +123,9 @@ public void onReplicationDone(SegmentReplicationState state) {
if (latestReceivedCheckpoint.get(replicaShard.shardId()).isAheadOf(replicaShard.getLatestReplicationCheckpoint())) {
Runnable runnable = () -> onNewCheckpoint(latestReceivedCheckpoint.get(replicaShard.shardId()), replicaShard);
// Checks if we are using same thread and forks if necessary.
if (thread == Thread.currentThread()){
if (thread == Thread.currentThread()) {
threadPool.generic().execute(runnable);
}
else{
} else {
runnable.run();
}
}
Expand Down

0 comments on commit 57afbd6

Please sign in to comment.