X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/5ae6545bfb26cc43af8e66284b505d819b4804df..bac023bb1c1ebfc6909be7f4c1fd4927949eda1c:/src/gras/gras.c diff --git a/src/gras/gras.c b/src/gras/gras.c index b4a33a3e07..b0a652dfdb 100644 --- a/src/gras/gras.c +++ b/src/gras/gras.c @@ -1,136 +1,194 @@ -/* $Id$ */ - /* gras.c -- generic functions not fitting anywhere else */ -/* Copyright (c) 2003, 2004 Martin Quinson. */ -/* All rights reserved. */ +/* Copyright (c) 2004, 2005, 2006, 2007, 2008, 2009, 2010. 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 "xbt/log.h" -#include "xbt/module.h" /* xbt_init/exit */ +#include "xbt/virtu.h" /* set the XBT virtualization to use GRAS */ +#include "xbt/module.h" /* xbt_init/exit */ +#include "xbt/xbt_os_time.h" /* xbt_os_time */ +#include "xbt/synchro.h" +#include "xbt/socket.h" -#include "gras_modinter.h" /* module init/exit */ -#include "amok/amok_modinter.h" /* module init/exit */ -#include "xbt_modinter.h" /* module init/exit */ +#include "Virtu/virtu_interface.h" /* Module mechanism FIXME: deplace&rename */ +#include "Virtu/virtu_private.h" +#include "gras_modinter.h" /* module init/exit */ +#include "amok/amok_modinter.h" /* module init/exit */ +#include "xbt_modinter.h" /* module init/exit */ #include "gras.h" -#include "gras/process.h" /* FIXME: killme and put process_init in modinter */ - -#include "portable.h" /* hexa_*(); signalling stuff */ +#include "gras/process.h" /* FIXME: killme and put process_init in modinter */ +#include "gras/transport.h" +#include "gras/Msg/msg_private.h" +#include "portable.h" /* hexa_*(); signalling stuff */ -XBT_LOG_NEW_DEFAULT_SUBCATEGORY(gras,XBT_LOG_ROOT_CAT,"All GRAS categories (cf. section \ref GRAS_API)"); +XBT_LOG_NEW_DEFAULT_CATEGORY(gras, + "All GRAS categories (cf. section \\ref GRAS_API)"); static int gras_running_process = 0; - #if defined(HAVE_SIGNAL) && defined(HAVE_SIGNAL_H) -static void gras_sigusr_handler(int sig) { - INFO0("SIGUSR1 received. Display the backtrace"); - xbt_backtrace_display(); +static void gras_sigusr_handler(int sig) +{ + XBT_INFO("SIGUSR1 received. Display the backtrace"); + xbt_backtrace_display_current(); } -static void gras_sigint_handler(int sig) { - static double lastone = 0; - if (lastone == 0 || gras_os_time() - lastone > 5) { - lastone = gras_os_time(); - xbt_backtrace_display(); - fprintf(stderr,"\nBacktrace displayed because Ctrl-C was pressed. Press again (within 5 sec) to abort the process.\n"); - } else { - exit(1); - } +static void gras_sigint_handler(int sig) +{ + static double lastone = 0; + if (lastone == 0 || xbt_os_time() - lastone > 5) { + if (gras_if_RL()) + xbt_backtrace_display_current(); + else + SIMIX_display_process_status(); + fprintf(stderr, + "\nBacktrace displayed because Ctrl-C was pressed. Press again (within 5 sec) to abort the process.\n"); + lastone = xbt_os_time(); + } else { + exit(1); + } } #endif -void gras_init(int *argc,char **argv) { +/** + * @ingroup GRAS_API + * \brief Initialize the gras mechanisms. + */ +void gras_init(int *argc, char **argv) +{ + int first = 0; + gras_procdata_t *pd; + gras_msg_procdata_t msg_pd; - VERB0("Initialize GRAS"); - + xbt_getpid = gras_os_getpid; /* First initialize the XBT */ - xbt_init(argc,argv); - - /* module registrations: - * - declare process specific data we need (without creating them) + xbt_init(argc, argv); + + XBT_VERB("Initialize GRAS"); + + /* module registrations: + * - declare process specific data we need (without creating them) */ if (gras_running_process == 0) { - gras_trp_register(); - gras_msg_register(); + first = 1; + /* Connect our log channels: that must be done manually under windows */ + + XBT_LOG_CONNECT(gras_modules, gras); + + XBT_LOG_CONNECT(gras_msg, gras); + XBT_LOG_CONNECT(gras_msg_read, gras_msg); + XBT_LOG_CONNECT(gras_msg_rpc, gras_msg); + + XBT_LOG_CONNECT(gras_timer, gras); + + XBT_LOG_CONNECT(gras_virtu, gras); + XBT_LOG_CONNECT(gras_virtu_emul, gras_virtu); + XBT_LOG_CONNECT(gras_virtu_process, gras_virtu); + + if (!getenv("GRAS_NO_WARN_EXPERIMENTAL")) + XBT_WARN("GRAS is not well maintained anymore. We consider it to be experimental (and not stable anymore) since SimGrid 3.6. Sorry about it, please consider contributing to improve this situation"); + + gras_trp_register(); + gras_msg_register(); + + xbt_trp_plugin_new("file", gras_trp_file_setup); + if (gras_if_SG()) { + xbt_trp_plugin_new("sg", gras_trp_sg_setup); + } + /* the TCP plugin (used in RL mode) is automatically loaded by XBT */ } - + gras_running_process++; + /* * Initialize the process specific stuff */ - gras_process_init(); /* calls procdata_init, which creates process specific data for each module */ - + gras_process_init(); /* calls procdata_init, which creates process specific data for each module */ + /* * Initialize the global stuff if it's not the first process created */ - if (gras_running_process++ == 0) { + if (first) { gras_emul_init(); gras_msg_init(); - gras_trp_init(); - gras_datadesc_init(); #if defined(HAVE_SIGNAL) && defined(HAVE_SIGNAL_H) - signal(SIGUSR1,gras_sigusr_handler); - signal(SIGINT,gras_sigint_handler); -#endif +# ifdef SIGUSR1 + signal(SIGUSR1, gras_sigusr_handler); +# endif + signal(SIGINT, gras_sigint_handler); +#endif } - + /* and then init amok */ amok_init(); + + /* And finally, launch the listener thread */ + pd = gras_procdata_get(); + msg_pd = gras_libdata_by_name("gras_msg"); + pd->listener = gras_msg_listener_launch(msg_pd->msg_received); } -void gras_exit(void) { - INFO0("Exiting GRAS"); +/** + * @ingroup GRAS_API + * @brief Finalize the gras mechanisms. + * */ +void gras_exit(void) +{ + XBT_INFO("Exiting GRAS"); + amok_exit(); + gras_moddata_leave(); + gras_msg_listener_shutdown(); + gras_process_exit(); if (--gras_running_process == 0) { gras_msg_exit(); - gras_trp_exit(); - gras_datadesc_exit(); gras_emul_exit(); + gras_moddata_exit(); } - gras_process_exit(); - xbt_exit(); } -const char *hexa_str(unsigned char *data, int size, int downside) { - static char*buff=NULL; - static int buffsize=0; - int i,pos=0; - - if (buffsize<5*(size+1)) { - if (buff) - free(buff); - buffsize=5*(size+1); - buff=xbt_malloc(buffsize); +const char *hexa_str(unsigned char *data, int size, int downside) +{ + static char *buff = NULL; + static int buffsize = 0; + int i, pos = 0; + int begin, increment; + + if (buffsize < 5 * (size + 1)) { + free(buff); + buffsize = 5 * (size + 1); + buff = xbt_malloc(buffsize); } - - int begin,increment; + + if (downside) { - begin=size-1; - increment=-1; + begin = size - 1; + increment = -1; } else { - begin=0; - increment=1; + begin = 0; + increment = 1; } - - for (i=begin; 0<=i && i126) - sprintf(buff+pos,"."); + + for (i = begin; 0 <= i && i < size; i += increment) { + if (data[i] < 32 || data[i] > 126) + sprintf(buff + pos, "."); else - sprintf(buff+pos,"%c",data[i]); + sprintf(buff + pos, "%c", data[i]); while (buff[++pos]); - } - sprintf(buff+pos,"("); + } + sprintf(buff + pos, "("); while (buff[++pos]); - for (i=begin; 0<=i && i