X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/2c69087d11c54eee924f6870373883d6aa9ff228..28e032fe2974bf84e0414e4d3d4cd89a38752dae:/src/msg/msg_mailbox.c diff --git a/src/msg/msg_mailbox.c b/src/msg/msg_mailbox.c index 0ef4c21f68..c2081d7dbb 100644 --- a/src/msg/msg_mailbox.c +++ b/src/msg/msg_mailbox.c @@ -116,10 +116,8 @@ MSG_mailbox_get_task_ext_bounded(msg_mailbox_t mailbox, msg_task_t * task, if (host) THROW_UNIMPLEMENTED; -#ifdef HAVE_TRACING TRACE_msg_task_get_start(); double start_time = MSG_get_clock(); -#endif /* Sanity check */ xbt_assert(task, "Null pointer for the task storage"); @@ -147,19 +145,20 @@ MSG_mailbox_get_task_ext_bounded(msg_mailbox_t mailbox, msg_task_t * task, case timeout_error: ret = MSG_TIMEOUT; break; + case host_error: + ret = MSG_HOST_FAILURE; + break; default: RETHROW; } xbt_ex_free(e); } -#ifdef HAVE_TRACING if (ret != MSG_HOST_FAILURE && ret != MSG_TRANSFER_FAILURE && ret != MSG_TIMEOUT) { TRACE_msg_task_get_end(start_time, *task); } -#endif MSG_RETURN(ret); } @@ -167,15 +166,12 @@ 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; simdata_task_t t_simdata = NULL; msg_process_t process = MSG_process_self(); simdata_process_t p_simdata = SIMIX_process_self_get_data(process); -#ifdef HAVE_TRACING int call_end = TRACE_msg_task_put_start(task); //must be after CHECK_HOST() -#endif /* Prepare the task to send */ t_simdata = task->simdata; @@ -204,17 +200,15 @@ MSG_mailbox_put_with_timeout(msg_mailbox_t mailbox, msg_task_t task, p_simdata->waiting_task = task; + xbt_ex_t e; /* Try to send it by calling SIMIX network layer */ TRY { smx_synchro_t comm = NULL; /* MC needs the comm to be set to NULL during the simix call */ comm = simcall_comm_isend(SIMIX_process_self(), mailbox,t_simdata->bytes_amount, t_simdata->rate, task, sizeof(void *), NULL, NULL, NULL, task, 0); -#ifdef HAVE_TRACING - if (TRACE_is_enabled()) { + if (TRACE_is_enabled()) simcall_set_category(comm, task->category); - } -#endif t_simdata->comm = comm; simcall_comm_wait(comm, timeout); } @@ -243,10 +237,8 @@ MSG_mailbox_put_with_timeout(msg_mailbox_t mailbox, msg_task_t task, p_simdata->waiting_task = NULL; -#ifdef HAVE_TRACING if (call_end) TRACE_msg_task_put_end(); -#endif MSG_RETURN(ret); }