X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/0f5aaf299f85e9347fa65abc98fd03d0555cc254..636461fcc168ebfae791028c0826a3e03947d906:/teshsuite/msg/host_on_off_processes/host_on_off_processes.c diff --git a/teshsuite/msg/host_on_off_processes/host_on_off_processes.c b/teshsuite/msg/host_on_off_processes/host_on_off_processes.c index c6e82220cb..83071fbd5f 100644 --- a/teshsuite/msg/host_on_off_processes/host_on_off_processes.c +++ b/teshsuite/msg/host_on_off_processes/host_on_off_processes.c @@ -4,31 +4,73 @@ /* 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. */ -#include #include "simgrid/msg.h" /* Yeah! If you want to use msg, you need to include simgrid/msg.h */ -#include "xbt/sysdep.h" /* calloc, printf */ -/* Create a log channel to have nice outputs. */ -#include "xbt/log.h" -#include "xbt/asserts.h" -XBT_LOG_NEW_DEFAULT_CATEGORY(msg_test, - "Messages specific for this msg example"); - -int test_launcher(int argc, char *argv[]); -int process_daemon(int argc, char *argv[]); -int process_sleep(int argc, char *argv[]); -int commRX(int argc, char *argv[]); -int commTX(int argc, char *argv[]); +XBT_LOG_NEW_DEFAULT_CATEGORY(msg_test, "Messages specific for this msg example"); xbt_dynar_t tests; int tasks_done = 0; -int test_launcher(int argc, char *argv[]) +static int process_daemon(int argc, char *argv[]) +{ + XBT_INFO(" Start daemon on %s (%f)", MSG_host_get_name(MSG_host_self()), MSG_host_get_speed(MSG_host_self())); + for(;;){ + msg_task_t task = MSG_task_create("daemon", MSG_host_get_speed(MSG_host_self()), 0, NULL); + XBT_INFO(" Execute daemon"); + MSG_task_execute(task); + MSG_task_destroy(task); + tasks_done ++; + } + XBT_INFO(" daemon done. See you!"); + return 0; +} + +static int process_sleep(int argc, char *argv[]) +{ + for(;;){ + XBT_INFO(" I'm alive but I should sleep"); + MSG_process_sleep(10); + } + XBT_INFO(" I'm done. See you!"); + return 0; +} + +static int commTX(int argc, char *argv[]) +{ + msg_task_t task = NULL; + const char * mailbox = "comm"; + XBT_INFO(" Start TX"); + task = MSG_task_create("COMM", 0, 100000000, NULL); + MSG_task_isend(task, mailbox); + // We should wait a bit (if not the process will end before the communication, hence an exception on the other side). + MSG_process_sleep(30); + XBT_INFO(" TX done"); + return 0; +} + +static int commRX(int argc, char *argv[]) +{ + msg_task_t task = NULL; + const char * mailbox = "comm"; + XBT_INFO(" Start RX"); + msg_error_t error = MSG_task_receive(&(task), mailbox); + if (error==MSG_OK) { + XBT_INFO(" Receive message: %s", task->name); + } else if (error==MSG_HOST_FAILURE) { + XBT_INFO(" Receive message: HOST_FAILURE"); + } else if (error==MSG_TRANSFER_FAILURE) { + XBT_INFO(" Receive message: TRANSFERT_FAILURE"); + } else { + XBT_INFO(" Receive message: %d", error); + } + XBT_INFO(" RX Done"); + return 0; +} + +static int test_launcher(int argc, char *argv[]) { int test = 0; char **argvF; - argvF = xbt_new(char*, 2); - argvF[0] = xbt_strdup("process_daemon"); msg_host_t jupiter = MSG_host_by_name("Jupiter"); test = 1; @@ -58,14 +100,16 @@ 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, WTF ?!(number of Process : %d, it should be 1)", MSG_process_get_number()); + 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("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()); } test = 3; @@ -86,7 +130,8 @@ int test_launcher(int argc, char *argv[]) test = 4; if (xbt_dynar_search_or_negative(tests, &test)!=-1){ - XBT_INFO("Test 4 (turn off src during a communication) : Create a Process/task to make a communication between Jupiter and Tremblay and turn off Jupiter during the communication"); + XBT_INFO("Test 4 (turn off src during a communication) : Create a Process/task to make a communication between " + "Jupiter and Tremblay and turn off Jupiter during the communication"); MSG_host_on(jupiter); MSG_process_sleep(10); argvF = xbt_new(char*, 2); @@ -99,12 +144,14 @@ int test_launcher(int argc, char *argv[]) MSG_process_sleep(10); XBT_INFO(" Turn Jupiter off"); MSG_host_off(jupiter); - XBT_INFO("Test 4 seems ok (number of Process : %d, it should be 1 or 2 if RX has not been satisfied) cool, you can now turn off a node that has a process paused by a sleep call", MSG_process_get_number()); + XBT_INFO("Test 4 seems ok (number of Process : %d, it should be 1 or 2 if RX has not been satisfied) cool, you " + "can now turn off a node that has a process paused by a sleep call", MSG_process_get_number()); } test = 5; if (xbt_dynar_search_or_negative(tests, &test)!=-1){ - XBT_INFO("Test 5 (turn off dest during a communication : Create a Process/task to make a communication between Tremblay and Jupiter and turn off Jupiter during the communication"); + XBT_INFO("Test 5 (turn off dest during a communication : Create a Process/task to make a communication between " + "Tremblay and Jupiter and turn off Jupiter during the communication"); MSG_host_on(jupiter); MSG_process_sleep(10); argvF = xbt_new(char*, 2); @@ -129,7 +176,7 @@ int test_launcher(int argc, char *argv[]) msg_vm_t vm0; msg_process_t daemon; - vm0 = MSG_vm_create (jupiter, "vm0", 1, 2048, 125, NULL, -1, 125, dpRate); + vm0 = MSG_vm_create(jupiter, "vm0", 2048, 125, dpRate); MSG_vm_start(vm0); argvF = xbt_new(char*, 2); @@ -152,103 +199,24 @@ int test_launcher(int argc, char *argv[]) MSG_vm_shutdown(vm0); XBT_INFO(" Destroy vm0"); MSG_vm_destroy(vm0); - XBT_INFO("Test 6 is also weird: when the node Jupiter is turned off once again, the VM and its daemon are not killed. However, the issue regarding the shutdown of hosted VMs can be seen a feature not a bug ;)"); - } - - test = 7; - if (xbt_dynar_search_or_negative(tests, &test)!=-1){ - - } - - test = 8; - if (xbt_dynar_search_or_negative(tests, &test)!=-1){ - + XBT_INFO("Test 6 is also weird: when the node Jupiter is turned off once again, the VM and its daemon are not " + "killed. However, the issue regarding the shutdown of hosted VMs can be seen a feature not a bug ;)"); } - test = 9; - if (xbt_dynar_search_or_negative(tests, &test)!=-1){ - - } XBT_INFO(" Test done. See you!"); return 0; } -int process_daemon(int argc, char *argv[]) -{ - msg_task_t task = NULL; - XBT_INFO(" Start daemon on %s (%f)", MSG_host_get_name(MSG_host_self()), MSG_get_host_speed(MSG_host_self())); - for(;;){ - task = MSG_task_create("daemon", MSG_get_host_speed(MSG_host_self()), 0, NULL); - XBT_INFO(" Execute daemon"); - MSG_task_execute(task); - MSG_task_destroy(task); - tasks_done ++; - } - XBT_INFO(" daemon done. See you!"); - return 0; -} - -int process_sleep(int argc, char *argv[]) -{ - for(;;){ - XBT_INFO(" I'm alive but I should sleep"); - MSG_process_sleep(10); - } - XBT_INFO(" I'm done. See you!"); - return 0; -} - -int commTX(int argc, char *argv[]) -{ - msg_task_t task = NULL; - char mailbox[80]; - sprintf(mailbox, "comm"); - XBT_INFO(" Start TX"); - task = MSG_task_create("COMM", 0, 100000000, NULL); - MSG_task_isend(task, mailbox); - // We should wait a bit (if not the process will end before the communication, leading to an exception at the other side). - MSG_process_sleep(30); - XBT_INFO(" TX done"); - return 0; -} - -int commRX(int argc, char *argv[]) -{ - msg_task_t task = NULL; - char mailbox[80]; - sprintf(mailbox, "comm"); - XBT_INFO(" Start RX"); - msg_error_t error = MSG_task_receive(&(task), mailbox); - if (error==MSG_OK) { - XBT_INFO(" Receive message: %s", task->name); - } else if (error==MSG_HOST_FAILURE) { - XBT_INFO(" Receive message: HOST_FAILURE"); - } else if (error==MSG_TRANSFER_FAILURE) { - XBT_INFO(" Receive message: TRANSFERT_FAILURE"); - } else { - XBT_INFO(" Receive message: %d", error); - } - XBT_INFO(" RX Done"); - return 0; -} - -/** Main function */ int main(int argc, char *argv[]) { msg_error_t res; - const char *platform_file; - const char *application_file; MSG_init(&argc, argv); - if (argc != 4) { - printf("Usage: %s platform_file deployment_file test_number\n", argv[0]); - printf("example: %s msg_platform.xml msg_deployment.xml 1\n", argv[0]); - exit(1); - } + xbt_assert(argc == 3,"Usage: %s platform_file test_number\n\tExample: %s msg_platform.xml 1\n", argv[0], argv[0]); unsigned int iter; char *groups; - xbt_dynar_t s_tests = xbt_str_split(argv[3], ","); + xbt_dynar_t s_tests = xbt_str_split(argv[2], ","); int tmp_test = 0; tests = xbt_dynar_new(sizeof(int), NULL); xbt_dynar_foreach(s_tests, iter, groups) { @@ -257,22 +225,13 @@ int main(int argc, char *argv[]) } xbt_dynar_free(&s_tests); - platform_file = argv[1]; - application_file = argv[2]; + MSG_create_environment(argv[1]); - { /* Simulation setting */ - MSG_create_environment(platform_file); - } - { /* Application deployment */ - MSG_function_register("test_launcher", test_launcher); - MSG_function_register("process_daemon", process_daemon); - MSG_function_register("process_sleep", process_sleep); + MSG_process_create("test_launcher", test_launcher, NULL, MSG_get_host_by_name("Tremblay")); - MSG_launch_application(application_file); - } res = MSG_main(); XBT_INFO("Simulation time %g", MSG_get_clock()); return res != MSG_OK; -} /* end_of_main */ +}