X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/29a3b2869c0075fc75e8ccc66fc1d9c4c8bf6a85..258864c23d070467ce222d3fa78aeb63e849c47c:/teshsuite/msg/host_on_off_processes/host_on_off_processes.cpp diff --git a/teshsuite/msg/host_on_off_processes/host_on_off_processes.cpp b/teshsuite/msg/host_on_off_processes/host_on_off_processes.cpp index 9d311e570e..b4a467a306 100644 --- a/teshsuite/msg/host_on_off_processes/host_on_off_processes.cpp +++ b/teshsuite/msg/host_on_off_processes/host_on_off_processes.cpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2010-2018. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2010-2019. The SimGrid Team. All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ @@ -15,8 +15,7 @@ int tasks_done = 0; static void task_cleanup_handler(void* task) { - if (task) - MSG_task_destroy(static_cast(task)); + MSG_task_destroy(static_cast(task)); } static int process_daemon(int /*argc*/, char** /*argv*/) @@ -27,13 +26,9 @@ static int process_daemon(int /*argc*/, char** /*argv*/) msg_task_t task = MSG_task_create("daemon", MSG_host_get_speed(MSG_host_self()), 0, NULL); MSG_process_set_data(self, task); XBT_INFO(" Execute daemon"); - msg_error_t res = MSG_task_execute(task); + MSG_task_execute(task); MSG_task_destroy(task); tasks_done++; - if (res == MSG_HOST_FAILURE) { - XBT_INFO("Host has died as expected, do nothing else"); - return 0; - } } XBT_INFO(" daemon done. See you!"); return 0; @@ -61,7 +56,7 @@ static int commRX(int /*argc*/, char** /*argv*/) XBT_INFO(" Start RX"); msg_error_t error = MSG_task_receive(&(task), mailbox); if (error == MSG_OK) { - XBT_INFO(" Receive message: %s", task->name); + XBT_INFO(" Receive message: %s", MSG_task_get_name(task)); MSG_task_destroy(task); } else if (error == MSG_HOST_FAILURE) { XBT_INFO(" Receive message: HOST_FAILURE"); @@ -97,7 +92,7 @@ static int test_launcher(int /*argc*/, char** /*argv*/) } test = 2; - // Create a process that on a host that is turned off (this should not be possible) + // Create a process that on a host that is turned off (this is not allowed) if (xbt_dynar_search_or_negative(tests, &test) != -1) { XBT_INFO("Test 2:"); XBT_INFO(" Turn off Jupiter"); @@ -108,21 +103,11 @@ static int test_launcher(int /*argc*/, char** /*argv*/) argvF[0] = xbt_strdup("process_daemon"); MSG_process_create_with_arguments("process_daemon", process_daemon, NULL, jupiter, 1, argvF); MSG_process_sleep(10); - XBT_INFO(" Test 2 does not crash as it should (number of Process : %d, it should be 1)", MSG_process_get_number()); - XBT_INFO(" Ok so let's turn on/off the node to see whether the process is correctly bound to Jupiter"); - MSG_host_on(jupiter); - XBT_INFO(" Turn off"); - MSG_host_off(jupiter); - XBT_INFO(" sleep"); - MSG_process_sleep(10); - XBT_INFO("number of Process : %d it should be 1. The daemon that has been created for test2 has been correctly " - "destroyed....ok at least it looks rigorous, cool ! You just have to disallow the possibility to create " - "a new process on a node when the node is off.)", - MSG_process_get_number()); + XBT_INFO(" Test 2 does crash as it should. This message will not be displayed."); } test = 3; - // Create a process running sucessive sleeps on a host and turn the host off during the execution of the process. + // Create a process running successive sleeps on a host and turn the host off during the execution of the process. if (xbt_dynar_search_or_negative(tests, &test) != -1) { xbt_die("Test 3 is superseeded by activity-lifecycle"); } @@ -224,6 +209,7 @@ int main(int argc, char* argv[]) MSG_create_environment(argv[1]); + MSG_process_set_data_cleanup(task_cleanup_handler); MSG_process_create("test_launcher", test_launcher, NULL, MSG_get_host_by_name("Tremblay")); res = MSG_main();