examples/smpi/replay_multiple/replay_multiple.c

   1 /* Copyright (c) 2009-2015. The SimGrid Team.
   2  * All rights reserved.                                                     */
   3
   4 /* This program is free software; you can redistribute it and/or modify it
   5  * under the terms of the license (GNU LGPL) which comes with this package. */
   6
   7 #include <stdio.h>
   8 #include "simgrid/msg.h"            /* Yeah! If you want to use msg, you need to include simgrid/msg.h */
   9 #include "xbt/sysdep.h"         /* calloc, printf */
  10 #include "mpi.h"
  11 /* Create a log channel to have nice outputs. */
  12 #include "xbt/log.h"
  13 #include "xbt/asserts.h"
  14 #include "smpi/smpi.h"
  15 XBT_LOG_NEW_DEFAULT_CATEGORY(msg_test,
  16                 "Messages specific for this msg example");
  17
  18 static int smpi_replay(int argc, char *argv[]) {
  19         smpi_replay_run(&argc, &argv);
  20         return 0;
  21 }
  22
  23 int main(int argc, char *argv[]){
  24         msg_error_t res;
  25         const char *platform_file;
  26         const char *application_file;
  27         const char *description_file;
  28
  29         MSG_init(&argc, argv);
  30
  31         if (argc < 4) {
  32                 printf("Usage: %s description_file platform_file deployment_file\n", argv[0]);
  33                 printf("example: %s smpi_multiple_apps msg_platform.xml msg_deployment.xml\n", argv[0]);
  34                 exit(1);
  35         }
  36         description_file = argv[1];
  37         platform_file = argv[2];
  38         application_file = argv[3];
  39
  40
  41         /*  Simulation setting */
  42         MSG_create_environment(platform_file);
  43
  44         /*   Application deployment: read the description file in order to identify instances to launch */
  45         FILE* fp = fopen(description_file, "r");
  46         if (fp == NULL)
  47                 xbt_die("Cannot open %s", description_file);
  48         ssize_t read;
  49         char     *line = NULL;
  50         size_t n         = 0;
  51         int instance_size = 0;
  52         const char* instance_id = NULL;
  53         while ((read = xbt_getline(&line, &n, fp)) != -1 ){
  54                 xbt_dynar_t elems = xbt_str_split_quoted_in_place(line);
  55                 if(xbt_dynar_length(elems)<3){
  56                         xbt_die ("Not enough elements in the line");
  57                 }
  58
  59                 const char** line_char= xbt_dynar_to_array(elems);
  60                 instance_id = line_char[0];
  61                 instance_size = atoi(line_char[2]);
  62
  63                 XBT_INFO("Initializing instance %s of size %d", instance_id, instance_size);
  64                 SMPI_app_instance_register(instance_id, smpi_replay,instance_size);
  65
  66                 xbt_free(line_char);
  67         }
  68
  69         MSG_launch_application(application_file);
  70         SMPI_init();
  71
  72         res = MSG_main();
  73
  74         XBT_INFO("Simulation time %g", MSG_get_clock());
  75
  76         SMPI_finalize();
  77         if (res == MSG_OK)
  78                 return 0;
  79         else
  80                 return 1;
  81
  82 }