X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/2ddab1a7a92fa2a458963cf9dc8dd5d2da30283e..53cc4a3aa4b84e658bba280f083a872eb1810b97:/examples/msg/msg_test.c diff --git a/examples/msg/msg_test.c b/examples/msg/msg_test.c index f8841cb44f..8e7f54da81 100644 --- a/examples/msg/msg_test.c +++ b/examples/msg/msg_test.c @@ -5,16 +5,9 @@ /* 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. */ -/** \file msg_test.c - * \ingroup MSG_examples - * \brief Simulation of a master-slave application using a realistic platform - * and an external description of the deployment. -*/ +#include "msg/msg.h" /* Yeah! If you want to use msg, you need to include msg/msg.h */ -/** Yeah! If you want to use msg, you need to include msg/msg.h */ -#include "msg/msg.h" - -/** This includes creates a log channel for to have nice outputs. */ +/* Create a log channel to have nice outputs. */ #include "xbt/log.h" XBT_LOG_NEW_DEFAULT_CATEGORY(msg_test,"Messages specific for this msg example"); @@ -23,14 +16,12 @@ int slave(int argc, char *argv[]); int forwarder(int argc, char *argv[]); void test_all(const char *platform_file, const char *application_file); - typedef enum { PORT_22 = 0, MAX_CHANNEL } channel_t; -/** Print arguments - * This function is just used so that users can check that each process +/* This function is just used so that users can check that each process * has received the arguments it was supposed to receive. */ static void print_args(int argc, char** argv) @@ -43,21 +34,7 @@ static void print_args(int argc, char** argv) fprintf(stderr,">\n"); } -/** Emitter function - * This function has to be assigned to a m_process_t that will behave as the master. - It should not be called directly but either given as a parameter to - #MSG_process_create() or registered as a public function through - #MSG_function_register() and then automatically assigned to a process through - #MSG_launch_application(). - - C style arguments (argc/argv) are interpreted as - \li the number of tasks to distribute - \li the computation size of each task - \li the size of the files associated to each task - \li a list of host that will accept those tasks. - - Tasks are dumbly sent in a round-robin style. - */ +/** Emitter function */ int master(int argc, char *argv[]) { int slaves_count = 0; @@ -105,34 +82,29 @@ int master(int argc, char *argv[]) INFO1("Got %d slave(s) :", slaves_count); for (i = 0; i < slaves_count; i++) - INFO1("\t %s", slaves[i]->name); + VERB1("\t %s", slaves[i]->name); INFO1("Got %d task to process :", number_of_tasks); for (i = 0; i < number_of_tasks; i++) - INFO1("\t\"%s\"", todo[i]->name); + VERB1("\t\"%s\"", todo[i]->name); for (i = 0; i < number_of_tasks; i++) { - INFO2("Sending \"%s\" to \"%s\"", + VERB2("Sending \"%s\" to \"%s\"", todo[i]->name, slaves[i % slaves_count]->name); MSG_task_put(todo[i], slaves[i % slaves_count], PORT_22); - INFO0("Send completed"); + DEBUG0("Send completed"); } INFO0("All tasks have been dispatched. Bye!"); free(slaves); free(todo); return 0; -} +} /* end_of_master */ -/** Receiver function - * This function has to be assigned to a #m_process_t that has to behave as a slave. - Just like #master(), it should not be called directly. - - This function keeps waiting for tasks and executes them as it receives them. - */ +/** Receiver function */ int slave(int argc, char *argv[]) { print_args(argc,argv); @@ -143,9 +115,9 @@ int slave(int argc, char *argv[]) a = MSG_task_get(&(task), PORT_22); if (a == MSG_OK) { INFO1("Received \"%s\" ", task->name); - INFO1("Processing \"%s\" ", task->name); + DEBUG1("Processing \"%s\" ", task->name); MSG_task_execute(task); - INFO1("\"%s\" done ", task->name); + VERB1("\"%s\" done ", task->name); MSG_task_destroy(task); } else { INFO0("Hey ?! What's up ? "); @@ -154,17 +126,9 @@ int slave(int argc, char *argv[]) } INFO0("I'm done. See you!"); return 0; -} - -/** Receiver function - * This function has to be assigned to a #m_process_t that has to behave as a forwarder. - Just like #master(), it should not be called directly. +} /* end_of_slave */ - C style arguments (argc/argv) are interpreted as a list of host - that will accept those tasks. - - This function keeps waiting for tasks and dispathes them to its slaves. - */ +/** Receiver function */ int forwarder(int argc, char *argv[]) { int i; @@ -206,22 +170,10 @@ int forwarder(int argc, char *argv[]) INFO0("I'm done. See you!"); return 0; -} +} /* end_of_forwarder */ -/** Test function - * This function is the core of the simulation and is divided only into 3 parts - * thanks to MSG_create_environment() and MSG_launch_application(). - * -# Simulation settings : MSG_create_environment() creates a realistic - * environment - * -# Application deployment : create the agents on the right locations with - * MSG_launch_application() - * -# The simulation is run with #MSG_main() - * @param platform_file the name of a file containing an valid surfxml platform - * description. - * @param application_file the name of a file containing a valid surfxml application - * description - */ +/** Test function */ void test_all(const char *platform_file,const char *application_file) { { /* Simulation setting */ @@ -238,13 +190,10 @@ void test_all(const char *platform_file,const char *application_file) MSG_main(); INFO1("Simulation time %g",MSG_getClock()); -} +} /* end_of_test_all */ -/** Main function - * This initializes MSG, runs a simulation, and free all data-structures created - * by MSG. - */ +/** Main function */ int main(int argc, char *argv[]) { MSG_global_init_args(&argc,argv); @@ -256,4 +205,4 @@ int main(int argc, char *argv[]) test_all(argv[1],argv[2]); MSG_clean(); return (0); -} +} /* end_of_main */