task: expose map_get_task_id to add a check in engine_dispatch

Signed-off-by: seblaz <[email protected]>
fluent · Apr 8, 2024 · 251c134 · 251c134
1 parent cf3e53c
commit 251c134
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/include/fluent-bit/flb_task.h b/include/fluent-bit/flb_task.h
@@ -125,6 +125,7 @@ struct flb_task_enqueued {
 
 int flb_task_running_count(struct flb_config *config);
 int flb_task_running_print(struct flb_config *config);
+int flb_task_map_get_task_id(struct flb_config *config);
 
 struct flb_task *flb_task_create(uint64_t ref_id,
                                  const char *buf,

diff --git a/src/flb_task.c b/src/flb_task.c
@@ -331,6 +331,10 @@ int flb_task_running_print(struct flb_config *config)
     return 0;
 }
 
+int flb_task_map_get_task_id(struct flb_config *config) {
+    return map_get_task_id(config);
+}
+
 /* Create an engine task to handle the output plugin flushing work */
 struct flb_task *flb_task_create(uint64_t ref_id,
                                  const char *buf,