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

fix crash

Browse Source
This commit is contained in:
fengzero
2026-06-11 09:05:17 +00:00
parent 6a316339b9
commit 02eda2738d
2 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/restful/datatag_handle.c
-1
View File
@@ -51,7 +51,6 @@ void handle_add_tags(nng_aio *aio)
if (strcmp(req->tags[i].name, req->tags[k].name) == 0) {
neu_resp_add_tag_result(&add_resp, i,
NEU_ERR_TAG_NAME_CONFLICT);
break;
}
}
}
src/adapter/adapter.c
+3 -3
View File
@@ -1599,8 +1599,8 @@ static int adapter_loop(enum neu_event_io_type type, int fd, void *usr_data)
}
neu_msg_exchange(header);
header->type = NEU_RESP_ADD_TAG;
reply(adapter, header, &resp);
free(cmd->tags);
reply(adapter, header, &resp);
break;
}
@@ -1616,8 +1616,8 @@ static int adapter_loop(enum neu_event_io_type type, int fd, void *usr_data)
resp.error = NEU_ERR_TAG_NAME_CONFLICT;
neu_resp_add_tag_result(&resp, resp.index, resp.error);
header->type = NEU_RESP_ADD_TAG;
reply(adapter, header, &resp);
free(cmd->tags);
reply(adapter, header, &resp);
break;
}
@@ -1632,8 +1632,8 @@ static int adapter_loop(enum neu_event_io_type type, int fd, void *usr_data)
neu_resp_add_tag_result(&resp, 0, resp.error);
neu_msg_exchange(header);
header->type = NEU_RESP_ADD_TAG;
reply(adapter, header, &resp);
free(cmd->tags);
reply(adapter, header, &resp);
break;
}