int Comm::wait_any_for(const std::vector<CommPtr>* comms, double timeout)
{
- auto rcomms = std::make_unique<kernel::activity::CommImpl*[]>(comms->size());
- std::transform(begin(*comms), end(*comms), rcomms.get(),
+ std::vector<kernel::activity::CommImpl*> rcomms(comms->size());
+ std::transform(begin(*comms), end(*comms), begin(rcomms),
[](const CommPtr& comm) { return static_cast<kernel::activity::CommImpl*>(comm->pimpl_.get()); });
- int changed_pos = simcall_comm_waitany(rcomms.get(), comms->size(), timeout);
+ int changed_pos = simcall_comm_waitany(rcomms.data(), rcomms.size(), timeout);
if (changed_pos != -1)
comms->at(changed_pos)->release_dependencies();
return changed_pos;
int Comm::test_any(const std::vector<CommPtr>* comms)
{
- auto rcomms = std::make_unique<kernel::activity::CommImpl*[]>(comms->size());
- std::transform(begin(*comms), end(*comms), rcomms.get(),
+ std::vector<kernel::activity::CommImpl*> rcomms(comms->size());
+ std::transform(begin(*comms), end(*comms), begin(rcomms),
[](const CommPtr& comm) { return static_cast<kernel::activity::CommImpl*>(comm->pimpl_.get()); });
- int changed_pos = simcall_comm_testany(rcomms.get(), comms->size());
+ int changed_pos = simcall_comm_testany(rcomms.data(), rcomms.size());
if (changed_pos != -1)
comms->at(changed_pos)->release_dependencies();
return changed_pos;
int Exec::wait_any_for(std::vector<ExecPtr>* execs, double timeout)
{
- auto rexecs = std::make_unique<kernel::activity::ExecImpl*[]>(execs->size());
- std::transform(begin(*execs), end(*execs), rexecs.get(),
+ std::vector<kernel::activity::ExecImpl*> rexecs(execs->size());
+ std::transform(begin(*execs), end(*execs), begin(rexecs),
[](const ExecPtr& exec) { return static_cast<kernel::activity::ExecImpl*>(exec->pimpl_.get()); });
- int changed_pos = simcall_execution_waitany_for(rexecs.get(), execs->size(), timeout);
+ int changed_pos = simcall_execution_waitany_for(rexecs.data(), rexecs.size(), timeout);
if (changed_pos != -1)
execs->at(changed_pos)->release_dependencies();
return changed_pos;
unsigned int simcall_comm_waitany(simgrid::kernel::activity::ActivityImplPtr comms[], size_t count,
double timeout) // XBT_ATTRIB_DEPRECATED_v330
{
- auto rcomms = std::make_unique<simgrid::kernel::activity::CommImpl*[]>(count);
- std::transform(comms, comms + count, rcomms.get(), [](const simgrid::kernel::activity::ActivityImplPtr& comm) {
+ std::vector<simgrid::kernel::activity::CommImpl*> rcomms(count);
+ std::transform(comms, comms + count, begin(rcomms), [](const simgrid::kernel::activity::ActivityImplPtr& comm) {
return static_cast<simgrid::kernel::activity::CommImpl*>(comm.get());
});
- return simcall_BODY_comm_waitany(rcomms.get(), count, timeout);
+ return simcall_BODY_comm_waitany(rcomms.data(), rcomms.size(), timeout);
}
unsigned int simcall_comm_waitany(simgrid::kernel::activity::CommImpl* comms[], size_t count, double timeout)
{
if (count == 0)
return -1;
- auto rcomms = std::make_unique<simgrid::kernel::activity::CommImpl*[]>(count);
- std::transform(comms, comms + count, rcomms.get(), [](const simgrid::kernel::activity::ActivityImplPtr& comm) {
+ std::vector<simgrid::kernel::activity::CommImpl*> rcomms(count);
+ std::transform(comms, comms + count, begin(rcomms), [](const simgrid::kernel::activity::ActivityImplPtr& comm) {
return static_cast<simgrid::kernel::activity::CommImpl*>(comm.get());
});
- return simcall_BODY_comm_testany(rcomms.get(), count);
+ return simcall_BODY_comm_testany(rcomms.data(), rcomms.size());
}
int simcall_comm_testany(simgrid::kernel::activity::CommImpl* comms[], size_t count)