Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
better than static casting, use a container
[simgrid.git] / src / msg / msg_actions.cpp
1 /* Copyright (c) 2009-2015. The SimGrid Team. All rights reserved.          */
2
3 /* This program is free software; you can redistribute it and/or modify it
4  * under the terms of the license (GNU LGPL) which comes with this package. */
5
6 #include "src/msg/msg_private.h"
7 #include "xbt/replay.hpp"
8
9 #include <errno.h>
10
11 XBT_LOG_NEW_DEFAULT_SUBCATEGORY(msg_action, msg, "MSG actions for trace driven simulation");
12
13 SG_BEGIN_DECL()
14
15 void MSG_action_init()
16 {
17   simgrid::xbt::replay_init();
18   MSG_function_register_default(simgrid::xbt::replay_runner);
19 }
20
21 void MSG_action_exit()
22 {
23   simgrid::xbt::replay_exit();
24 }
25
26 /** \ingroup msg_trace_driven
27  * \brief A trace loader
28  *
29  *  If path!=nullptr, load a trace file containing actions, and execute them.
30  *  Else, assume that each process gets the path in its deployment file
31  */
32 msg_error_t MSG_action_trace_run(char *path)
33 {
34   if (path) {
35     simgrid::xbt::action_fs = new std::ifstream(path, std::ifstream::in);
36   }
37
38   msg_error_t res = MSG_main();
39
40   if (!simgrid::xbt::action_queues.empty()) {
41     XBT_WARN("Not all actions got consumed. If the simulation ended successfully (without deadlock),"
42              " you may want to add new processes to your deployment file.");
43
44     for (auto actions_of : simgrid::xbt::action_queues) {
45       XBT_WARN("Still %zu actions for %s", actions_of.second->size(), actions_of.first.c_str());
46     }
47   }
48
49   if (path) {
50     delete simgrid::xbt::action_fs;
51     simgrid::xbt::action_fs = nullptr;
52   }
53
54   return res;
55 }
56
57 SG_END_DECL()