Searched refs:RD_KAFKA_IDEMP_STATE_DRAIN_RESET (Results 1 – 6 of 6) sorted by relevance
68 new_state != RD_KAFKA_IDEMP_STATE_DRAIN_RESET && in rd_kafka_idemp_set_state()304 case RD_KAFKA_IDEMP_STATE_DRAIN_RESET: in rd_kafka_idemp_pid_fsm()468 if (rk->rk_eos.idemp_state == RD_KAFKA_IDEMP_STATE_DRAIN_RESET) { in rd_kafka_idemp_drain_done()525 rd_kafka_idemp_set_state(rk, RD_KAFKA_IDEMP_STATE_DRAIN_RESET); in rd_kafka_idemp_drain_reset()
128 RD_KAFKA_IDEMP_STATE_DRAIN_RESET, /**< Wait for outstanding enumerator
68 new_state != RD_KAFKA_IDEMP_STATE_DRAIN_RESET && in rd_kafka_idemp_set_state()356 case RD_KAFKA_IDEMP_STATE_DRAIN_RESET: in rd_kafka_idemp_pid_fsm()522 if (rk->rk_eos.idemp_state == RD_KAFKA_IDEMP_STATE_DRAIN_RESET) { in rd_kafka_idemp_drain_done()596 rd_kafka_idemp_set_state(rk, RD_KAFKA_IDEMP_STATE_DRAIN_RESET); in rd_kafka_idemp_drain_reset()
126 RD_KAFKA_IDEMP_STATE_DRAIN_RESET, /**< Wait for outstanding enumerator
68 new_state != RD_KAFKA_IDEMP_STATE_DRAIN_RESET &&356 case RD_KAFKA_IDEMP_STATE_DRAIN_RESET: in rd_buf_write_ensure()522 if (rk->rk_eos.idemp_state == RD_KAFKA_IDEMP_STATE_DRAIN_RESET) { in rd_segment_write_update()596 rd_kafka_idemp_set_state(rk, RD_KAFKA_IDEMP_STATE_DRAIN_RESET);