X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/71daf4c9813145587e68d18293e8043193b00915..eb5b6b0c3c4d9a38bb205b2c8bc9aeeba8674a25:/src/xbt/xbt_replay.c diff --git a/src/xbt/xbt_replay.c b/src/xbt/xbt_replay.c index dd5bda1bd5..f3a9fbcb79 100644 --- a/src/xbt/xbt_replay.c +++ b/src/xbt/xbt_replay.c @@ -1,4 +1,4 @@ -/* Copyright (c) 2010. The SimGrid Team. +/* Copyright (c) 2010, 2012-2014. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it @@ -10,6 +10,8 @@ #include "xbt/log.h" #include "xbt/str.h" #include "xbt/replay.h" +#include +#include XBT_LOG_NEW_DEFAULT_SUBCATEGORY(replay,xbt,"Replay trace reader"); @@ -29,14 +31,29 @@ xbt_dict_t action_queues; static char *action_line = NULL; static size_t action_len = 0; +int is_replay_active = 0 ; + static char **action_get_action(char *name); +static char *str_tolower (const char *str) +{ + char *ret = xbt_strdup (str); + int i, n = strlen (ret); + for (i = 0; i < n; i++) + ret[i] = tolower (str[i]); + return ret; +} + +int _xbt_replay_is_active(void){ + return is_replay_active; +} + xbt_replay_reader_t xbt_replay_reader_new(const char *filename) { xbt_replay_reader_t res = xbt_new0(s_xbt_replay_reader_t,1); res->fp = fopen(filename, "r"); - xbt_assert(res->fp != NULL, "Cannot open %s: %s", filename, - strerror(errno)); + if (res->fp == NULL) + xbt_die("Cannot open %s: %s", filename, strerror(errno)); res->filename = xbt_strdup(filename); return res; } @@ -96,7 +113,9 @@ void xbt_replay_reader_free(xbt_replay_reader_t *reader) */ void xbt_replay_action_register(const char *action_name, action_fun function) { - xbt_dict_set(action_funs, action_name, function, NULL); + char* lowername = str_tolower (action_name); + xbt_dict_set(action_funs, lowername, function, NULL); + xbt_free(lowername); } /** \ingroup XBT_replay @@ -106,11 +125,14 @@ void xbt_replay_action_register(const char *action_name, action_fun function) */ void xbt_replay_action_unregister(const char *action_name) { - xbt_dict_remove(action_funs, action_name); + char* lowername = str_tolower (action_name); + xbt_dict_remove(action_funs, lowername); + xbt_free(lowername); } void _xbt_replay_action_init(void) { + is_replay_active = 1; action_funs = xbt_dict_new_homogeneous(NULL); action_queues = xbt_dict_new_homogeneous(NULL); } @@ -135,8 +157,10 @@ int xbt_replay_action_runner(int argc, char *argv[]) if (action_fp) { // A unique trace file char **evt; while ((evt = action_get_action(argv[0]))) { + char* lowername = str_tolower (evt[1]); action_fun function = - (action_fun)xbt_dict_get(action_funs, evt[1]); + (action_fun)xbt_dict_get(action_funs, lowername); + xbt_free(lowername); function((const char **)evt); for (i=0;evt[i]!= NULL;i++) free(evt[i]); @@ -152,7 +176,9 @@ int xbt_replay_action_runner(int argc, char *argv[]) xbt_replay_reader_t reader = xbt_replay_reader_new(argv[1]); while ((evt=xbt_replay_reader_get(reader))) { if (!strcmp(argv[0],evt[0])) { - action_fun function = (action_fun)xbt_dict_get(action_funs, evt[1]); + char* lowername = str_tolower (evt[1]); + action_fun function = (action_fun)xbt_dict_get(action_funs, lowername); + xbt_free(lowername); function(evt); } else { XBT_WARN("%s: Ignore trace element not for me", @@ -193,7 +219,7 @@ static char **action_get_action(char *name) // if it's for me, I'm done evtname = xbt_dynar_get_as(evt, 0, char *); - if (!strcmp(name, evtname)) { + if (!strcasecmp(name, evtname)) { return xbt_dynar_to_array(evt); } else { // Else, I have to store it for the relevant colleague