From a65ef30d78b67f71a83eaebaa8491d76dcd18839 Mon Sep 17 00:00:00 2001
From: evgeny <evgeny@adaptto.ru>
Date: Thu, 1 Oct 2026 00:51:17 +0300
Subject: [PATCH] conn_mgr: resume recovery when local sockets change

---
 src/routing_layer/conn_mgr.h           | 5 ++++-
 src/transport_layer/auto_socket.c      | 7 +++++++
 src/transport_layer/node_conn_direct.c | 5 +++++
 3 files changed, 16 insertions(+), 1 deletion(-)

diff --git a/src/routing_layer/conn_mgr.h b/src/routing_layer/conn_mgr.h
index 8f0e9b8a..787af9ac 100644
--- a/src/routing_layer/conn_mgr.h
+++ b/src/routing_layer/conn_mgr.h
@@ -31,7 +31,7 @@ struct TOPO_GROUP;
 
 enum conn_mgr_event {
     CONN_EVENT_UP      = 0,  /* связь есть. handle жив, можно отправлять данные               */
-    CONN_EVENT_DOWN    = 1,  /* связь потеряна; handle остаётся у владельца, успех восстановления не гарантирован */
+    CONN_EVENT_DOWN    = 1,  /* все пути потеряны; восстановление продолжается, пока жив handle */
     CONN_EVENT_TIMEOUT = 2,  /* подключение не удалось. handle жив, закройте сами             */
 };
 
@@ -93,6 +93,9 @@ void conn_mgr_update_best_candidates(struct CONN_MGR* mgr, uint64_t node_id, uin
 /** Запланировать перепроверку путей после изменения маршрутов или READY групповых сессий. */
 void conn_mgr_routes_changed(struct CONN_MGR* mgr);
 
+/** Изменились локальные сокеты: начать восстановление без ожидания backoff, сохраняя работающие пути. */
+void conn_mgr_network_changed(struct CONN_MGR* mgr);
+
 /** Заимствованный next hop: READY прямой путь/подтверждённый посредник; allow_probe — только для управляющего обмена CM. */
 struct ETCP_CONN* conn_mgr_route_conn(struct CONN_MGR* mgr, uint64_t node_id, int allow_probe);
 
diff --git a/src/transport_layer/auto_socket.c b/src/transport_layer/auto_socket.c
index 351cf721..f5d61800 100644
--- a/src/transport_layer/auto_socket.c
+++ b/src/transport_layer/auto_socket.c
@@ -52,6 +52,8 @@
 #include "config_parser.h"
 #include "../chat/chat_event.h"
 #include "../chat/chat_sync.h"
+#include "../routing_layer/topo_group.h"
+#include "../routing_layer/conn_mgr.h"
 #include "../lib/debug_config.h"
 #include "../lib/mem.h"
 #include "../lib/u_async.h"
@@ -238,6 +240,11 @@ static void auto_socket_post_sockets_changed(struct AUTO_SOCKET* as) {
         need_reconnect = 1;
     as->v4_addr_changed = 0; as->v6_addr_changed = 0;
 
+    struct TOPO_GROUPS* groups = as->instance->topo_groups;
+    for (struct ll_entry* e = groups && groups->group_list ? groups->group_list->head : NULL; e; e = e->next) {
+        struct TOPO_GROUP* group = (struct TOPO_GROUP*)e;
+        if (!group->stopping) conn_mgr_network_changed(group->conn_mgr);
+    }
     chat_event_post(as->instance, CHAT_EVT_LOCAL_SOCKETS, NULL, 0);
 
     if (need_reconnect) {
diff --git a/src/transport_layer/node_conn_direct.c b/src/transport_layer/node_conn_direct.c
index aa5d4bc9..d99fa131 100644
--- a/src/transport_layer/node_conn_direct.c
+++ b/src/transport_layer/node_conn_direct.c
@@ -206,6 +206,11 @@ static int ncd_add_tcp_link(struct ETCP_CONN* conn, struct ETCP_SOCKET* sock,
                        (unsigned long long)conn->peer_node_id, link->local_link_id, link->link_status);
             if (!link->link_status) etcp_tcp_link_start_reconnect(link);
         }
+        if (!link->link_status && !link->tcp_link && !link->tcp_reconnect_timer) {
+            DEBUG_INFO(DEBUG_CATEGORY_NCD, "[ncd] resume idle TCP probe node=%016llx link=%u",
+                       (unsigned long long)conn->peer_node_id, link->local_link_id);
+            etcp_tcp_link_start_reconnect(link);
+        }
         return 0;
     }
     struct ETCP_LINK* link = etcp_link_new(conn, sock, addr, 0);