engine: add task instrumentation

matthewfala · Nov 7, 2022 · 95b733c · 95b733c
1 parent b853a88
commit 95b733c
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/flb_engine.c b/src/flb_engine.c
@@ -106,6 +106,7 @@ int flb_engine_flush(struct flb_config *config,
     struct flb_input_instance *in;
     struct flb_input_plugin *p;
     struct mk_list *head;
+    char task_count[20];
 
     mk_list_foreach(head, &config->inputs) {
         in = mk_list_entry(head, struct flb_input_instance, _head);
@@ -117,6 +118,9 @@ int flb_engine_flush(struct flb_config *config,
         flb_engine_dispatch(0, in, config);
     }
 
+    sprintf(task_count, "%i", flb_task_running_count(config));
+    flb_log_recurring_event("task_count", task_count);
+
     return 0;
 }