X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/dab3029067ba2677a42fb2f4f2c3b3b2f71e33c2..7cf68ae88d84d10a4afde2c9a564856fecda7666:/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 86199c85b7..754264b097 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 @@ -1,10 +1,9 @@ -/* Copyright (c) 2010-2015. The SimGrid Team. - * All rights reserved. */ +/* Copyright (c) 2010-2017. 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. */ -#include "simgrid/msg.h" /* Yeah! If you want to use msg, you need to include simgrid/msg.h */ +#include "simgrid/msg.h" XBT_LOG_NEW_DEFAULT_CATEGORY(msg_test, "Messages specific for this msg example"); @@ -13,10 +12,9 @@ int tasks_done = 0; static 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())); + XBT_INFO(" Start daemon on %s (%f)", MSG_host_get_name(MSG_host_self()), MSG_host_get_speed(MSG_host_self())); for(;;){ - task = MSG_task_create("daemon", MSG_get_host_speed(MSG_host_self()), 0, NULL); + 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); @@ -38,10 +36,9 @@ static int process_sleep(int argc, char *argv[]) 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_t 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); @@ -72,8 +69,6 @@ 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; @@ -103,7 +98,7 @@ 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, 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"); @@ -179,7 +174,7 @@ static 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", 1, 2048, 125, dpRate); MSG_vm_start(vm0); argvF = xbt_new(char*, 2);