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; } 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); } }