Don't run aggregation on feed end

diff --git a/proto/aggregator/aggregator.c b/proto/aggregator/aggregator.c
index 21251e3190e641cc2596e53caf01ab6102da5ad5..bdf2b0e50d11f18a72e3cee774f697917c087f88 100644 (file)
--- 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;
 }