Skip to content

Commit

Permalink
Add extra logging
Browse files Browse the repository at this point in the history
  • Loading branch information
fcofdez committed Nov 27, 2023
1 parent 7b8e0d1 commit 1ac483c
Showing 1 changed file with 2 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -4167,9 +4167,11 @@ public void testMultiplePeriodicFlushesCanBeTriggeredBeforeTheyAreDurable() thro
@Override
public void flush(boolean force, boolean waitIfOngoing, ActionListener<FlushResult> listener) throws EngineException {
if (shardStarted.get()) {
logger.info("--> running flush after shard started {} {}", force, waitIfOngoing);
pendingListeners.add(listener);
safeAwait(flushExecutedBarrier);
} else {
logger.info("--> running flush before shard started {} {}", force, waitIfOngoing);
super.flush(force, waitIfOngoing, listener);
}
}
Expand Down

0 comments on commit 1ac483c

Please sign in to comment.