return mailbox;
}
-MSG_error_t
+void MSG_mailbox_set_async(const char *alias){
+ msg_mailbox_t mailbox = MSG_mailbox_get_by_alias(alias);
+
+ simcall_rdv_set_receiver(mailbox, SIMIX_process_self());
+ XBT_VERB("%s mailbox set to receive eagerly for process %p\n",alias, SIMIX_process_self());
+
+}
+
+msg_error_t
MSG_mailbox_get_task_ext(msg_mailbox_t mailbox, msg_task_t * task,
msg_host_t host, double timeout)
{
xbt_ex_t e;
- MSG_error_t ret = MSG_OK;
+ msg_error_t ret = MSG_OK;
/* We no longer support getting a task from a specific host */
if (host)
THROW_UNIMPLEMENTED;
MSG_RETURN(ret);
}
-MSG_error_t
+msg_error_t
MSG_mailbox_put_with_timeout(msg_mailbox_t mailbox, msg_task_t task,
double timeout)
{
xbt_ex_t e;
- MSG_error_t ret = MSG_OK;
+ msg_error_t ret = MSG_OK;
simdata_task_t t_simdata = NULL;
msg_process_t process = MSG_process_self();
simdata_process_t p_simdata = SIMIX_process_self_get_data(process);