});
/* 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++;
double flops_amount = 0.0; /* Computation size */
msg_process_t sender = nullptr;
msg_process_t receiver = nullptr;
- msg_host_t source = nullptr;
double priority = 1.0;
double bound = 0.0; /* Capping for CPU resource, or 0 for no capping */
/** @brief Returns the source (the sender's host) of the given task */
msg_host_t MSG_task_get_source(msg_task_t task)
{
- return task->simdata->source;
+ return task->simdata->sender->get_host();
}
/** @brief Returns the name of the given task. */
{
parallel_execute(hosts, flops_amounts, bytes_amounts, -1);
}
+
void parallel_execute(const std::vector<s4u::Host*>& hosts, const std::vector<double>& flops_amounts,
const std::vector<double>& bytes_amounts, double timeout)
{