When you add a message to the Q you will at most provide work for 1 persistence thread.

1 files changed, 4 insertions, 6 deletions

diff --git a/storage/src/vespa/storage/persistence/filestorage/filestorhandlerimpl.cpp b/storage/src/vespa/storage/persistence/filestorage/filestorhandlerimpl.cpp
index 834b3dfa48e..13f3ceb328b 100644
--- a/storage/src/vespa/storage/persistence/filestorage/filestorhandlerimpl.cpp
+++ b/storage/src/vespa/storage/persistence/filestorage/filestorhandlerimpl.cpp
@@ -1101,12 +1101,10 @@ FileStorHandlerImpl::Stripe::abort(std::vector<std::shared_ptr<api::StorageReply
 bool
 FileStorHandlerImpl::Stripe::schedule(MessageEntry messageEntry)
 {
-    {
-        std::lock_guard guard(*_lock);
-        _queue->emplace_back(std::move(messageEntry));
-        update_cached_queue_size(guard);
-    }
-    _cond->notify_all();
+    std::lock_guard guard(*_lock);
+    _queue->emplace_back(std::move(messageEntry));
+    update_cached_queue_size(guard);
+    _cond->notify_one();
     return true;
 }