From cb8b793980354a95040bd374b7fce9bf53f49657 Mon Sep 17 00:00:00 2001 From: ZhouBox Date: Fri, 13 Mar 2026 15:29:12 +0800 Subject: [PATCH 1/2] log errno detail on message forward failure --- src/core/manager_internal.h | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/core/manager_internal.h b/src/core/manager_internal.h index de5f1183..fd53e174 100644 --- a/src/core/manager_internal.h +++ b/src/core/manager_internal.h @@ -20,6 +20,8 @@ #ifndef _NEU_MANAGER_INTERNAL_H_ #define _NEU_MANAGER_INTERNAL_H_ +#include + #include "event/event.h" #include "persist/persist.h" @@ -109,9 +111,9 @@ inline static void forward_msg(neu_manager_t * manager, if (0 == ret) { nlog_info("forward msg %s to %s", neu_reqresp_type_string(t), receiver); } else { - nlog_warn("forward msg %s to node (%s)%s %s %s fail", + nlog_warn("forward msg %s to node (%s)%s %s %s fail, errno: %s(%d)", neu_reqresp_type_string(t), receiver, &addr.sun_path[1], node, - header->sender); + header->sender, strerror(errno), errno); neu_msg_free(msg); } } From 8e57c67533149bfe9573723589e6bd0df37db3cd Mon Sep 17 00:00:00 2001 From: ZhouBox Date: Fri, 13 Mar 2026 16:39:33 +0800 Subject: [PATCH 2/2] fix monitor ready check to use abstract socket name index --- src/core/manager.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/core/manager.c b/src/core/manager.c index 14fdf8d8..b2cafbd2 100644 --- a/src/core/manager.c +++ b/src/core/manager.c @@ -1987,7 +1987,7 @@ inline static void notify_monitor(neu_manager_t * manager, // monitor not ready, ignore neu_node_manager_t *mgr = manager->node_manager; struct sockaddr_un addr = neu_node_manager_get_addr(mgr, "monitor"); - if (0 == addr.sun_path[0]) { + if (0 == addr.sun_path[1]) { return; }