// FIXME I think that this fires at the same time for all hosts, so when the src sends something,
// the dst will be notified even though it didn't even arrive at the recv yet
kernel::activity::CommImpl::on_start.connect([this](const kernel::activity::CommImpl& comm) {
// FIXME I think that this fires at the same time for all hosts, so when the src sends something,
// the dst will be notified even though it didn't even arrive at the recv yet
kernel::activity::CommImpl::on_start.connect([this](const kernel::activity::CommImpl& comm) {