X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/0821eaf865ee5431f938481ede3c2e77ef095f65..73662a7c0b0d1e462f2b99322183295be3a24a5a:/examples/msg/tracing/ms.c diff --git a/examples/msg/tracing/ms.c b/examples/msg/tracing/ms.c index df58acd05d..aed734ede0 100644 --- a/examples/msg/tracing/ms.c +++ b/examples/msg/tracing/ms.c @@ -1,4 +1,4 @@ -/* Copyright (c) 2010. The SimGrid Team. +/* Copyright (c) 2010-2014. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it @@ -6,7 +6,17 @@ /** @addtogroup MSG_examples * - * - tracing/ms.c TODO + * - tracing/ms.c This is a master/slave program where the master creates + * tasks, send them to the slaves. For each task received, the slave executes + * it and then destroys it. This program uses several tracing functions that + * enable the tracing of categorized resource utilization, the use of trace marks, + * and user variables associated to the hosts of the platform file. + * You might want to run this program with the following parameters: + * --cfg=tracing/categorized:yes + * --cfg=tracing/uncategorized:yes + * --cfg=viva/categorized:viva_cat.plist + * --cfg=viva/uncategorized:viva_uncat.plist + * (See \ref tracing_tracing_options for details) */ #include @@ -31,27 +41,27 @@ int master(int argc, char *argv[]) long slaves_count = atol(argv[4]); //setting the variable "is_master" (previously declared) to value 1 - TRACE_host_variable_set(MSG_host_self()->name, "is_master", 1); + TRACE_host_variable_set(MSG_host_get_name(MSG_host_self()), "is_master", 1); TRACE_mark("msmark", "start_send_tasks"); int i; for (i = 0; i < number_of_tasks; i++) { - m_task_t task = NULL; + msg_task_t task = NULL; task = MSG_task_create("task", task_comp_size, task_comm_size, NULL); //setting the variable "task_creation" to value i - TRACE_host_variable_set(MSG_host_self()->name, "task_creation", i); + TRACE_host_variable_set(MSG_host_get_name(MSG_host_self()), "task_creation", i); //setting the category of task to "compute" //the category of a task must be defined before it is sent or executed - TRACE_msg_set_task_category(task, "compute"); + MSG_task_set_category(task, "compute"); MSG_task_send(task, "master_mailbox"); } TRACE_mark("msmark", "finish_send_tasks"); for (i = 0; i < slaves_count; i++) { - m_task_t finalize = MSG_task_create("finalize", 0, 0, 0); - TRACE_msg_set_task_category(finalize, "finalize"); + msg_task_t finalize = MSG_task_create("finalize", 0, 0, 0); + MSG_task_set_category(finalize, "finalize"); MSG_task_send(finalize, "master_mailbox"); } @@ -61,9 +71,12 @@ int master(int argc, char *argv[]) /** Receiver function */ int slave(int argc, char *argv[]) { - m_task_t task = NULL; + msg_task_t task = NULL; - TRACE_host_variable_set(MSG_host_self()->name, "is_slave", 1); + TRACE_host_variable_set(MSG_host_get_name(MSG_host_self()), "is_slave", 1); + TRACE_host_variable_set(MSG_host_get_name(MSG_host_self()), + "task_computation", + 0); while (1) { MSG_task_receive(&(task), "master_mailbox"); @@ -73,7 +86,7 @@ int slave(int argc, char *argv[]) } //adding the value returned by MSG_task_get_compute_duration(task) //to the variable "task_computation" - TRACE_host_variable_add(MSG_host_self()->name, + TRACE_host_variable_add(MSG_host_get_name(MSG_host_self()), "task_computation", MSG_task_get_compute_duration(task)); MSG_task_execute(task); @@ -86,7 +99,7 @@ int slave(int argc, char *argv[]) /** Main function */ int main(int argc, char *argv[]) { - MSG_global_init(&argc, argv); + MSG_init(&argc, argv); if (argc < 3) { printf("Usage: %s platform_file deployment_file\n", argv[0]); exit(1); @@ -102,8 +115,10 @@ int main(int argc, char *argv[]) TRACE_host_variable_declare("task_creation"); TRACE_host_variable_declare("task_computation"); - //declaring user markers + //declaring user markers and values TRACE_declare_mark("msmark"); + TRACE_declare_mark_value ("msmark", "start_send_tasks"); + TRACE_declare_mark_value ("msmark", "finish_send_tasks"); //declaring user categories with RGB colors (values from 0 to 1) TRACE_category_with_color ("compute", "1 0 0"); //compute is red @@ -118,6 +133,27 @@ int main(int argc, char *argv[]) MSG_launch_application(deployment_file); MSG_main(); - MSG_clean(); + + unsigned int cursor; + xbt_dynar_t categories = TRACE_get_categories (); + if (categories){ + XBT_INFO ("Declared tracing categories:"); + char *category; + xbt_dynar_foreach (categories, cursor, category){ + XBT_INFO ("%s", category); + } + xbt_dynar_free (&categories); + } + + xbt_dynar_t marks = TRACE_get_marks (); + if (marks){ + XBT_INFO ("Declared marks:"); + char *mark; + xbt_dynar_foreach (marks, cursor, mark){ + XBT_INFO ("%s", mark); + } + xbt_dynar_free (&marks); + } + return 0; } /* end_of_main */