diff --git a/plugins/restful/datatag_handle.c b/plugins/restful/datatag_handle.c index 113995ad2..df9dbdd69 100644 --- a/plugins/restful/datatag_handle.c +++ b/plugins/restful/datatag_handle.c @@ -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; } } } diff --git a/src/adapter/adapter.c b/src/adapter/adapter.c index 8a8d7feff..f9e16d7ec 100644 --- a/src/adapter/adapter.c +++ b/src/adapter/adapter.c @@ -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; }