X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/a34aa584ccd2bdb81659d0e5df22864cf999c0f4..6a6209ae617ba25152ddd80cd3b79d72748d7bd5:/src/msg/msg_private.h diff --git a/src/msg/msg_private.h b/src/msg/msg_private.h index 97af923ebf..b7801c9f70 100644 --- a/src/msg/msg_private.h +++ b/src/msg/msg_private.h @@ -16,7 +16,6 @@ #include "xbt/dict.h" #include "xbt/config.h" #include "instr/instr_private.h" - SG_BEGIN_DECL() /**************** datatypes **********************************/ @@ -92,12 +91,13 @@ typedef struct msg_comm { msg_task_t *task_received; /* where the task will be received (NULL for the sender) */ msg_error_t status; /* status of the communication once finished */ } s_msg_comm_t; - +/* typedef enum { msg_vm_state_suspended, msg_vm_state_running, msg_vm_state_migrating } 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; @@ -105,7 +105,7 @@ typedef struct msg_vm { msg_host_t location; int coreAmount; } s_msg_vm_t; - +*/ /************************** Global variables ********************************/ typedef struct MSG_Global { xbt_fifo_t host; @@ -139,7 +139,7 @@ XBT_PUBLIC_DATA(MSG_Global_t) msg_global; #endif msg_host_t __MSG_host_create(smx_host_t workstation); -void __MSG_host_destroy(msg_host_t host); +void __MSG_host_destroy(msg_host_priv_t host); void __MSG_display_process_status(void); @@ -153,5 +153,46 @@ void MSG_comm_copy_data_from_SIMIX(smx_action_t comm, void* buff, size_t buff_si void _MSG_action_init(void); void _MSG_action_exit(void); +void MSG_post_create_environment(void); + +/********** Tracing **********/ +/* declaration of instrumentation functions from msg_task_instr.c */ +void TRACE_msg_set_task_category(msg_task_t task, const char *category); +void TRACE_msg_task_create(msg_task_t task); +void TRACE_msg_task_execute_start(msg_task_t task); +void TRACE_msg_task_execute_end(msg_task_t task); +void TRACE_msg_task_destroy(msg_task_t task); +void TRACE_msg_task_get_start(void); +void TRACE_msg_task_get_end(double start_time, msg_task_t task); +int TRACE_msg_task_put_start(msg_task_t task); //returns TRUE if the task_put_end must be called +void TRACE_msg_task_put_end(void); + +/* declaration of instrumentation functions from msg_process_instr.c */ +char *instr_process_id (msg_process_t proc, char *str, int len); +char *instr_process_id_2 (const char *process_name, int process_pid, char *str, int len); +void TRACE_msg_process_change_host(msg_process_t process, msg_host_t old_host, + msg_host_t new_host); +void TRACE_msg_process_create (const char *process_name, int process_pid, msg_host_t host); +void TRACE_msg_process_destroy (const char *process_name, int process_pid, msg_host_t host); +void TRACE_msg_process_kill(msg_process_t process); +void TRACE_msg_process_suspend(msg_process_t process); +void TRACE_msg_process_resume(msg_process_t process); +void TRACE_msg_process_sleep_in(msg_process_t process); //called from msg/gos.c +void TRACE_msg_process_sleep_out(msg_process_t process); +void TRACE_msg_process_end(msg_process_t process); + +/* declaration of instrumentation functions from instr_msg_vm.c */ +char *instr_vm_id (msg_vm_t vm, char *str, int len); +char *instr_vm_id_2 (const char *vm_name, char *str, int len); +void TRACE_msg_vm_change_host(msg_vm_t vm, msg_host_t old_host, + msg_host_t new_host); +void TRACE_msg_vm_create (const char *vm_name, msg_host_t host); +void TRACE_msg_vm_kill(msg_vm_t process); +void TRACE_msg_vm_suspend(msg_vm_t vm); +void TRACE_msg_vm_resume(msg_vm_t vm); +void TRACE_msg_vm_sleep_in(msg_vm_t vm); +void TRACE_msg_vm_sleep_out(msg_vm_t vm); +void TRACE_msg_vm_end(msg_vm_t vm); + SG_END_DECL() #endif