X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/eabf5fd1b436c08b408de268a45aac7182924f34..97d3abf54943fe29eef37b8c639b736eafd7aa09:/include/msg/msg.h diff --git a/include/msg/msg.h b/include/msg/msg.h index 7354664dac..b589ff63d7 100644 --- a/include/msg/msg.h +++ b/include/msg/msg.h @@ -9,11 +9,13 @@ #define MSG_H #include "xbt/misc.h" +#include "xbt/sysdep.h" BEGIN_DECL() #include "msg/datatypes.h" /************************** Global ******************************************/ +xbt_error_t MSG_config(const char *name, ...); void MSG_global_init(void); void MSG_global_init_args(int *argc, char **argv); void MSG_set_verbosity(MSG_outputmode_t mode); @@ -28,6 +30,7 @@ void MSG_launch_application(const char *file); void MSG_paje_output(const char *filename); double MSG_getClock(void); +double MSG_get_clock(void); /************************** Host handling ***********************************/ MSG_error_t MSG_host_set_data(m_host_t host, void *data); @@ -35,7 +38,7 @@ void *MSG_host_get_data(m_host_t host); const char *MSG_host_get_name(m_host_t host); m_host_t MSG_host_self(void); int MSG_get_host_msgload(m_host_t host); -int MSG_get_msgload(void); +/* int MSG_get_msgload(void); This function lacks specification; discard it */ void MSG_create_environment(const char *file); @@ -80,9 +83,13 @@ m_task_t MSG_task_create(const char *name, double compute_duration, double message_size, void *data); void *MSG_task_get_data(m_task_t task); m_process_t MSG_task_get_sender(m_task_t task); +const char *MSG_task_get_name(m_task_t task); + MSG_error_t MSG_task_destroy(m_task_t task); MSG_error_t MSG_task_get(m_task_t * task, m_channel_t channel); +MSG_error_t MSG_task_get_with_time_out(m_task_t * task, m_channel_t channel, + double max_duration); MSG_error_t MSG_task_put(m_task_t task, m_host_t dest, m_channel_t channel); MSG_error_t MSG_task_put_bounded(m_task_t task, @@ -91,9 +98,14 @@ MSG_error_t MSG_task_put_bounded(m_task_t task, MSG_error_t MSG_task_execute(m_task_t task); int MSG_task_Iprobe(m_channel_t channel); int MSG_task_probe_from(m_channel_t channel); +MSG_error_t MSG_channel_select_from(m_channel_t channel, double max_duration, + int *PID); MSG_error_t MSG_process_sleep(double nb_sec); MSG_error_t MSG_get_errno(void); +double MSG_task_get_compute_duration(m_task_t task); +double MSG_task_get_data_size(m_task_t task); + /************************** Deprecated ***************************************/ /* MSG_error_t MSG_routing_table_init(void); */ /* MSG_error_t MSG_routing_table_set(m_host_t host1, m_host_t host2, */