No need to notify if bucket is already locked
@@ -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
