-void* recv(MailboxPtr chan) {
- void *res = nullptr;
- Comm& c = Comm::recv_init(chan);
- c.setDstData(&res,sizeof(res));
- c.wait();
- return res;
+void parallel_execute(int host_nb, sg_host_t* host_list, double* flops_amount, double* bytes_amount, double timeout)
+{
+ smx_activity_t s =
+ simcall_execution_parallel_start(nullptr, host_nb, host_list, flops_amount, bytes_amount, -1, timeout);
+ simcall_execution_wait(s);
+}
+
+void parallel_execute(int host_nb, sg_host_t* host_list, double* flops_amount, double* bytes_amount)
+{
+ smx_activity_t s = simcall_execution_parallel_start(nullptr, host_nb, host_list, flops_amount, bytes_amount, -1, -1);
+ simcall_execution_wait(s);
+}
+
+void* recv(MailboxPtr chan) // deprecated
+{
+ return chan->get();