xbt_fifo_t *pending_send_request_queues;
xbt_fifo_t *received_message_queues;
+ smx_process_t *main_processes;
smx_process_t *sender_processes;
smx_process_t *receiver_processes;
smpi_receiver, hdata,
SIMIX_host_get_name(SIMIX_host_self()), 0, NULL,
/*props */ NULL);
+
+ smpi_global->main_processes[hdata->index] = SIMIX_process_self();
return;
}
smpi_global->received_message_queues = xbt_new(xbt_fifo_t, size);
// sender/receiver processes
+ smpi_global->main_processes = xbt_new(smx_process_t, size);
smpi_global->sender_processes = xbt_new(smx_process_t, size);
smpi_global->receiver_processes = xbt_new(smx_process_t, size);
smpi_do_once_duration_node_t curr, next;
// processes
+ xbt_free(smpi_global->main_processes);
xbt_free(smpi_global->sender_processes);
xbt_free(smpi_global->receiver_processes);