Searched refs:tmr_next (Results 1 – 3 of 3) sorted by relevance
1439 rd_ts_t tmr_next; in rd_kafka_toppar_offset_retry() local1444 tmr_next = rd_kafka_timer_next(&rktp->rktp_rkt->rkt_rk->rk_timers, in rd_kafka_toppar_offset_retry()1447 restart_tmr = (tmr_next == -1 || in rd_kafka_toppar_offset_retry()1448 tmr_next > rd_clock() + (backoff_ms * 1000ll)); in rd_kafka_toppar_offset_retry()
1472 rd_ts_t tmr_next; in rd_kafka_toppar_offset_retry() local1477 tmr_next = rd_kafka_timer_next(&rktp->rktp_rkt->rkt_rk->rk_timers, in rd_kafka_toppar_offset_retry()1480 restart_tmr = (tmr_next == -1 || in rd_kafka_toppar_offset_retry()1481 tmr_next > rd_clock() + (backoff_ms * 1000ll)); in rd_kafka_toppar_offset_retry()
1458 rd_ts_t tmr_next; in rd_kafka_toppar_offset_retry() local1463 tmr_next = rd_kafka_timer_next(&rktp->rktp_rkt->rkt_rk->rk_timers, in rd_kafka_toppar_offset_retry()1466 restart_tmr = (tmr_next == -1 || in rd_kafka_toppar_offset_retry()1467 tmr_next > rd_clock() + (backoff_ms * 1000ll)); in rd_kafka_toppar_offset_retry()