|
@@ -303,16 +303,13 @@ void _starpu_handle_job_termination(struct _starpu_job *j)
|
|
|
0
|
|
|
#endif
|
|
|
;
|
|
|
+
|
|
|
if (!continuation)
|
|
|
{
|
|
|
void (*epilogue_callback)(void *) = task->epilogue_callback_func;
|
|
|
/* the epilogue callback is executed before the dependencies release*/
|
|
|
if (epilogue_callback)
|
|
|
{
|
|
|
- int profiling = starpu_profiling_status_get();
|
|
|
- if (profiling && task->profiling_info)
|
|
|
- _starpu_clock_gettime(&task->profiling_info->callback_start_time);
|
|
|
-
|
|
|
/* so that we can check whether we are doing blocking calls
|
|
|
* within the callback */
|
|
|
_starpu_set_local_worker_status(STATUS_CALLBACK);
|
|
@@ -331,11 +328,9 @@ void _starpu_handle_job_termination(struct _starpu_job *j)
|
|
|
_starpu_set_current_task(current_task);
|
|
|
|
|
|
_starpu_set_local_worker_status(STATUS_UNKNOWN);
|
|
|
-
|
|
|
- if (profiling && task->profiling_info)
|
|
|
- _starpu_clock_gettime(&task->profiling_info->callback_end_time);
|
|
|
}
|
|
|
}
|
|
|
+
|
|
|
#ifdef STARPU_DEBUG
|
|
|
STARPU_PTHREAD_MUTEX_LOCK(&all_jobs_list_mutex);
|
|
|
_starpu_job_multilist_erase_all_submitted(&all_jobs_list, j);
|