X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/ffbfdb3354cedfee2d8d6f3831ab04634bc004bd..0c14e681436e252f680310c7696b3ba17a349706:/src/msg/msg_mailbox.c diff --git a/src/msg/msg_mailbox.c b/src/msg/msg_mailbox.c index 4eb5053183..9b94299312 100644 --- a/src/msg/msg_mailbox.c +++ b/src/msg/msg_mailbox.c @@ -41,7 +41,7 @@ MSG_mailbox_get_count_host_waiting_tasks(msg_mailbox_t mailbox, m_host_t host) { return simcall_rdv_comm_count_by_host(mailbox, - host->simdata->smx_host); + host->smx_host); } msg_mailbox_t MSG_mailbox_get_by_alias(const char *alias) @@ -55,18 +55,6 @@ msg_mailbox_t MSG_mailbox_get_by_alias(const char *alias) return mailbox; } -msg_mailbox_t MSG_mailbox_get_by_channel(m_host_t host, - m_channel_t channel) -{ - XBT_WARN("DEPRECATED! Now use MSG_mailbox_get_by_alias"); - xbt_assert((host != NULL), "Invalid host"); - xbt_assert((channel >= 0) - && (channel < msg_global->max_channel), "Invalid channel %d", - channel); - - return host->simdata->mailboxes[(size_t) channel]; -} - MSG_error_t MSG_mailbox_get_task_ext(msg_mailbox_t mailbox, m_task_t * task, m_host_t host, double timeout) @@ -77,7 +65,6 @@ MSG_mailbox_get_task_ext(msg_mailbox_t mailbox, m_task_t * task, if (host) THROW_UNIMPLEMENTED; - CHECK_HOST(); #ifdef HAVE_TRACING TRACE_msg_task_get_start(); volatile double start_time = MSG_get_clock(); @@ -132,7 +119,6 @@ MSG_mailbox_put_with_timeout(msg_mailbox_t mailbox, m_task_t task, simdata_task_t t_simdata = NULL; m_process_t process = MSG_process_self(); simdata_process_t p_simdata = SIMIX_process_self_get_data(process); - CHECK_HOST(); #ifdef HAVE_TRACING int call_end = TRACE_msg_task_put_start(task); //must be after CHECK_HOST() @@ -147,6 +133,7 @@ MSG_mailbox_put_with_timeout(msg_mailbox_t mailbox, m_task_t task, "This task is still being used somewhere else. You cannot send it now. Go fix your code!"); t_simdata->isused=1; + t_simdata->comm = NULL; msg_global->sent_msg++; @@ -194,3 +181,17 @@ MSG_mailbox_put_with_timeout(msg_mailbox_t mailbox, m_task_t task, #endif MSG_RETURN(ret); } + +#ifdef MSG_USE_DEPRECATED +msg_mailbox_t MSG_mailbox_get_by_channel(m_host_t host, + m_channel_t channel) +{ + XBT_WARN("DEPRECATED! Now use MSG_mailbox_get_by_alias"); + xbt_assert((host != NULL), "Invalid host"); + xbt_assert((channel >= 0) + && (channel < msg_global->max_channel), "Invalid channel %d", + channel); + + return host->simdata->mailboxes[(size_t) channel]; +} +#endif