Merge pull request #8123 from nokute78/init_in_calyptia_fleet

in_calyptia_fleet: add missing release function
fluent · Nov 3, 2023 · a4f50c3 · a4f50c3
2 parents 818de85 + 9f3cc81
commit a4f50c3
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/plugins/in_calyptia_fleet/in_calyptia_fleet.c b/plugins/in_calyptia_fleet/in_calyptia_fleet.c
@@ -1158,13 +1158,15 @@ static int in_calyptia_fleet_init(struct flb_input_instance *in,
 
         if (tmpdir == NULL) {
             flb_plg_error(in, "unable to find temporary directory (%%TEMP%%).");
+            flb_free(ctx);
             return -1;
         }
 
         ctx->config_dir = flb_sds_create_size(4096);
 
         if (ctx->config_dir == NULL) {
             flb_plg_error(in, "unable to allocate config-dir.");
+            flb_free(ctx);
             return -1;
         }
         flb_sds_printf(&ctx->config_dir, "%s" PATH_SEPARATOR "%s", tmpdir, "calyptia-fleet");
@@ -1213,6 +1215,7 @@ static int in_calyptia_fleet_init(struct flb_input_instance *in,
 
     if (ret == -1) {
         flb_plg_error(ctx->ins, "could not initialize collector for fleet input plugin");
+        flb_upstream_destroy(ctx->u);
         flb_free(ctx);
         return -1;
     }