|
@@ -38,7 +38,7 @@ static int njobs, maxnjobs;
|
|
|
|
|
|
#ifdef STARPU_DEBUG
|
|
#ifdef STARPU_DEBUG
|
|
/* List of all jobs, for debugging */
|
|
/* List of all jobs, for debugging */
|
|
-static struct _starpu_job_list all_jobs_list;
|
|
|
|
|
|
+static struct _starpu_job_multilist_all_submitted all_jobs_list;
|
|
static starpu_pthread_mutex_t all_jobs_list_mutex = STARPU_PTHREAD_MUTEX_INITIALIZER;
|
|
static starpu_pthread_mutex_t all_jobs_list_mutex = STARPU_PTHREAD_MUTEX_INITIALIZER;
|
|
#endif
|
|
#endif
|
|
|
|
|
|
@@ -46,7 +46,7 @@ void _starpu_job_init(void)
|
|
{
|
|
{
|
|
max_memory_use = starpu_get_env_number_default("STARPU_MAX_MEMORY_USE", 0);
|
|
max_memory_use = starpu_get_env_number_default("STARPU_MAX_MEMORY_USE", 0);
|
|
#ifdef STARPU_DEBUG
|
|
#ifdef STARPU_DEBUG
|
|
- _starpu_job_list_init(&all_jobs_list);
|
|
|
|
|
|
+ _starpu_job_multilist_init_all_submitted(&all_jobs_list);
|
|
#endif
|
|
#endif
|
|
}
|
|
}
|
|
|
|
|
|
@@ -255,7 +255,7 @@ void _starpu_handle_job_submission(struct _starpu_job *j)
|
|
|
|
|
|
#ifdef STARPU_DEBUG
|
|
#ifdef STARPU_DEBUG
|
|
STARPU_PTHREAD_MUTEX_LOCK(&all_jobs_list_mutex);
|
|
STARPU_PTHREAD_MUTEX_LOCK(&all_jobs_list_mutex);
|
|
- _starpu_job_list_push_back(&all_jobs_list, j, all_submitted);
|
|
|
|
|
|
+ _starpu_job_multilist_push_back_all_submitted(&all_jobs_list, j);
|
|
STARPU_PTHREAD_MUTEX_UNLOCK(&all_jobs_list_mutex);
|
|
STARPU_PTHREAD_MUTEX_UNLOCK(&all_jobs_list_mutex);
|
|
#endif
|
|
#endif
|
|
}
|
|
}
|
|
@@ -275,7 +275,7 @@ void _starpu_handle_job_termination(struct _starpu_job *j)
|
|
|
|
|
|
#ifdef STARPU_DEBUG
|
|
#ifdef STARPU_DEBUG
|
|
STARPU_PTHREAD_MUTEX_LOCK(&all_jobs_list_mutex);
|
|
STARPU_PTHREAD_MUTEX_LOCK(&all_jobs_list_mutex);
|
|
- _starpu_job_list_erase(&all_jobs_list, j, all_submitted);
|
|
|
|
|
|
+ _starpu_job_multilist_erase_all_submitted(&all_jobs_list, j);
|
|
STARPU_PTHREAD_MUTEX_UNLOCK(&all_jobs_list_mutex);
|
|
STARPU_PTHREAD_MUTEX_UNLOCK(&all_jobs_list_mutex);
|
|
#endif
|
|
#endif
|
|
|
|
|