Searched refs:defragStreamConsumer (Results 1 – 1 of 1) sorted by relevance
709 void* defragStreamConsumer(raxIterator *ri, void *privdata, long *defragged) { in defragStreamConsumer() function731 *defragged += defragRadixTree(&cg->consumers, 0, defragStreamConsumer, cg); in defragStreamConsumerGroup()