X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/bdaa135f5f4c27c592daf1483894bcbb0eeb9aa9..61ab0b23d55ea10365ba11d22b8c11b39cbf16e9:/src/simix/ActorImpl.hpp diff --git a/src/simix/ActorImpl.hpp b/src/simix/ActorImpl.hpp index 28409f3180..15bfeb04cb 100644 --- a/src/simix/ActorImpl.hpp +++ b/src/simix/ActorImpl.hpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2007-2017. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2007-2018. 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. */ @@ -19,7 +19,8 @@ struct s_smx_process_exit_fun_t { }; namespace simgrid { -namespace simix { +namespace kernel { +namespace actor { class ProcessArg { public: @@ -56,12 +57,11 @@ public: aid_t pid = 0; aid_t ppid = -1; simgrid::xbt::string name; - const simgrid::xbt::string& getName() const { return name; } - const char* getCname() const { return name.c_str(); } + const simgrid::xbt::string& get_name() const { return name; } + const char* get_cname() const { return name.c_str(); } s4u::Host* host = nullptr; /* the host on which the process is running */ smx_context_t context = nullptr; /* the context (uctx/raw/thread) that executes the user function */ - // TODO, pack them std::exception_ptr exception; bool finished = false; bool blocked = false; @@ -70,15 +70,15 @@ public: smx_activity_t waiting_synchro = nullptr; /* the current blocking synchro if any */ std::list comms; /* the current non-blocking communication synchros */ - s_smx_simcall_t simcall; - void* userdata = nullptr; /* kept for compatibility, it should be replaced with moddata */ + s_smx_simcall simcall; std::vector on_exit; /* list of functions executed when the process dies */ std::function code; smx_timer_t kill_timer = nullptr; - /* Refcounting */ private: + void* userdata = nullptr; /* kept for compatibility, it should be replaced with moddata */ + /* Refcounting */ std::atomic_int_fast32_t refcount_{0}; public: @@ -127,14 +127,13 @@ public: typedef boost::intrusive::list, &ActorImpl::smx_synchro_hook>> SynchroList; -} -} -typedef simgrid::simix::ProcessArg *smx_process_arg_t; - -typedef simgrid::simix::ActorImpl* smx_actor_t; +XBT_PUBLIC void create_maestro(std::function code); +} +} // namespace kernel +} // namespace simgrid -extern "C" { +typedef simgrid::kernel::actor::ActorImpl* smx_actor_t; XBT_PRIVATE smx_actor_t SIMIX_process_create(const char* name, std::function code, void* data, sg_host_t host, std::map* properties, @@ -142,19 +141,15 @@ XBT_PRIVATE smx_actor_t SIMIX_process_create(const char* name, std::function