X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/b3d18155a991509df0050df72c7531ffbcae7efc..1a61b7d465d6e6e5fc1fa6e8ee0f8cdab9ebaba6:/include/msg/msg.h diff --git a/include/msg/msg.h b/include/msg/msg.h index 2b4df2d626..7936aebff3 100644 --- a/include/msg/msg.h +++ b/include/msg/msg.h @@ -8,21 +8,27 @@ #ifndef MSG_H #define MSG_H +#include "xbt/misc.h" +#include "xbt/sysdep.h" + +BEGIN_DECL() #include "msg/datatypes.h" /************************** Global ******************************************/ void MSG_global_init(void); +void MSG_global_init_args(int *argc, char **argv); void MSG_set_verbosity(MSG_outputmode_t mode); MSG_error_t MSG_set_channel_number(int number); -MSG_error_t MSG_set_sharing_policy(MSG_sharing_t mode, long double param); +MSG_error_t MSG_set_sharing_policy(MSG_sharing_t mode, double param); int MSG_get_channel_number(void); MSG_error_t MSG_main(void); MSG_error_t MSG_clean(void); void MSG_function_register(const char *name, m_process_code_t code); m_process_code_t MSG_get_registered_function(const char *name); void MSG_launch_application(const char *file); +void MSG_paje_output(const char *filename); -long double MSG_getClock(void); +double MSG_getClock(void); /************************** Host handling ***********************************/ MSG_error_t MSG_host_set_data(m_host_t host, void *data); @@ -45,6 +51,8 @@ m_process_t MSG_process_create(const char *name, m_process_t MSG_process_create_with_arguments(const char *name, m_process_code_t code, void *data, m_host_t host, int argc, char **argv); +void MSG_process_kill(m_process_t process); +int MSG_process_killall(int reset_PIDs); MSG_error_t MSG_get_arguments(int *argc, char ***argv); MSG_error_t MSG_set_arguments(m_process_t process,int argc, char *argv[]); @@ -69,17 +77,24 @@ MSG_error_t MSG_process_start(m_process_t process); /************************** Task handling ************************************/ -m_task_t MSG_task_create(const char *name, long double compute_duration, - long double message_size, void *data); +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_put(m_task_t task, m_host_t dest, m_channel_t channel); +MSG_error_t MSG_task_put_bounded(m_task_t task, + m_host_t dest, m_channel_t channel, + double max_rate); MSG_error_t MSG_task_execute(m_task_t task); int MSG_task_Iprobe(m_channel_t channel); -MSG_error_t MSG_process_sleep(long double nb_sec); +int MSG_task_probe_from(m_channel_t channel); +MSG_error_t MSG_process_sleep(double nb_sec); MSG_error_t MSG_get_errno(void); /************************** Deprecated ***************************************/ @@ -104,5 +119,5 @@ MSG_error_t MSG_get_errno(void); /* m_link_t MSG_link_merge(const char *name, m_link_t src1, m_link_t src2); */ /* m_link_t MSG_get_link_by_name(const char *name); */ /* void MSG_tracelink(m_host_t dest, const char* **names, int *count); */ - +END_DECL() #endif