flb_chunk_trace: abstract out the pipeline thread into its own API.

Signed-off-by: Phillip Whelan <[email protected]>
fluent · Oct 26, 2023 · 4acff0e · 4acff0e
1 parent 56d3b2c
commit 4acff0e
Show file tree

Hide file tree

Showing 2 changed files with 202 additions and 83 deletions.
diff --git a/include/fluent-bit/flb_chunk_trace.h b/include/fluent-bit/flb_chunk_trace.h
@@ -67,22 +67,27 @@ struct flb_chunk_trace_limit {
     int count;
 };
 
-struct flb_chunk_trace_context {
+struct flb_chunk_pipeline_context {
+    flb_ctx_t *flb;
+    flb_sds_t output_name;
+    pthread_t thread;
+    pthread_mutex_t lock;
+    pthread_cond_t cond;
+    struct mk_list *props;
+    void *data;
     void *input;
     void *output;
+};
+
+struct flb_chunk_trace_context {
+    void *input;
     int trace_count;
     struct flb_chunk_trace_limit limit;
     flb_sds_t trace_prefix;
     int to_destroy;
     int chunks;
-    flb_ctx_t *flb;
-    struct cio_ctx *cio;
-    pthread_t thread;
-    pthread_cond_t wait;
-    pthread_mutex_t lock;
-    flb_sds_t output_name;
-    struct mk_list *props;
-    void *data;
+
+    struct flb_chunk_pipeline_context pipeline;
 };
 
 struct flb_chunk_trace {