return task;
}
+/** \ingroup msg_gos_functions
+ * \brief Description forthcoming (FIXME)
+ *
+ * \param task
+ * \return
+ */
MSG_error_t MSG_parallel_task_execute(m_task_t task)
{
simdata_task_t simdata = NULL;
}
}
+/** \ingroup msg_gos_functions
+ * \brief Description forthcoming (FIXME)
+ *
+ * \param task
+ * \param alias
+ * \param host
+ * \return
+ */
MSG_error_t
MSG_task_receive_from_host(m_task_t * task, const char *alias,
m_host_t host)
return MSG_task_receive_ext(task, alias, -1, host);
}
+/** \ingroup msg_gos_functions
+ * \brief Description forthcoming (FIXME)
+ *
+ * \param task
+ * \param alias
+ * \return
+ */
MSG_error_t MSG_task_receive(m_task_t * task, const char *alias)
{
return MSG_task_receive_with_timeout(task, alias, -1);
}
+/** \ingroup msg_gos_functions
+ * \brief Description forthcoming (FIXME)
+ *
+ * \param task
+ * \param alias
+ * \param timeout
+ * \return
+ */
MSG_error_t
MSG_task_receive_with_timeout(m_task_t * task, const char *alias,
double timeout)
return MSG_task_receive_ext(task, alias, timeout, NULL);
}
+/** \ingroup msg_gos_functions
+ * \brief Description forthcoming (FIXME)
+ *
+ * \param task
+ * \param alias
+ * \param timeout
+ * \param host
+ * \return
+ */
MSG_error_t
MSG_task_receive_ext(m_task_t * task, const char *alias, double timeout,
m_host_t host)
return comm->status;
}
+/** \ingroup msg_gos_functions
+ * \brief Description forthcoming (FIXME)
+ *
+ * \param comm
+ * \return
+ */
m_task_t MSG_comm_get_task(msg_comm_t comm)
{
xbt_assert(comm, "Invalid parameter");
}
}
+/** \ingroup msg_gos_functions
+ * \brief Description forthcoming (FIXME)
+ *
+ * \param task
+ * \param alias
+ * \return
+ */
MSG_error_t MSG_task_send(m_task_t task, const char *alias)
{
XBT_DEBUG("MSG_task_send: Trying to send a message on mailbox '%s'", alias);
return MSG_task_send_with_timeout(task, alias, -1);
}
-
+/** \ingroup msg_gos_functions
+ * \brief Description forthcoming (FIXME)
+ *
+ * \param task
+ * \param alias
+ * \param maxrate
+ * \return
+ */
MSG_error_t
MSG_task_send_bounded(m_task_t task, const char *alias, double maxrate)
{
return MSG_task_send(task, alias);
}
-
+/** \ingroup msg_gos_functions
+ * \brief Description forthcoming (FIXME)
+ *
+ * \param task
+ * \param alias
+ * \param timeout
+ * \return
+ */
MSG_error_t
MSG_task_send_with_timeout(m_task_t task, const char *alias,
double timeout)
task, timeout);
}
+/** \ingroup msg_gos_functions
+ * \brief Description forthcoming (FIXME)
+ *
+ * \param alias
+ * \return
+ */
int MSG_task_listen(const char *alias)
{
CHECK_HOST();
return !MSG_mailbox_is_empty(MSG_mailbox_get_by_alias(alias));
}
+/** \ingroup msg_gos_functions
+ * \brief Description forthcoming (FIXME)
+ *
+ * \param alias
+ * \param host
+ * \return
+ */
int MSG_task_listen_from_host(const char *alias, m_host_t host)
{
CHECK_HOST();
(alias), host);
}
+/** \ingroup msg_gos_functions
+ * \brief Description forthcoming (FIXME)
+ *
+ * \param alias
+ * \return
+ */
int MSG_task_listen_from(const char *alias)
{
m_task_t task;