GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-28 05:56:39 +08:00
Code Issues Packages Projects Releases Wiki Activity

modify log level and content

Browse Source
This commit is contained in:
zhouxiang
2023-03-01 13:17:02 +08:00
parent 1c61162ac5
commit c0091244f3
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/adapter/adapter.c
+4 -2
View File
@@ -1048,9 +1048,11 @@ inline static void reply(neu_adapter_t *adapter, neu_reqresp_head_t *header,
{
nng_msg *msg = neu_msg_gen(header, data);
if (nng_sendmsg(adapter->sock, msg, 0) != 0) {
int ret = nng_sendmsg(adapter->sock, msg, 0);
if (ret != 0) {
nng_msg_free(msg);
nlog_error("adapter reply fail! adapter:%s receiver:%s", adapter->name, header->receiver);
nlog_warn("reply %s to %s of %s, error:%s", header->sender, header->receiver,
neu_reqresp_type_string(header->type), nng_strerror(ret));
}
}