Lines Matching refs:next_attempt
586 int64_t next_attempt; in process_pubs() local
595 next_attempt = 0; in process_pubs()
598 next_attempt = pub->con.last_attempt + T_RETRY_MSEC; in process_pubs()
602 if (next_attempt <= now) { in process_pubs()
624 next_attempt = now + T_RETRY_MSEC; in process_pubs()
630 if (next_attempt > now && (*next_cycle == 0 || next_attempt < *next_cycle)) { in process_pubs()
631 *next_cycle = next_attempt; in process_pubs()
644 int64_t next_attempt; in process_topics() local
651 next_attempt = 0; in process_topics()
654 next_attempt = topic->con.last_attempt + T_RETRY_MSEC; in process_topics()
658 if (next_attempt <= now) { in process_topics()
669 next_attempt = now + T_RETRY_MSEC; in process_topics()
680 next_attempt = now + T_RETRY_MSEC; in process_topics()
690 next_attempt = now + T_RETRY_MSEC; in process_topics()
698 if (next_attempt > now && (*next_cycle == 0 || next_attempt < *next_cycle)) { in process_topics()
699 *next_cycle = next_attempt; in process_topics()