X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/1906319f3340a70c04f334e2b5b35219b0cc7ae6..ba26409dfb68b4eb12207ba64a996558177d4195:/include/msg/msg.h diff --git a/include/msg/msg.h b/include/msg/msg.h index 1424a4c20a..f6efd0ac54 100644 --- a/include/msg/msg.h +++ b/include/msg/msg.h @@ -101,10 +101,12 @@ 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, +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); +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); @@ -132,5 +134,43 @@ 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); + +/************************** Task handling ************************************/ +XBT_PUBLIC(MSG_error_t) +MSG_mailbox_get_task_ext(msg_mailbox_t mailbox, m_task_t* task, m_host_t host, double timeout); + +XBT_PUBLIC(MSG_error_t) +MSG_mailbox_put_with_timeout(msg_mailbox_t mailbox, m_task_t task, double timeout); + SG_END_DECL() #endif