sg_host_t host = MSG_process_get_host(MSG_process_self());
simdata->compute = simgrid::simix::simcall([task, host] {
return simgrid::kernel::activity::ExecImplPtr(
- new simgrid::kernel::activity::ExecImpl(task->name ?: "", task->category ?: "",
- /*timeout_detector*/ nullptr, host));
+ new simgrid::kernel::activity::ExecImpl(task->name ?: "", task->category ?: "", host));
});
/* checking for infinite values */
xbt_assert(std::isfinite(simdata->flops_amount), "flops_amount is not finite!");
- xbt_assert(std::isfinite(simdata->priority), "priority is not finite!");
simdata->compute->start(simdata->flops_amount, simdata->priority, simdata->bound);
}
/* Prepare the task to send */
t_simdata = task->simdata;
t_simdata->sender = myself;
- t_simdata->source = MSG_host_self();
t_simdata->set_used();
t_simdata->comm = nullptr;
msg_global->sent_msg++;
/* Prepare the task to send */
simdata_task_t t_simdata = task->simdata;
t_simdata->sender = MSG_process_self();
- t_simdata->source = MSG_host_self();
t_simdata->set_used();
msg_global->sent_msg++;