static void
first_pass(struct trie_node *node, slab *trie_slab)
{
+ bug("");
assert(node != NULL);
assert(trie_slab != NULL);
static void
run_aggregation(struct aggregator_proto *p)
{
+ assert(p->root != NULL);
+ log("==== AGGREGATION START ====");
+
construct_trie(p);
calculate_trie(p);
collect_prefixes(p);
sl_free(old_bucket);
}
+ assert(p->root != NULL);
settle_kick(&p->aggr_timer);
}
settle_cancel(&p->aggr_timer);
+ assert(p->root != NULL);
delete_trie(p->root);
p->root = NULL;