RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2024-12-19 18:02:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

rgw/pubsub: Waiter unlocks before suspend

Browse Source 
Signed-off-by: Casey Bodley <cbodley@redhat.com>
This commit is contained in:
Casey Bodley 2024-05-22 08:24:26 -04:00
parent b7328fed0e
commit 629ad4562b
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/rgw/driver/rados/rgw_pubsub_push.cc
View File

@ -154,10 +154,10 @@ public:
auto yield = y.get_yield_context();
auto&& token = yield[ec];
boost::asio::async_initiate<boost::asio::yield_context, Signature>(
[this] (auto handler, auto ex) {
[this, &l] (auto handler, auto ex) {
completion = Completion::create(ex, std::move(handler));
l.unlock(); // unlock before suspend
}, token, yield.get_executor());
l.unlock();
return -ec.value();
}
cond.wait(l, [this]{return (done==true);});