X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/dda3ca8a409584cb8939acbd287d69912d247622..14b05fb84012709086290492445a2154c69b673b:/examples/msg/icomms/peer2.c diff --git a/examples/msg/icomms/peer2.c b/examples/msg/icomms/peer2.c index 8de9a03fcf..01d03c6bf0 100644 --- a/examples/msg/icomms/peer2.c +++ b/examples/msg/icomms/peer2.c @@ -33,7 +33,7 @@ int sender(int argc, char *argv[]) double task_comm_size = atof(argv[3]); long receivers_count = atol(argv[4]); - xbt_dynar_t comms = xbt_dynar_new(sizeof(msg_comm_t), NULL); + msg_comm_t *comm = xbt_new(msg_comm_t, number_of_tasks + receivers_count); int i; msg_task_t task = NULL; for (i = 0; i < number_of_tasks; i++) { @@ -44,22 +44,22 @@ int sender(int argc, char *argv[]) task = MSG_task_create(sprintf_buffer, task_comp_size, task_comm_size, NULL); - xbt_dynar_push_as(comms, msg_comm_t, MSG_task_isend(task, mailbox)); + comm[i] = MSG_task_isend(task, mailbox); XBT_INFO("Send to receiver-%ld Task_%d", i % receivers_count, i); } for (i = 0; i < receivers_count; i++) { char mailbox[80]; sprintf(mailbox, "receiver-%ld", i % receivers_count); task = MSG_task_create("finalize", 0, 0, 0); - xbt_dynar_push_as(comms, msg_comm_t, MSG_task_isend(task, mailbox)); + comm[i + number_of_tasks] = MSG_task_isend(task, mailbox); XBT_INFO("Send to receiver-%ld finalize", i % receivers_count); } /* Here we are waiting for the completion of all communications */ - MSG_comm_waitall(comms, -1); + MSG_comm_waitall(comm, (number_of_tasks + receivers_count), -1); XBT_INFO("Goodbye now!"); - xbt_dynar_free(&comms); + xbt_free(comm); return 0; } /* end_of_sender */