static void
aggregate_on_feed_end(struct channel *C)
{
- struct aggregator_proto *p = SKIP_BACK(struct aggregator_proto, p, 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)
}
static void
-aggregate_on_settle_timer(struct settle *timer)
+aggregate_on_settle_timer(struct settle *s)
{
- struct aggregator_proto *p = SKIP_BACK(struct aggregator_proto, p, timer);
+ struct aggregator_proto *p = SKIP_BACK(struct aggregator_proto, p, s->tm.data);
run_aggregation(p);
}