X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/05898e1bb90bb5120653b524b08f296edec37a0e..eabf5fd1b436c08b408de268a45aac7182924f34:/include/msg/msg.h diff --git a/include/msg/msg.h b/include/msg/msg.h index 2202096c08..7354664dac 100644 --- a/include/msg/msg.h +++ b/include/msg/msg.h @@ -8,6 +8,9 @@ #ifndef MSG_H #define MSG_H +#include "xbt/misc.h" + +BEGIN_DECL() #include "msg/datatypes.h" /************************** Global ******************************************/ @@ -15,15 +18,16 @@ 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); @@ -46,6 +50,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[]); @@ -70,8 +76,8 @@ 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); MSG_error_t MSG_task_destroy(m_task_t task); @@ -79,10 +85,13 @@ 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); int MSG_task_probe_from(m_channel_t channel); -MSG_error_t MSG_process_sleep(long double nb_sec); +MSG_error_t MSG_process_sleep(double nb_sec); MSG_error_t MSG_get_errno(void); /************************** Deprecated ***************************************/ @@ -107,5 +116,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