X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/05898e1bb90bb5120653b524b08f296edec37a0e..4a5549091dbdecc6e56ff56e09ef922ba83b1d02:/include/msg/msg.h diff --git a/include/msg/msg.h b/include/msg/msg.h index 2202096c08..63837ec477 100644 --- a/include/msg/msg.h +++ b/include/msg/msg.h @@ -15,15 +15,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 +47,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 +73,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 +82,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 ***************************************/