X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/e5922b4dce28002422ca9d68a4c44521f67c0f6f..82904dcc37f75453c571a1a74e67c1ba282ebe23:/src/msg/task.c?ds=sidebyside diff --git a/src/msg/task.c b/src/msg/task.c index 2a9a5c09d9..b0df136d09 100644 --- a/src/msg/task.c +++ b/src/msg/task.c @@ -159,25 +159,22 @@ MSG_error_t MSG_task_destroy(m_task_t task) smx_action_t action = NULL; xbt_assert((task != NULL), "Invalid parameter"); - /* why? if somebody is using, then you can't free! ok... but will return MSG_OK? when this task will be destroyed? isn't the user code wrong? */ - if (task->simdata->isused > 0) { - XBT_DEBUG("Cannot destroy task %p since somebody is using it", task); - return MSG_OK; + if (task->simdata->isused) { + /* the task is still being used, it may be an unfinished dsend */ + MSG_task_cancel(task); } #ifdef HAVE_TRACING TRACE_msg_task_destroy(task); #endif - if (task->name) - free(task->name); + xbt_free(task->name); action = task->simdata->compute; if (action) SIMIX_req_host_execution_destroy(action); /* parallel tasks only */ - if (task->simdata->host_list) - xbt_free(task->simdata->host_list); + xbt_free(task->simdata->host_list); /* free main structures */ xbt_free(task->simdata); @@ -201,6 +198,7 @@ MSG_error_t MSG_task_cancel(m_task_t task) } else if (task->simdata->comm) { SIMIX_req_comm_cancel(task->simdata->comm); + task->simdata->isused = 0; } else { static int warned = 0;