X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/6bc18b576fa4a890d8b9916d292ca67dfbf60dd3..937f2eb5b429c3c03fc989a25fbc26fabd0cf529:/examples/msg/platform-failures/platform-failures.c diff --git a/examples/msg/platform-failures/platform-failures.c b/examples/msg/platform-failures/platform-failures.c index 7771e50925..f1d5d5baa3 100644 --- a/examples/msg/platform-failures/platform-failures.c +++ b/examples/msg/platform-failures/platform-failures.c @@ -25,13 +25,13 @@ static int master(int argc, char *argv[]) for (i = 0; i < number_of_tasks; i++) { char mailbox[256]; snprintf(mailbox, 255, "worker-%ld", i % workers_count); - + XBT_INFO("Send a message to %s", mailbox); msg_task_t task = MSG_task_create("Task", task_comp_size, task_comm_size, xbt_new0(double, 1)); *((double *) task->data) = MSG_get_clock(); switch ( MSG_task_send_with_timeout(task,mailbox,10.0) ) { case MSG_OK: - XBT_INFO("Send completed"); + XBT_INFO("Send to %s completed", mailbox); break; case MSG_HOST_FAILURE: @@ -103,21 +103,20 @@ static int worker(int argc, char *argv[]) while (1) { double time1 = MSG_get_clock(); msg_task_t task = NULL; + XBT_INFO("Waiting a message on %s", mailbox); int retcode = MSG_task_receive( &(task), mailbox); double time2 = MSG_get_clock(); if (retcode == MSG_OK) { - XBT_INFO("Received \"%s\"", MSG_task_get_name(task)); if (MSG_task_get_data(task) == FINALIZE) { MSG_task_destroy(task); break; } if (time1 < *((double *) task->data)) time1 = *((double *) task->data); - XBT_INFO("Communication time : \"%f\"", time2 - time1); - XBT_INFO("Processing \"%s\"", MSG_task_get_name(task)); + XBT_INFO("Start execution..."); retcode = MSG_task_execute(task); if (retcode == MSG_OK) { - XBT_INFO("\"%s\" done", MSG_task_get_name(task)); + XBT_INFO("Execution complete."); free(task->data); MSG_task_destroy(task); } else if (retcode == MSG_HOST_FAILURE) {