GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-17 04:40:42 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #2711 from ZhouBox/v2.13

Browse Source 
[v2.13]log errno detail on message forward failure
This commit is contained in:
fengzeroz
2026-03-13 17:06:44 +08:00
committed by GitHub
parent 22ab84bfdb 8e57c67533
commit dc73b5cc4c
2 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/core/manager.c
+1 -1
View File
@@ -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;
}
src/core/manager_internal.h
+4 -2
View File
@@ -20,6 +20,8 @@
#ifndef _NEU_MANAGER_INTERNAL_H_
#define _NEU_MANAGER_INTERNAL_H_
#include <errno.h>
#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);
}
}