X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/bf6e499b29ed3183f40b60fbcd0fe3caed12f197..347996b4a10c4e8579080692afa60e0afb88b60a:/examples/msg/parallel_task/parallel_task.c diff --git a/examples/msg/parallel_task/parallel_task.c b/examples/msg/parallel_task/parallel_task.c index c16de7212f..13866dd96c 100644 --- a/examples/msg/parallel_task/parallel_task.c +++ b/examples/msg/parallel_task/parallel_task.c @@ -1,93 +1,96 @@ -/* $Id$ */ - -/* Copyright (c) 2002,2003,2004 Arnaud Legrand. All rights reserved. */ +/* Copyright (c) 2007-2015. 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 -#include "msg/msg.h" /* Yeah! If you want to use msg, you need to include msg/msg.h */ -#include "xbt/sysdep.h" /* calloc, printf */ +#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"); +XBT_LOG_NEW_DEFAULT_CATEGORY(msg_test, + "Messages specific for this msg example"); + +/** @addtogroup MSG_examples + * + * - parallel_task/parallel_task.c: Demonstrates the use of + * @ref MSG_parallel_task_create, to create special tasks that run + * on several hosts at the same time. The resulting simulations are + * very close to what can be achieved in @ref SD_API, but still + * allows to use the other features of MSG (it'd be cool to be able + * to mix interfaces, but it's not possible ATM). + */ + + +/** Function in charge of running the example (that's a simgrid process) */ +static int runner(int argc, char *argv[]) +{ + int i, j; -int test(int argc, char *argv[]); -MSG_error_t test_all(const char *platform_file); + /* Retrieve the list of all hosts as an array of hosts */ + xbt_dynar_t slaves_dynar = MSG_hosts_as_dynar(); + int slaves_count = xbt_dynar_length(slaves_dynar); + msg_host_t *slaves = xbt_dynar_to_array(slaves_dynar); -/** Emitter function */ -int test(int argc, char *argv[]) -{ - int slaves_count = 0; - m_host_t *slaves = NULL; - double task_comp_size = 0; - double task_comm_size = 0; - double *computation_amount = NULL; - double *communication_amount = NULL; - m_task_t ptask = NULL; - int i,j; - - slaves_count = MSG_get_host_number(); - slaves = MSG_get_host_table(); - - computation_amount = calloc(slaves_count,sizeof(double)); - communication_amount = calloc(slaves_count*slaves_count,sizeof(double)); - - for(i=0;i 1, "Usage: %s ", argv[0]); + MSG_create_environment(argv[1]); - MSG_process_create("test",test,NULL,MSG_get_host_table()[0]); - res = MSG_main(); - - INFO1("Simulation time %g",MSG_get_clock()); - return res; -} + /* Pick a process, no matter which, from the platform file */ + xbt_dynar_t all_hosts = MSG_hosts_as_dynar(); + msg_host_t first_host = xbt_dynar_getfirst_as(all_hosts,msg_host_t); + xbt_dynar_free(&all_hosts); -int main(int argc, char *argv[]) -{ - MSG_error_t res = MSG_OK; - - MSG_global_init(&argc,argv); - if (argc < 2) { - printf ("Usage: %s platform_file\n",argv[0]); - printf ("example: %s msg_platform.xml\n",argv[0]); - exit(1); - } - res = test_all(argv[1]); - MSG_clean(); - - if(res==MSG_OK) - return 0; - else - return 1; + MSG_process_create("test", runner, NULL, first_host); + msg_error_t res = MSG_main(); + XBT_INFO("Simulation done."); + + return res != MSG_OK; }