diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2023-01-12 13:20:07 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2023-01-12 13:20:07 +0000 |
commit | 4c10c550e96635d3a14abfca560064ec085b74ab (patch) | |
tree | a7543fbcc7932d56a09957810dd9a196e1a1bcfe /storage/src | |
parent | ca9c0bb23d927af20f4c40cc71679c22c7cb08e5 (diff) |
No need to notify if bucket is already locked
Diffstat (limited to 'storage/src')
-rw-r--r-- | storage/src/vespa/storage/persistence/filestorage/filestorhandlerimpl.cpp | 9 |
1 files changed, 1 insertions, 8 deletions
diff --git a/storage/src/vespa/storage/persistence/filestorage/filestorhandlerimpl.cpp b/storage/src/vespa/storage/persistence/filestorage/filestorhandlerimpl.cpp index 1c245d9c38e..834b3dfa48e 100644 --- a/storage/src/vespa/storage/persistence/filestorage/filestorhandlerimpl.cpp +++ b/storage/src/vespa/storage/persistence/filestorage/filestorhandlerimpl.cpp @@ -1116,14 +1116,7 @@ FileStorHandlerImpl::Stripe::schedule_and_get_next_async_message(MessageEntry en std::unique_lock guard(*_lock); _queue->emplace_back(std::move(entry)); update_cached_queue_size(guard); - auto lockedMessage = get_next_async_message(guard); - if ( ! lockedMessage.msg) { - if (guard.owns_lock()) { - guard.unlock(); - } - _cond->notify_all(); - } - return lockedMessage; + return get_next_async_message(guard); } void |