Skip to content

Commit

Permalink
#1983: objgroup: fix bug not consuming on pending dispatch
Browse files Browse the repository at this point in the history
  • Loading branch information
lifflander committed Dec 7, 2022
1 parent 8c256b5 commit e213347
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion src/vt/objgroup/manager.static.h
Original file line number Diff line number Diff line change
Expand Up @@ -143,7 +143,7 @@ void dispatch(
);
if (obj_iter == objs.end()) {
auto const epoch = envelopeGetEpoch(msg->env);
if (epoch != no_epoch and epoch != term::any_epoch_sentinel) {
if (epoch != no_epoch) {
theTerm()->produce(epoch);
}
auto& pending = getPending();
Expand All @@ -152,6 +152,9 @@ void dispatch(
auto obj_iter2 = objs2.find(proxy);
vtAssert(obj_iter2 != objs2.end(), "Obj must exist");
detail::dispatchImpl(msg, han, from_node, cont, obj_iter2->second->getPtr());
if (epoch != no_epoch) {
theTerm()->consume(epoch);
}
});
} else {
detail::dispatchImpl(msg, han, from_node, cont, obj_iter->second->getPtr());
Expand Down

0 comments on commit e213347

Please sign in to comment.