From d092720e5102da3f78522679bcbf383e933930c5 Mon Sep 17 00:00:00 2001 From: Gabriel Corona Date: Tue, 9 Feb 2016 11:58:14 +0100 Subject: [PATCH] [simix] Use std::function for the maestro callback instead of void(void*) --- include/simgrid/simix.hpp | 3 +++ src/simix/smx_global.cpp | 19 ++++++++++++++----- src/simix/smx_process.cpp | 24 +++++++++++++++++------- 3 files changed, 34 insertions(+), 12 deletions(-) diff --git a/include/simgrid/simix.hpp b/include/simgrid/simix.hpp index 3d3e660d28..fb3fd5aa5d 100644 --- a/include/simgrid/simix.hpp +++ b/include/simgrid/simix.hpp @@ -232,6 +232,9 @@ public: virtual void attach_stop() = 0; }; +XBT_PUBLIC(void) set_maestro(std::function code); +XBT_PUBLIC(void) create_maestro(std::function code); + } } diff --git a/src/simix/smx_global.cpp b/src/simix/smx_global.cpp index 080e606dfc..10fbcebcf6 100644 --- a/src/simix/smx_global.cpp +++ b/src/simix/smx_global.cpp @@ -175,13 +175,22 @@ static void SIMIX_storage_create_(smx_storage_t storage) SIMIX_storage_create(key, storage, NULL); } -static void (*maestro_code)(void*) = nullptr; -static void* maestro_data = nullptr; +static std::function maestro_code; + +namespace simgrid { +namespace simix { + +XBT_PUBLIC(void) set_maestro(std::function code) +{ + maestro_code = std::move(code); +} + +} +} void SIMIX_set_maestro(void (*code)(void*), void* data) { - maestro_code = code; - maestro_data = data; + maestro_code = std::bind(code, data); } /** @@ -230,7 +239,7 @@ void SIMIX_global_init(int *argc, char **argv) // Either create a new context with maestro or create // a context object with the current context mestro): - SIMIX_maestro_create(maestro_code, maestro_data); + simgrid::simix::create_maestro(maestro_code); /* context exception handlers */ __xbt_running_ctx_fetch = SIMIX_process_get_running_context; diff --git a/src/simix/smx_process.cpp b/src/simix/smx_process.cpp index 65d1f6c271..46007fbaaa 100644 --- a/src/simix/smx_process.cpp +++ b/src/simix/smx_process.cpp @@ -139,10 +139,10 @@ void SIMIX_process_empty_trash(void) } } -/** - * \brief Creates and runs the maestro process - */ -void SIMIX_maestro_create(void (*code)(void*), void* data) +namespace simgrid { +namespace simix { + +void create_maestro(std::function code) { smx_process_t maestro = NULL; /* Create maestro process and intilialize it */ @@ -150,7 +150,7 @@ void SIMIX_maestro_create(void (*code)(void*), void* data) maestro->pid = simix_process_maxpid++; maestro->ppid = -1; maestro->name = (char*) ""; - maestro->data = data; + maestro->data = nullptr; maestro->running_ctx = (xbt_running_ctx_t*) xbt_malloc0(sizeof(xbt_running_ctx_t)); XBT_RUNNING_CTX_INITIALIZE(maestro->running_ctx); @@ -160,14 +160,24 @@ void SIMIX_maestro_create(void (*code)(void*), void* data) if (!simix_global) xbt_die("simix is not initialized, please call MSG_init first"); maestro->context = - simix_global->context_factory->create_maestro( - std::bind(code, data), maestro); + simix_global->context_factory->create_maestro(code, maestro); } maestro->simcall.issuer = maestro; simix_global->maestro_process = maestro; } +} +} + +/** + * \brief Creates and runs the maestro process + */ +void SIMIX_maestro_create(void (*code)(void*), void* data) +{ + simgrid::simix::create_maestro(std::bind(code, data)); +} + /** * \brief Stops a process. * -- 2.20.1