summaryrefslogtreecommitdiff
path: root/src/core
diff options
context:
space:
mode:
Diffstat (limited to 'src/core')
-rw-r--r--src/core/queue.c10
-rw-r--r--src/core/queue.h3
2 files changed, 11 insertions, 2 deletions
diff --git a/src/core/queue.c b/src/core/queue.c
index 615e351..79a87b2 100644
--- a/src/core/queue.c
+++ b/src/core/queue.c
@@ -60,6 +60,13 @@ bool init_global_works(void)
g_work_queue_define_work_group(queue);
#endif
+#ifndef NDEBUG
+ expected = g_work_queue_define_work_group(queue);
+ assert(expected == LOADING_WORK_GROUP);
+#else
+ g_work_queue_define_work_group(queue);
+#endif
+
return true;
}
@@ -105,7 +112,8 @@ void wait_for_all_global_works(void)
GWorkQueue *queue; /* Singleton pour tâches */
static const wgroup_id_t group_ids[] = {
- DEFAULT_WORK_GROUP
+ DEFAULT_WORK_GROUP,
+ LOADING_WORK_GROUP
};
queue = get_work_queue();
diff --git a/src/core/queue.h b/src/core/queue.h
index 1984fff..bee16a4 100644
--- a/src/core/queue.h
+++ b/src/core/queue.h
@@ -34,8 +34,9 @@
*/
#define DEFAULT_WORK_GROUP 0
+#define LOADING_WORK_GROUP 1
-#define GLOBAL_WORK_GROUPS_COUNT 1
+#define GLOBAL_WORK_GROUPS_COUNT 2
/* Met en place les mécanismes de traitements parallèles. */