X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/55092bf3f9fe1cccfe72f7ef81fcd51f9a0eb4ca..9fd6cbc6c3b06f4b09e3c3339ffb3cc8a68f9bfa:/include/simgrid/simix.hpp diff --git a/include/simgrid/simix.hpp b/include/simgrid/simix.hpp index d4200a3080..9720dc87c4 100644 --- a/include/simgrid/simix.hpp +++ b/include/simgrid/simix.hpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2007-2010, 2012-2015. The SimGrid Team. +/* Copyright (c) 2007-2018. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it @@ -7,20 +7,15 @@ #ifndef SIMGRID_SIMIX_HPP #define SIMGRID_SIMIX_HPP -#include - -#include -#include -#include -#include - -#include -#include +#include #include +#include +#include -#include +#include +#include -XBT_PUBLIC(void) simcall_run_kernel(std::function const& code); +XBT_PUBLIC void simcall_run_kernel(std::function const& code); /** Execute some code in the kernel and block * @@ -31,7 +26,7 @@ XBT_PUBLIC(void) simcall_run_kernel(std::function const& code); * * @ref simix::kernelSync() is a higher level wrapper for this. */ -XBT_PUBLIC(void) simcall_run_blocking(std::function const& code); +XBT_PUBLIC void simcall_run_blocking(std::function const& code); template inline void simcall_run_kernel(F& f) @@ -54,8 +49,7 @@ namespace simix { * More importantly, this enforces a deterministic/reproducible ordering * of the operation with respect to other simcalls. */ -template -typename std::result_of::type kernelImmediate(F&& code) +template typename std::result_of::type simcall(F&& code) { // If we are in the maestro, we take the fast path and execute the // code directly without simcall mashalling/unmarshalling/dispatch: @@ -67,25 +61,19 @@ typename std::result_of::type kernelImmediate(F&& code) // conveniently handles the success/failure value for us. typedef typename std::result_of::type R; simgrid::xbt::Result result; - simcall_run_kernel([&]{ - xbt_assert(SIMIX_is_maestro(), "Not in maestro"); - simgrid::xbt::fulfillPromise(result, std::forward(code)); - }); + simcall_run_kernel([&] { simgrid::xbt::fulfill_promise(result, std::forward(code)); }); return result.get(); } - -XBT_PUBLIC(void) set_maestro(std::function code); -XBT_PUBLIC(void) create_maestro(std::function code); +XBT_PUBLIC const std::vector& process_get_runnable(); // What's executed as SIMIX actor code: typedef std::function ActorCode; -// Create ActorCode based on argv: +// Create an ActorCode based on a std::string typedef std::function args)> ActorCodeFactory; -XBT_PUBLIC(void) registerFunction(const char* name, ActorCodeFactory factory); - +XBT_PUBLIC void register_function(std::string name, ActorCodeFactory factory); } } @@ -98,39 +86,30 @@ XBT_PUBLIC(void) registerFunction(const char* name, ActorCodeFactory factory); * void *data: data a pointer to any data one may want to attach to the new object. * sg_host_t host: the location where the new process is executed * int argc, char **argv: parameters passed to code - * xbt_dict_t pros: properties + * std::map* props: properties */ -typedef smx_process_t (*smx_creation_func_t) ( - /* name */ const char*, - std::function code, - /* userdata */ void*, - /* hostname */ const char*, - /* kill_time */ double, - /* props */ xbt_dict_t, - /* auto_restart */ int, - /* parent_process */ smx_process_t); - -extern "C" -XBT_PUBLIC(void) SIMIX_function_register_process_create(smx_creation_func_t function); - -XBT_PUBLIC(smx_process_t) simcall_process_create(const char *name, - std::function code, - void *data, - const char *hostname, - double kill_time, - xbt_dict_t properties, - int auto_restart); - -XBT_PUBLIC(smx_timer_t) SIMIX_timer_set(double date, simgrid::xbt::Task callback); +typedef smx_actor_t (*smx_creation_func_t)( + /* name */ std::string, simgrid::simix::ActorCode code, + /* userdata */ void*, + /* hostname */ sg_host_t, + /* props */ std::unordered_map*, + /* parent_process */ smx_actor_t); + +XBT_PUBLIC void SIMIX_function_register_process_create(smx_creation_func_t function); + +XBT_PUBLIC smx_actor_t simcall_process_create(std::string name, simgrid::simix::ActorCode code, void* data, + sg_host_t host, std::unordered_map* properties); + +XBT_PUBLIC smx_timer_t SIMIX_timer_set(double date, simgrid::xbt::Task callback); template inline -XBT_PUBLIC(smx_timer_t) SIMIX_timer_set(double date, F callback) +smx_timer_t SIMIX_timer_set(double date, F callback) { return SIMIX_timer_set(date, simgrid::xbt::Task(std::move(callback))); } template inline -XBT_PUBLIC(smx_timer_t) SIMIX_timer_set(double date, R(*callback)(T*), T* arg) +smx_timer_t SIMIX_timer_set(double date, R(*callback)(T*), T* arg) { return SIMIX_timer_set(date, [=](){ callback(arg); }); }