diff options
author | Tor Brede Vekterli <vekterli@yahooinc.com> | 2023-10-06 10:11:44 +0000 |
---|---|---|
committer | Tor Brede Vekterli <vekterli@yahooinc.com> | 2023-10-06 10:12:15 +0000 |
commit | 1689de5f1f2b3a1adb55d60b17156deb2ab72281 (patch) | |
tree | 43262704a12d5cffbf338409820b5d17d7b2c1db /storage | |
parent | ef83874db3ce7e3b45f190bec3dda5173e478891 (diff) |
Move async message queue signal notification inside lock
Diffstat (limited to 'storage')
-rw-r--r-- | storage/src/vespa/storage/common/storagelink.cpp | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/storage/src/vespa/storage/common/storagelink.cpp b/storage/src/vespa/storage/common/storagelink.cpp index 2d566f1fc29..6f8802cc26f 100644 --- a/storage/src/vespa/storage/common/storagelink.cpp +++ b/storage/src/vespa/storage/common/storagelink.cpp @@ -281,15 +281,14 @@ Queue::getNext(std::shared_ptr<api::StorageMessage>& msg, vespalib::duration tim void Queue::enqueue(std::shared_ptr<api::StorageMessage> msg) { - { - std::lock_guard sync(_lock); - _queue.emplace(std::move(msg)); - } + std::lock_guard sync(_lock); + _queue.emplace(std::move(msg)); _cond.notify_one(); } void Queue::signal() { + std::lock_guard sync(_lock); _cond.notify_one(); } |