X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/07c319ec54d6fc778ee3cc5e75a747242006723e..806504b9602a886e391b54e458b2c1f7f42d3afb:/src/msg/msg_mailbox.c diff --git a/src/msg/msg_mailbox.c b/src/msg/msg_mailbox.c index 29ae2e5b20..fad007c211 100644 --- a/src/msg/msg_mailbox.c +++ b/src/msg/msg_mailbox.c @@ -13,7 +13,7 @@ XBT_LOG_NEW_DEFAULT_SUBCATEGORY(msg_mailbox, msg, msg_mailbox_t MSG_mailbox_new(const char *alias) { - return SIMIX_req_rdv_create(alias ? xbt_strdup(alias) : NULL); + return SIMIX_req_rdv_create(alias); } void MSG_mailbox_free(void *mailbox) @@ -33,7 +33,7 @@ m_task_t MSG_mailbox_get_head(msg_mailbox_t mailbox) if (!comm) return NULL; - return (m_task_t) SIMIX_req_comm_get_data(comm); + return (m_task_t) SIMIX_req_comm_get_src_data(comm); } int @@ -95,8 +95,9 @@ MSG_mailbox_get_task_ext(msg_mailbox_t mailbox, m_task_t * task, /* Try to receive it by calling SIMIX network layer */ TRY { - comm = SIMIX_req_comm_irecv(mailbox, task, NULL); + comm = SIMIX_req_comm_irecv(mailbox, task, NULL, NULL, NULL); SIMIX_req_comm_wait(comm, timeout); + SIMIX_req_comm_destroy(comm); DEBUG2("Got task %s from %p",(*task)->name,mailbox); (*task)->simdata->refcount--; } @@ -112,6 +113,7 @@ MSG_mailbox_get_task_ext(msg_mailbox_t mailbox, m_task_t * task, ret = MSG_TIMEOUT; break; default: + xbt_backtrace_display(&e); xbt_die(bprintf("Unhandled SIMIX network exception: %s", e.msg)); } xbt_ex_free(e); @@ -160,8 +162,12 @@ MSG_mailbox_put_with_timeout(msg_mailbox_t mailbox, m_task_t task, /* Try to send it by calling SIMIX network layer */ TRY { t_simdata->comm = SIMIX_req_comm_isend(mailbox, t_simdata->message_size, - t_simdata->rate, task, sizeof(void *), task); + t_simdata->rate, task, sizeof(void *), NULL, task); +#ifdef HAVE_TRACING + SIMIX_req_set_category(t_simdata->comm, task->category); +#endif SIMIX_req_comm_wait(t_simdata->comm, timeout); + SIMIX_req_comm_destroy(t_simdata->comm); } CATCH(e) {