diff options
| -rw-r--r-- | searchcore/src/vespa/searchcore/proton/flushengine/flushengine.cpp | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/searchcore/src/vespa/searchcore/proton/flushengine/flushengine.cpp b/searchcore/src/vespa/searchcore/proton/flushengine/flushengine.cpp index 00b9b5c8fd7..fb0b114d4b3 100644 --- a/searchcore/src/vespa/searchcore/proton/flushengine/flushengine.cpp +++ b/searchcore/src/vespa/searchcore/proton/flushengine/flushengine.cpp @@ -169,6 +169,8 @@ FlushEngine::Run(FastOS_ThreadInterface *thread, void *arg) } LOG(debug, "Making another wait(idle=%s, timeMS=%d) last was '%s'", shouldIdle ? "true" : "false", shouldIdle ? _idleIntervalMS : 0, prevFlushName.c_str()); } + _executor.sync(); + prune(); } bool @@ -299,6 +301,7 @@ FlushEngine::flushNextTarget(const vespalib::string & name) // Everything returned from a priority strategy should be flushed flushAll(lst.first); _executor.sync(); + prune(); _priorityStrategy.reset(); _strategyCond.notify_all(); return ""; |