- DEBUG2("%s: %s sends", name, process_name);
- sprintf(task_name, "%s_%s_p0", name, process_name);
- DEBUG1("put on %s", task_name);
- MSG_task_send(MSG_task_create(name, 0, parse_double(comm_size), NULL),
- task_name);
-
- MSG_task_receive(&task, name);
+ DEBUG2("%s: %s sends", allreduce_identifier, process_name);
+ sprintf(mailbox, "%s_%s_p0", allreduce_identifier, process_name);
+ DEBUG1("put on %s", mailbox);
+ MSG_task_send(MSG_task_create(allreduce_identifier, 0, comm_size, NULL),
+ mailbox);
+
+ sprintf(mailbox, "%s_p0_%s", allreduce_identifier, process_name);
+ MSG_task_receive(&task, mailbox);