Use new plugin log api

Signed-off-by: sirwio <[email protected]>
fluent · Nov 18, 2020 · 9062cea · 9062cea
1 parent 59b6315
commit 9062cea
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/plugins/out_es/es.c b/plugins/out_es/es.c
@@ -513,7 +513,7 @@ static int cb_es_init(struct flb_output_instance *ins,
 
     ctx = flb_calloc(1, sizeof(struct flb_elasticsearch));
     if (!ctx) {
-        flb_errno();
+        flb_plg_error(ins, "cannot initialize plugin");
         return -1;
     }
     ctx->ins = ins;

diff --git a/plugins/out_es/es_conf.c b/plugins/out_es/es_conf.c
@@ -277,7 +277,7 @@ int es_config_ha(const char *upstream_file,
     ctx->ha_mode = FLB_TRUE;
     ctx->ha = flb_upstream_ha_from_file(upstream_file, config);
     if (!ctx->ha) {
-        flb_error("[out_es] cannot load Upstream file");
+        flb_plg_error(ctx->ins, "cannot load Upstream file");
         return -1;
     }
 
@@ -296,7 +296,7 @@ int es_config_ha(const char *upstream_file,
         ec = flb_calloc(1, sizeof(struct flb_elasticsearch_config));
         if (!ec) {
             flb_errno();
-            flb_error("[out_es] failed config allocation");
+            flb_plg_error(ctx->ins, "failed config allocation");
             continue;
         }