X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/32df9acdb9c57513bf704fab767117eaccdcecc9..0a95c78251f3ecbf1dfcb3ebe7904e44acf1beef:/src/msg/msg_private.h diff --git a/src/msg/msg_private.h b/src/msg/msg_private.h index e675c36740..e24bfe0927 100644 --- a/src/msg/msg_private.h +++ b/src/msg/msg_private.h @@ -14,8 +14,6 @@ #include -SG_BEGIN_DECL() - /**************** datatypes **********************************/ /**************************** Host Extension *********************************/ namespace simgrid { @@ -73,20 +71,14 @@ typedef struct simdata_file { smx_file_t smx_file; } s_simdata_file_t; -XBT_PRIVATE int __MSG_host_get_file_descriptor_id(msg_host_t host); -XBT_PRIVATE void __MSG_host_release_file_descriptor_id(msg_host_t host, int id); - /******************************* Process *************************************/ -typedef struct simdata_process { - msg_host_t m_host; /* the host on which the process is running */ - msg_host_t put_host; /* used for debugging purposes */ - smx_activity_t waiting_action; - msg_task_t waiting_task; - msg_error_t last_errno; /* the last value returned by a MSG_function */ - - void* data; /* user data */ -} s_simdata_process_t, *simdata_process_t; +class MsgActorExt { +public: + explicit MsgActorExt(void* d) : data(d) {} + msg_error_t errno_ = MSG_OK; /* the last value returned by a MSG_function */ + void* data = nullptr; /* user data */ +}; typedef struct process_arg { const char *name; @@ -113,21 +105,20 @@ typedef struct MSG_Global { void_f_pvoid_t process_data_cleanup; } s_MSG_Global_t, *MSG_Global_t; -/*extern MSG_Global_t msg_global;*/ XBT_PUBLIC_DATA(MSG_Global_t) msg_global; /*************************************************************/ +SG_BEGIN_DECL() + XBT_PRIVATE msg_host_t __MSG_host_create(sg_host_t host); XBT_PRIVATE msg_storage_t __MSG_storage_create(smx_storage_t storage); XBT_PRIVATE void __MSG_storage_destroy(msg_storage_priv_t host); XBT_PRIVATE void __MSG_file_destroy(msg_file_priv_t host); XBT_PRIVATE void MSG_process_cleanup_from_SIMIX(smx_actor_t smx_proc); -XBT_PRIVATE smx_actor_t MSG_process_create_from_SIMIX(const char *name, - std::function code, void *data, - sg_host_t host, double kill_time, - xbt_dict_t properties, int auto_restart, - smx_actor_t parent_process); +XBT_PRIVATE smx_actor_t MSG_process_create_from_SIMIX(const char* name, std::function code, void* data, + sg_host_t host, xbt_dict_t properties, int auto_restart, + smx_actor_t parent_process); XBT_PRIVATE void MSG_comm_copy_data_from_SIMIX(smx_activity_t comm, void* buff, size_t buff_size); XBT_PRIVATE void MSG_post_create_environment();