MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-09-30 12:48:54 +02:00
Code Issues Releases Wiki Activity

ircd::ctx::parallel: Block interruption when calling sender().

Browse source
This commit is contained in:
Jason Volk 2019-01-25 16:41:16 -08:00
parent 33601e88a1
commit 3e9b830206
1 changed files with 2 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
include/ircd/ctx/parallel.h
View file

@ -73,6 +73,7 @@ template<class arg>
void void
ircd::ctx::parallel<arg>::operator()(const arg &a) ircd::ctx::parallel<arg>::operator()(const arg &a)
{ {
const uninterruptible ui;
rethrow_any_exception(); rethrow_any_exception();
assert(avail()); assert(avail());
this->a.at(nextpos()) = a; this->a.at(nextpos()) = a;
@ -84,6 +85,7 @@ template<class arg>
void void
ircd::ctx::parallel<arg>::operator()() ircd::ctx::parallel<arg>::operator()()
{ {
const uninterruptible ui;
rethrow_any_exception(); rethrow_any_exception();
assert(avail()); assert(avail());
sender(); sender();