Searched refs:_consumer_t (Results 1 – 3 of 3) sorted by relevance
49 } _consumer_t; typedef56 _consumer_t *c, int64_t start, in static_member_wait_rebalance0()102 _consumer_t *c = opaque; in rebalance_cb()148 _consumer_t c[_CONSUMER_CNT] = RD_ZERO_INIT; in do_test_static_group_rebalance()
49 } _consumer_t; typedef56 _consumer_t *c, int64_t start, in static_member_wait_rebalance0()99 _consumer_t *c = opaque; in rebalance_cb()145 _consumer_t c[_CONSUMER_CNT] = RD_ZERO_INIT; in do_test_static_group_rebalance()