summaryrefslogtreecommitdiffstats
path: root/searchcore
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2023-05-08 13:43:56 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2023-05-08 13:43:56 +0000
commit698958121d901f6c16da091e97aa87108d0c8457 (patch)
treed10c4d5b905a45ebee67a89bd377c4321f09b3a0 /searchcore
parent039a1a5c69128a7d2333f33f2a6fc46a410973eb (diff)
Just wait unconditionally
Diffstat (limited to 'searchcore')
-rw-r--r--searchcore/src/vespa/searchcore/proton/flushengine/flushengine.cpp4
1 files changed, 1 insertions, 3 deletions
diff --git a/searchcore/src/vespa/searchcore/proton/flushengine/flushengine.cpp b/searchcore/src/vespa/searchcore/proton/flushengine/flushengine.cpp
index 905a864f470..b9382ffa824 100644
--- a/searchcore/src/vespa/searchcore/proton/flushengine/flushengine.cpp
+++ b/searchcore/src/vespa/searchcore/proton/flushengine/flushengine.cpp
@@ -159,9 +159,7 @@ FlushEngine::canFlushMore(const std::unique_lock<std::mutex> &, IFlushTarget::Pr
void
FlushEngine::idle_wait(vespalib::duration minimumWaitTimeIfReady) {
std::unique_lock<std::mutex> guard(_lock);
- if (canFlushMore(guard, IFlushTarget::Priority::HIGH) && _pendingPrune.empty()) {
- _cond.wait_for(guard, minimumWaitTimeIfReady);
- }
+ _cond.wait_for(guard, minimumWaitTimeIfReady);
}
bool