Searched refs:rk_broker_down_cnt (Results 1 – 6 of 6) sorted by relevance
233 rd_atomic32_t rk_broker_down_cnt; member
300 if (rd_atomic32_add(&rkb->rkb_rk->rk_broker_down_cnt, 1) == in rd_kafka_broker_set_state()308 rk_broker_down_cnt), in rd_kafka_broker_set_state()317 rd_atomic32_sub(&rkb->rkb_rk->rk_broker_down_cnt, 1); in rd_kafka_broker_set_state()
237 rd_atomic32_t rk_broker_down_cnt; member
320 if (rd_atomic32_add(&rkb->rkb_rk->rk_broker_down_cnt, 1) == in rd_kafka_broker_set_state()329 rk_broker_down_cnt), in rd_kafka_broker_set_state()338 rd_atomic32_sub(&rkb->rkb_rk->rk_broker_down_cnt, 1); in rd_kafka_broker_set_state()
312 if (rd_atomic32_add(&rkb->rkb_rk->rk_broker_down_cnt, 1) == in rd_kafka_broker_set_state()320 rk_broker_down_cnt), in rd_kafka_broker_set_state()329 rd_atomic32_sub(&rkb->rkb_rk->rk_broker_down_cnt, 1); in rd_kafka_broker_set_state()