From f8ba169152d9fa2994103e514234929273cfef5f Mon Sep 17 00:00:00 2001 From: Igor Putovny Date: Thu, 30 May 2024 14:36:54 +0200 Subject: [PATCH] Don't run aggregation on feed end --- proto/aggregator/aggregator.c | 11 ----------- 1 file changed, 11 deletions(-) diff --git a/proto/aggregator/aggregator.c b/proto/aggregator/aggregator.c index 21251e319..bdf2b0e50 100644 --- a/proto/aggregator/aggregator.c +++ b/proto/aggregator/aggregator.c @@ -920,16 +920,6 @@ run_aggregation(struct aggregator_proto *p) log("==== AGGREGATION DONE ===="); } -static void -aggregate_on_feed_end(struct channel *C) -{ - struct aggregator_proto *p = SKIP_BACK(struct aggregator_proto, p, C->proto); - - /* Run aggregation only on feed end from the source channel */ - if (C == p->src) - run_aggregation(p); -} - static void aggregate_on_settle_timer(struct settle *s) { @@ -1549,7 +1539,6 @@ aggregator_init(struct proto_config *CF) P->rt_notify = aggregator_rt_notify; P->preexport = aggregator_preexport; - P->feed_end = aggregate_on_feed_end; return P; } -- 2.47.2