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

fix(adapter): memory leak if sendmsg fail

Browse Source
This commit is contained in:
fengzero
2022-06-22 09:24:16 +00:00
parent 3d2f9f4e81
commit cd973f3737
1 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/adapter/adapter.c
+10 -2
View File
@@ -207,8 +207,12 @@ static int adapter_response(neu_adapter_t *adapter, neu_reqresp_head_t *header,
}
nng_msg *msg = neu_msg_gen(header, data);
int ret = nng_sendmsg(adapter->sock, msg, 0);
if (ret != 0) {
nng_msg_free(msg);
}
return nng_sendmsg(adapter->sock, msg, 0);
return ret;
}
static int adapter_loop(enum neu_event_io_type type, int fd, void *usr_data)
@@ -553,7 +557,11 @@ static int adapter_loop(enum neu_event_io_type type, int fd, void *usr_data)
strcpy(cmd->node, adapter->name);
uninit_msg = neu_msg_gen(header, cmd);
nng_sendmsg(adapter->sock, uninit_msg, 0);
if (nng_sendmsg(adapter->sock, uninit_msg, 0) == 0) {
nlog_warn("send uninit msg to %s", header->receiver);
} else {
nng_msg_free(uninit_msg);
}
break;
}