Skip to content

Commit fd54f7b

Browse files
committed
in_prometheus_remote_write: honor queue ownership
Signed-off-by: Eduardo Silva <eduardo@chronosphere.io>
1 parent b8c0dcb commit fd54f7b

1 file changed

Lines changed: 1 addition & 6 deletions

File tree

plugins/in_prometheus_remote_write/prom_rw_prot.c

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -76,12 +76,7 @@ static int process_payload_metrics_ng(struct flb_prom_remote_write *ctx,
7676

7777
result = prom_rw_ingest_metrics(ctx, NULL, 0, context);
7878

79-
if (prom_rw_uses_worker_ingress_queue(ctx)) {
80-
if (result != 0 && result != FLB_INPUT_INGRESS_BUSY) {
81-
cmt_decode_prometheus_remote_write_destroy(context);
82-
}
83-
}
84-
else {
79+
if (!prom_rw_uses_worker_ingress_queue(ctx)) {
8580
cmt_decode_prometheus_remote_write_destroy(context);
8681
}
8782

0 commit comments

Comments
 (0)