mxq_group: Warn on database inconsistency

mariux · Jul 27, 2015 · a8513e7 · a8513e7
1 parent 9d6364c
commit a8513e7
Showing 1 changed file with 10 additions and 4 deletions.
diff --git a/mxq_group.c b/mxq_group.c
@@ -116,12 +116,15 @@ inline uint64_t mxq_group_jobs_done(struct mxq_group *g)
 
 inline uint64_t mxq_group_jobs_active(struct mxq_group *g)
 {
-    uint64_t inq;
+    uint64_t active;
 
-    inq  = g->group_jobs;
-    inq -= mxq_group_jobs_done(g);
+    active  = g->group_jobs;
+    active -= mxq_group_jobs_done(g);
 
-    return inq;
+    if (active != g->group_jobs_inq+g->group_jobs_running)
+        mx_log_warning("BUG: mxq_group: inconsistent 'active' (inq+run) value");
+
+    return active;
 }
 
 inline uint64_t mxq_group_jobs_inq(struct mxq_group *g)
@@ -131,6 +134,9 @@ inline uint64_t mxq_group_jobs_inq(struct mxq_group *g)
     inq  = mxq_group_jobs_active(g);
     inq -= g->group_jobs_running;
 
+    if (inq != g->group_jobs_inq)
+        mx_log_warning("BUG: mxq_group: inconsistent inq value");
+
     return inq;
 }