output: release instance when init failed (fluent#3576)

Signed-off-by: Takahiro Yamashita <[email protected]>
xmcqueen · Jun 29, 2021 · 489a83e · 489a83e
1 parent 8cdba69
commit 489a83e
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/flb_output.c b/src/flb_output.c
@@ -841,6 +841,7 @@ int flb_output_init_all(struct flb_config *config)
         if (p->type == FLB_OUTPUT_PLUGIN_PROXY) {
             ret = flb_plugin_proxy_init(p->proxy, ins, config);
             if (ret == -1) {
+                flb_output_instance_destroy(ins);
                 return -1;
             }
             continue;
@@ -878,6 +879,7 @@ int flb_output_init_all(struct flb_config *config)
             if (!config_map) {
                 flb_error("[output] error loading config map for '%s' plugin",
                           p->name);
+                flb_output_instance_destroy(ins);
                 return -1;
             }
             ins->config_map = config_map;
@@ -940,6 +942,7 @@ int flb_output_init_all(struct flb_config *config)
         if (ret == -1) {
             flb_error("[output] Failed to initialize '%s' plugin",
                       p->name);
+            flb_output_instance_destroy(ins);
             return -1;
         }
 
@@ -949,6 +952,7 @@ int flb_output_init_all(struct flb_config *config)
             if (ret == -1) {
                 flb_error("[output] could not start thread pool for '%s' plugin",
                           p->name);
+                flb_output_instance_destroy(ins);
                 return -1;
             }