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-11 14:40:31 +0000 |
commit | 3d76030d52a293fa63b9cb0d5fca77666edb26a0 (patch) | |
tree | a70cdf878913450fcc6bb7eeba28b9317bcb9632 /storage/src | |
parent | 683c0878884713382207fa8b498562b06464a456 (diff) |
Move async message queue signal notification inside lock
Diffstat (limited to 'storage/src')
-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 beccd605650..feed32f9b94 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(); } |