X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/ea2e2f84bb9c4d52951666f7f7136213483523a2..4bd1f48f0bf1ad1703be680ec2a38d626c6a2668:/src/msg/msg_actions.cpp diff --git a/src/msg/msg_actions.cpp b/src/msg/msg_actions.cpp index 6edbf1b5ea..917c86883e 100644 --- a/src/msg/msg_actions.cpp +++ b/src/msg/msg_actions.cpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2009-2015. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2009-2017. 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. */ @@ -6,7 +6,7 @@ #include "src/msg/msg_private.h" #include "xbt/replay.hpp" -#include +#include XBT_LOG_NEW_DEFAULT_SUBCATEGORY(msg_action, msg, "MSG actions for trace driven simulation"); @@ -14,13 +14,12 @@ SG_BEGIN_DECL() void MSG_action_init() { - _xbt_replay_action_init(); - MSG_function_register_default(xbt_replay_action_runner); + MSG_function_register_default(simgrid::xbt::replay_runner); } void MSG_action_exit() { - _xbt_replay_action_exit(); + // Nothing to do anymore here } /** \ingroup msg_trace_driven @@ -31,22 +30,18 @@ void MSG_action_exit() */ msg_error_t MSG_action_trace_run(char *path) { - msg_error_t res; - char *name; - xbt_dynar_t todo; - xbt_dict_cursor_t cursor; - if (path) { simgrid::xbt::action_fs = new std::ifstream(path, std::ifstream::in); } - res = MSG_main(); - if (!xbt_dict_is_empty(xbt_action_queues)) { + msg_error_t res = MSG_main(); + + if (not simgrid::xbt::action_queues.empty()) { XBT_WARN("Not all actions got consumed. If the simulation ended successfully (without deadlock)," " you may want to add new processes to your deployment file."); - xbt_dict_foreach(xbt_action_queues, cursor, name, todo) { - XBT_WARN("Still %lu actions for %s", xbt_dynar_length(todo), name); + for (auto const& actions_of : simgrid::xbt::action_queues) { + XBT_WARN("Still %zu actions for %s", actions_of.second->size(), actions_of.first.c_str()); } } @@ -55,9 +50,6 @@ msg_error_t MSG_action_trace_run(char *path) simgrid::xbt::action_fs = nullptr; } - xbt_dict_free(&xbt_action_queues); - xbt_action_queues = xbt_dict_new_homogeneous(nullptr); - return res; }