std::vector<sg4::CommPtr> pending_comms;
pending_comms.push_back(comm1);
pending_comms.push_back(comm2);
- long index;
try {
- index = sg4::Comm::wait_any(pending_comms);
+ long index = sg4::Comm::wait_any(pending_comms);
XBT_INFO("Wait any returned index %ld (comm to %s)", index, pending_comms.at(index)->get_mailbox()->get_cname());
} catch (simgrid::NetworkFailureException& e) {
XBT_INFO("Sender has experienced a network failure exception, so it knows that something went wrong");
}
XBT_INFO("Wait for remaining comm, just to be nice");
pending_comms.erase(pending_comms.begin());
- index = simgrid::s4u::Comm::wait_any(pending_comms);
+ simgrid::s4u::Comm::wait_any(pending_comms);
}
};
exec2->start();
XBT_INFO("Calling wait_any..");
- long index;
try {
- index = sg4::Exec::wait_any(pending_execs);
+ long index = sg4::Exec::wait_any(pending_execs);
XBT_INFO("Wait any returned index %ld (exec on %s)", index, pending_execs.at(index)->get_host()->get_cname());
} catch (simgrid::HostFailureException& e) {
XBT_INFO("Dispatcher has experienced a host failure exception, so it knows that something went wrong");
}
pending_execs.pop_back();
XBT_INFO("Wait for remaining exec, just to be nice");
- index = simgrid::s4u::Exec::wait_any(pending_execs);
+ simgrid::s4u::Exec::wait_any(pending_execs);
XBT_INFO("Dispatcher ends");
}