MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-12-26 15:33:54 +01:00
Code Issues Releases Wiki Activity

ircd::ctx: yield the promise-notifying ctx until any then() has posted.

Browse source
This commit is contained in:
Jason Volk 2018-04-07 04:48:45 -07:00
parent db93acf8fb
commit 8d91c90574
1 changed files with 12 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
include/ircd/ctx/shared_state.h
View file

@ -104,11 +104,21 @@ ircd::ctx::notify(shared_state<T> &st)
return;
}
ircd::post([&st]
// Need a fresh stack to execute then(), not this ctx's.
ircd::post([&st]() noexcept
{
assert(bool(st.then));
st.cond.notify_all();
st.then(st);
st.then = {};
st.cond.notify_all();
});
// If we don't hold the ctx here then it's too easy to destroy the future
// between now and when then() posts. This is completely effective if the
// future is on this ctx as long as then() itself doesn't hose it.
st.cond.wait([&st]
{
return !bool(st.then);
});
}