summaryrefslogtreecommitdiff
path: root/src/glibext
diff options
context:
space:
mode:
Diffstat (limited to 'src/glibext')
-rw-r--r--src/glibext/workgroup.h5
-rw-r--r--src/glibext/workqueue.c7
2 files changed, 11 insertions, 1 deletions
diff --git a/src/glibext/workgroup.h b/src/glibext/workgroup.h
index 1a003c8..f40155e 100644
--- a/src/glibext/workgroup.h
+++ b/src/glibext/workgroup.h
@@ -47,6 +47,11 @@ DECLARE_GTYPE(GWorkGroup, g_work_group, G, WORK_GROUP);
*/
typedef uint64_t wgroup_id_t;
+/**
+ * Marque de non initialisation.
+ */
+#define INVALID_GROUP_ID 0
+
/* Crée un nouveau thread dédié à un type de travaux donné. */
GWorkGroup *g_work_group_new(wgroup_id_t, guint);
diff --git a/src/glibext/workqueue.c b/src/glibext/workqueue.c
index ad6ede6..fe7f1bb 100644
--- a/src/glibext/workqueue.c
+++ b/src/glibext/workqueue.c
@@ -247,8 +247,13 @@ wgroup_id_t g_work_queue_define_group(GWorkQueue *queue, guint count)
do
{
- result = queue->generator++;
+ result = ++queue->generator;
+
+ if (result == INVALID_GROUP_ID)
+ continue;
+
created = g_work_queue_ensure_group_exists(queue, result, count);
+
}
while (!created);