|
|
|
@ -193,7 +193,7 @@ void cm_candidate_ping_timer_cb(void* arg) { |
|
|
|
if (cm_has_active_conn(mgr->group, nid)) { |
|
|
|
if (cm_has_active_conn(mgr->group, nid)) { |
|
|
|
struct ETCP_CONN* dc = topo_group_find_conn_for_node(mgr->group, nid); |
|
|
|
struct ETCP_CONN* dc = topo_group_find_conn_for_node(mgr->group, nid); |
|
|
|
struct TOPO_NODE* ni = topo_node_registry_find(mgr->instance->topo_groups, nq->node_id); |
|
|
|
struct TOPO_NODE* ni = topo_node_registry_find(mgr->instance->topo_groups, nq->node_id); |
|
|
|
if (ni && dc) etcp_send_ping(mgr->instance, ni->public_key, &dc->links->remote_addr, CONN_PROBE_TIMEOUT_MS, NULL, NULL, NULL, 0); |
|
|
|
if (ni && dc) etcp_send_ping(mgr->instance, ni->public_key, &dc->links->remote_addr, CONN_PROBE_TIMEOUT_MS, cm_bg_ping_noop_cb, NULL, NULL, 0); |
|
|
|
} else route_connectivity_probe_node(mgr->instance, mgr->group, nq); |
|
|
|
} else route_connectivity_probe_node(mgr->instance, mgr->group, nq); |
|
|
|
} |
|
|
|
} |
|
|
|
mgr->candidate_ping_timer = uasync_set_timeout(mgr->instance->ua, CONN_MGR_CANDIDATE_PING_TB, mgr, cm_candidate_ping_timer_cb, "conn_mgr_cand_ping"); |
|
|
|
mgr->candidate_ping_timer = uasync_set_timeout(mgr->instance->ua, CONN_MGR_CANDIDATE_PING_TB, mgr, cm_candidate_ping_timer_cb, "conn_mgr_cand_ping"); |
|
|
|
|