msg_mailbox_t MSG_mailbox_new(const char *alias)
{
- return simcall_rdv_create(alias);
-}
-
-void MSG_mailbox_free(void *mailbox)
-{
- simcall_rdv_destroy((msg_mailbox_t)mailbox);
+ return simcall_mbox_create(alias);
}
int MSG_mailbox_is_empty(msg_mailbox_t mailbox)
{
- return (NULL == simcall_rdv_get_head(mailbox));
+ return (NULL == simcall_mbox_get_head(mailbox));
}
msg_task_t MSG_mailbox_get_head(msg_mailbox_t mailbox)
{
- smx_synchro_t comm = simcall_rdv_get_head(mailbox);
+ smx_synchro_t comm = simcall_mbox_get_head(mailbox);
if (!comm)
return NULL;
return (msg_task_t) simcall_comm_get_src_data(comm);
}
-int MSG_mailbox_get_count_host_waiting_tasks(msg_mailbox_t mailbox, msg_host_t host)
-{
- return simcall_rdv_comm_count_by_host(mailbox, host);
-}
-
msg_mailbox_t MSG_mailbox_get_by_alias(const char *alias)
{
- msg_mailbox_t mailbox = simcall_rdv_get_by_name(alias);
+ msg_mailbox_t mailbox = simcall_mbox_get_by_name(alias);
if (!mailbox)
mailbox = MSG_mailbox_new(alias);
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());
+ simcall_mbox_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 ret = MSG_OK;
simdata_task_t t_simdata = NULL;
msg_process_t process = MSG_process_self();
- simdata_process_t p_simdata = (simdata_process_t) SIMIX_process_self_get_data(process);
+ simdata_process_t p_simdata = (simdata_process_t) SIMIX_process_self_get_data();
int call_end = TRACE_msg_task_put_start(task); //must be after CHECK_HOST()
/* Prepare the task to send */
t_simdata = task->simdata;
t_simdata->sender = process;
- t_simdata->source = ((simdata_process_t) SIMIX_process_self_get_data(process))->m_host;
+ t_simdata->source = ((simdata_process_t) SIMIX_process_self_get_data())->m_host;
if (t_simdata->isused != 0) {
if (msg_global->debug_multiple_use){