X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/9e68ca10e951fb61e944c99c7774b1e415ae9f6d..a64f9bb7306061da60882141573e40d32fed4964:/include/msg/datatypes.h diff --git a/include/msg/datatypes.h b/include/msg/datatypes.h index cedd660b20..8fca546a1a 100644 --- a/include/msg/datatypes.h +++ b/include/msg/datatypes.h @@ -7,6 +7,7 @@ #define MSG_DATATYPE_H #include "xbt/misc.h" #include "xbt/file_stat.h" +#include "xbt/lib.h" #include "simgrid/simix.h" #include "simgrid_config.h" // for HAVE_TRACING @@ -29,13 +30,7 @@ typedef struct s_smx_rvpoint *msg_mailbox_t; /* ******************************** Host ************************************ */ -typedef struct msg_host { - xbt_swag_t vms; - smx_host_t smx_host; /**< SIMIX representation of this host */ -#ifdef MSG_USE_DEPRECATED - msg_mailbox_t *mailboxes; /**< the channels */ -#endif -} s_msg_host_t; +extern int MSG_HOST_LEVEL; /** @brief Host datatype. @ingroup m_host_management @@ -47,7 +42,20 @@ typedef struct msg_host { some private data that can be only accessed by local process. */ -typedef struct msg_host *msg_host_t; +typedef xbt_dictelm_t msg_host_t; +typedef s_xbt_dictelm_t s_msg_host_t; + +typedef struct msg_host_priv { +#ifdef MSG_USE_DEPRECATED + msg_mailbox_t *mailboxes; /**< the channels */ +#endif +} s_msg_host_priv_t, *msg_host_priv_t; + +static inline msg_host_priv_t MSG_host_priv(msg_host_t host){ + return xbt_lib_get_level(host, MSG_HOST_LEVEL); +} + + /* ******************************** Task ************************************ */ @@ -72,22 +80,32 @@ typedef struct msg_task { */ typedef struct msg_task *msg_task_t; -/* ******************************** VM ************************************* */ -typedef struct msg_vm *msg_vm_t; +/* ******************************** VM ************************************* */ +typedef msg_host_t msg_vm_t; +typedef msg_host_priv_t msg_vm_priv_t; +/* must be synchronized with e_surf_vm_state_t */ typedef enum { - msg_vm_state_suspended, msg_vm_state_running, msg_vm_state_migrating + /* created, but not yet started */ + msg_vm_state_created, + + msg_vm_state_running, + msg_vm_state_migrating, + + /* Suspend/resume does not involve disk I/O, so we assume there is no transition states. */ + msg_vm_state_suspended, + + /* Save/restore involves disk I/O, so there should be transition states. */ + msg_vm_state_saving, + msg_vm_state_saved, + msg_vm_state_restoring, + } e_msg_vm_state_t; -typedef struct msg_vm { - const char *name; - s_xbt_swag_hookup_t all_vms_hookup; - s_xbt_swag_hookup_t host_vms_hookup; - xbt_dynar_t processes; - e_msg_vm_state_t state; - msg_host_t location; - int coreAmount; -} s_msg_vm_t; +static inline msg_vm_priv_t MSG_vm_priv(msg_vm_t vm){ + return xbt_lib_get_level(vm, MSG_HOST_LEVEL); +} + /* ******************************** File ************************************ */ typedef struct simdata_file *simdata_file_t;