X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/5904252e9e4e84030ee544d5efbd832dffa696a7..42e69c5d43675587aae0bb367b8bf0746f6be13a:/src/msg/msg_private.h diff --git a/src/msg/msg_private.h b/src/msg/msg_private.h index 855992ff53..b7801c9f70 100644 --- a/src/msg/msg_private.h +++ b/src/msg/msg_private.h @@ -9,6 +9,7 @@ #include "msg/msg.h" #include "simgrid/simix.h" +#include "surf/surf.h" #include "xbt/fifo.h" #include "xbt/dynar.h" #include "xbt/swag.h" @@ -90,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; @@ -103,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; @@ -137,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 +155,44 @@ 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