X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/03c27179831733fff83ac0f341ce94b1be8be9ad..df54794d40fd920525d429df1913077a4beeb46a:/teshsuite/msg/task_destroy_cancel.c?ds=sidebyside diff --git a/teshsuite/msg/task_destroy_cancel.c b/teshsuite/msg/task_destroy_cancel.c index 6daa0d270d..c71f9cbeff 100644 --- a/teshsuite/msg/task_destroy_cancel.c +++ b/teshsuite/msg/task_destroy_cancel.c @@ -27,6 +27,8 @@ int master(int argc, char *argv[]) char mailbox[256]; msg_task_t task = NULL; msg_comm_t comm = NULL; + xbt_ex_t ex; + sprintf(mailbox, "jupi"); task = MSG_task_create("normal", task_comp_size, task_comm_size, NULL); @@ -45,11 +47,25 @@ int master(int argc, char *argv[]) comm = MSG_task_isend(task, mailbox); XBT_INFO("Canceling task \"%s\" during comm", task->name); MSG_task_cancel(task); + TRY { + MSG_comm_wait(comm, -1); + } + CATCH (ex) { + xbt_ex_free(ex); + MSG_comm_destroy(comm); + } task = MSG_task_create("finalize", task_comp_size, task_comm_size, NULL); comm = MSG_task_isend(task, mailbox); XBT_INFO("Destroying task \"%s\" during comm", task->name); MSG_task_destroy(task); + TRY { + MSG_comm_wait(comm, -1); + } + CATCH (ex) { + xbt_ex_free(ex); + MSG_comm_destroy(comm); + } task = MSG_task_create("cancel", task_comp_size, task_comm_size, NULL); MSG_task_send_with_timeout(task, mailbox, timeout); @@ -77,8 +93,7 @@ int slave(int argc, char *argv[]) _XBT_GNUC_UNUSED int res; int id = -1; char mailbox[80]; - _XBT_GNUC_UNUSED int read; - double duration, start, end; + double start, end; sprintf(mailbox, "jupi"); while (1) { @@ -100,7 +115,6 @@ int slave(int argc, char *argv[]) continue; } - duration = MSG_task_get_compute_duration(task); start = MSG_get_clock(); MSG_task_execute(task); end = MSG_get_clock();