diff --git a/src/etcp_connections.c b/src/etcp_connections.c index ca8463b..aa40178 100644 --- a/src/etcp_connections.c +++ b/src/etcp_connections.c @@ -220,18 +220,20 @@ static void keepalive_timer_cb(void* arg) { if (link->recv_keepalive != 0) { link->recv_keepalive = 0; // down link->link_status = 0; + etcp_on_link_down(link->etcp); DEBUG_WARN(DEBUG_CATEGORY_CONNECTION, "[%s] Link %p (local_id=%d) recv status changed to DOWN - " "no packets received for %llu ms (timeout=%u ms)", link->etcp->log_name, link, link->local_link_id, (unsigned long long)(elapsed / 10), link->keepalive_timeout); } - } else { - if (link->recv_keepalive != 1) { - link->recv_keepalive = 1; // up -// loadbalancer_link_ready(link); - DEBUG_INFO(DEBUG_CATEGORY_CONNECTION, "[%s] Link %p (local_id=%d) recv status changed to UP", link->etcp->log_name, link, link->local_link_id); - } } +// else { +// if (link->recv_keepalive != 1) { +// link->recv_keepalive = 1; // up +// loadbalancer_link_ready(link); +// DEBUG_ERROR(DEBUG_CATEGORY_CONNECTION, "[%s] Link %p (local_id=%d) recv status changed to UP", link->etcp->log_name, link, link->local_link_id); +// } +// } // Send keepalive only if no packets were sent since last tick if (!link->pkt_sent_since_keepalive) etcp_link_send_keepalive(link);