X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/77e63efea0d0c200b85f224c2faf9de94d98e83a..bb90f02025de07b7f6b3e319114764303010562e:/src/msg/msg_private.h diff --git a/src/msg/msg_private.h b/src/msg/msg_private.h index 3c6c04db3a..cbc10c8df3 100644 --- a/src/msg/msg_private.h +++ b/src/msg/msg_private.h @@ -58,8 +58,6 @@ typedef struct simdata_gpu_task { typedef struct simdata_process { msg_host_t m_host; /* the host on which the process is running */ - int PID; /* used for debugging purposes */ - int PPID; /* The parent PID */ msg_host_t put_host; /* used for debugging purposes */ #ifdef MSG_USE_DEPRECATED m_channel_t put_channel; /* used for debugging purposes */ @@ -91,12 +89,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; @@ -104,14 +103,13 @@ typedef struct msg_vm { msg_host_t location; int coreAmount; } s_msg_vm_t; - +*/ /************************** Global variables ********************************/ typedef struct MSG_Global { xbt_fifo_t host; #ifdef MSG_USE_DEPRECATED int max_channel; #endif - int PID; int session; unsigned long int sent_msg; /* Total amount of messages sent during the simulation */ void (*task_copy_callback) (msg_task_t task, msg_process_t src, msg_process_t dst); @@ -138,7 +136,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); @@ -154,5 +152,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