Searched refs:next_attempt (Results 1 – 1 of 1) sorted by relevance
586 int64_t next_attempt; in process_pubs() local595 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() local651 next_attempt = 0; in process_topics()654 next_attempt = topic->con.last_attempt + T_RETRY_MSEC; in process_topics()[all …]
