task: fix counter of running tasks, use 'users' counter (fluent#2411)

Signed-off-by: Eduardo Silva <[email protected]>
xmcqueen · Oct 6, 2020 · 196d9c0 · 196d9c0
1 parent 33cf48e
commit 196d9c0
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/src/flb_task.c b/src/flb_task.c
@@ -272,11 +272,18 @@ int flb_task_running_count(struct flb_config *config)
 {
     int count = 0;
     struct mk_list *head;
+    struct mk_list *t_head;
+    struct flb_task *task;
     struct flb_input_instance *ins;
 
     mk_list_foreach(head, &config->inputs) {
         ins = mk_list_entry(head, struct flb_input_instance, _head);
-        count += mk_list_size(&ins->tasks);
+        mk_list_foreach(t_head, &ins->tasks) {
+            task = mk_list_entry(t_head, struct flb_task, _head);
+            if (task->users > 0) {
+                count++;
+            }
+        }
     }
 
     return count;