input: fix custom calyptia test (input/output initialization).

Set coroutine parameters to NULL for input and output via their initializers. Signed-off-by: Phillip Whelan <[email protected]>
fluent · Nov 6, 2023 · ef2f7fd · ef2f7fd
1 parent 0abf858
commit ef2f7fd
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 2 deletions.
diff --git a/src/flb_input.c b/src/flb_input.c
@@ -144,6 +144,7 @@ int flb_input_log_check(struct flb_input_instance *ins, int l)
 void flb_input_init()
 {
     FLB_TLS_INIT(in_collect_params);
+    FLB_TLS_SET(in_collect_params, NULL);
 }
 
 void flb_input_exit()

diff --git a/src/flb_output.c b/src/flb_output.c
@@ -45,6 +45,7 @@ FLB_TLS_DEFINE(struct flb_out_flush_params, out_flush_params);
 void flb_output_prepare()
 {
     FLB_TLS_INIT(out_flush_params);
+    FLB_TLS_SET(out_flush_params, NULL);
 }
 
 /* Validate the the output address protocol */

diff --git a/tests/runtime/custom_calyptia_test.c b/tests/runtime/custom_calyptia_test.c
@@ -19,6 +19,9 @@ void flb_custom_calyptia_pipeline_config_get_test()
     ctx = flb_create();
     flb_service_set(ctx, "flush", "1", "grace", "1", NULL);
 
+    flb_input_init();
+    flb_output_prepare();
+
     in_ffd_dummy = flb_input(ctx, (char *) "dummy", NULL);
     TEST_CHECK(in_ffd_dummy >= 0);
 
@@ -46,8 +49,6 @@ void flb_custom_calyptia_pipeline_config_get_test()
     cfg = custom_calyptia_pipeline_config_get(ctx->config);
     TEST_CHECK(strcmp(cfg, cfg_str) == 0);
 
-    // fix a thread local storage bug on macos
-    flb_output_prepare();
     flb_sds_destroy(cfg);
     flb_destroy(ctx);
 }