X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/301a28e1a96c21b0581abc2dd632952e3c5d0ff8..9b57381fd90f9a91865c5224c63a45c9bd766a5f:/include/msg/msg.h diff --git a/include/msg/msg.h b/include/msg/msg.h index 197d78e175..63e5cc37d4 100644 --- a/include/msg/msg.h +++ b/include/msg/msg.h @@ -101,10 +101,16 @@ XBT_PUBLIC(MSG_error_t) MSG_task_cancel(m_task_t task); XBT_PUBLIC(MSG_error_t) MSG_task_destroy(m_task_t task); XBT_PUBLIC(MSG_error_t) MSG_task_get(m_task_t * task, m_channel_t channel); -XBT_PUBLIC(MSG_error_t) MSG_task_get_with_time_out(m_task_t * task, m_channel_t channel, - double max_duration); +XBT_PUBLIC(MSG_error_t) MSG_task_get_with_timeout(m_task_t * task, m_channel_t channel, + double max_duration); XBT_PUBLIC(MSG_error_t) MSG_task_get_from_host(m_task_t * task, int channel, - m_host_t host); + m_host_t host); +MSG_error_t +MSG_task_receive_from_host(m_task_t * task, const char* alias, m_host_t host); +XBT_PUBLIC(MSG_error_t) MSG_task_get_ext(m_task_t * task, int channel, + double max_duration, m_host_t host); + + XBT_PUBLIC(MSG_error_t) MSG_task_put(m_task_t task, m_host_t dest, m_channel_t channel); XBT_PUBLIC(MSG_error_t) MSG_task_put_bounded(m_task_t task, @@ -128,5 +134,36 @@ XBT_PUBLIC(double) MSG_task_get_compute_duration(m_task_t task); XBT_PUBLIC(double) MSG_task_get_remaining_computation(m_task_t task); XBT_PUBLIC(double) MSG_task_get_data_size(m_task_t task); + +XBT_PUBLIC(MSG_error_t) +MSG_task_receive_ext(m_task_t* task, const char* alias, double timeout, m_host_t host); + +XBT_PUBLIC(MSG_error_t) +MSG_task_receive_with_timeout(m_task_t * task, const char* alias, double timeout); + +XBT_PUBLIC(MSG_error_t) +MSG_task_receive(m_task_t * task, const char* alias); + +XBT_PUBLIC(int) +MSG_task_listen(const char* alias); + +XBT_PUBLIC(int) +MSG_task_listen_from_host(const char* alias, m_host_t host); + +XBT_PUBLIC(MSG_error_t) +MSG_alias_select_from(const char* alias, double timeout, int* PID); + +XBT_PUBLIC(MSG_error_t) +MSG_task_send_with_timeout(m_task_t task, const char* alias, double timeout); + +XBT_PUBLIC(MSG_error_t) +MSG_task_send(m_task_t task,const char* alias); + +XBT_PUBLIC(MSG_error_t) +MSG_task_send_bounded(m_task_t task, const char* alias, double rate); + +XBT_PUBLIC(int) +MSG_task_listen_from(const char* alias); + SG_END_DECL() #endif