X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/c64b87ac6ee7d4655690a40cf12bd95f0c1d633f..d011cb8a5566e78daba9b90c6a370dca07b74c5a:/src/msg/msg_global.cpp diff --git a/src/msg/msg_global.cpp b/src/msg/msg_global.cpp index 8c6365cf08..9608ac7806 100644 --- a/src/msg/msg_global.cpp +++ b/src/msg/msg_global.cpp @@ -12,12 +12,10 @@ #include XBT_LOG_NEW_CATEGORY(msg, "All MSG categories"); -XBT_LOG_NEW_DEFAULT_SUBCATEGORY(msg_kernel, msg, "Logging specific to MSG (kernel)"); bool MSG_Global_t::debug_multiple_use = false; MSG_Global_t* msg_global = nullptr; -simgrid::xbt::Extension simgrid::msg::ActorUserData::EXTENSION_ID; static void MSG_exit(); @@ -43,7 +41,12 @@ void MSG_init_nocheck(int *argc, char **argv) { msg_global->sent_msg = 0; msg_global->task_copy_callback = nullptr; msg_global->process_data_cleanup = nullptr; - MSG_process_userdata_init(); + simgrid::s4u::Actor::on_termination.connect([](simgrid::s4u::Actor const& actor) { + // free the data if a function was provided + void* userdata = sg_actor_data(&actor); + if (userdata && msg_global->process_data_cleanup) + msg_global->process_data_cleanup(userdata); + }); } if(MC_is_active()){ @@ -51,7 +54,7 @@ void MSG_init_nocheck(int *argc, char **argv) { MC_ignore_heap(&(msg_global->sent_msg), sizeof(msg_global->sent_msg)); } - if (simgrid::config::get_value("clean-atexit")) + if (simgrid::config::get_value("debug/clean-atexit")) atexit(MSG_exit); }