GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-23 18:37:45 +08:00
Code Issues Packages Projects Releases Wiki Activity

rm dup error

Browse Source
This commit is contained in:
fengzero
2026-06-12 07:34:07 +00:00
parent e36ce77992
commit 93b5ee3828
1 changed files with 33 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/adapter/adapter.c
+33
View File
@@ -68,6 +68,37 @@ inline static void reply(neu_adapter_t *adapter, neu_reqresp_head_t *header,
inline static void notify_monitor(neu_adapter_t * adapter,
neu_reqresp_type_e event, void *data);
static void dedup_add_tag_results_by_index(neu_resp_add_tag_t *resp)
{
if (resp == NULL || resp->results == NULL) {
return;
}
size_t n_results = utarray_len(resp->results);
if (n_results < 2) {
return;
}
for (size_t i = 0; i < n_results; i++) {
neu_resp_tag_op_result_t *current =
(neu_resp_tag_op_result_t *) utarray_eltptr(resp->results, i);
if (current == NULL) {
continue;
}
for (size_t j = i + 1; j < n_results;) {
neu_resp_tag_op_result_t *candidate =
(neu_resp_tag_op_result_t *) utarray_eltptr(resp->results, j);
if (candidate != NULL && candidate->index == current->index) {
utarray_erase(resp->results, j, 1);
n_results--;
continue;
}
j++;
}
}
}
static const adapter_callbacks_t callback_funs = {
.command = adapter_command,
.response = adapter_response,
@@ -1611,6 +1642,7 @@ 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;
free(cmd->tags);
dedup_add_tag_results_by_index(&resp);
reply(adapter, header, &resp);
break;
}
@@ -1631,6 +1663,7 @@ 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;
dedup_add_tag_results_by_index(&resp);
reply(adapter, header, &resp);
break;
}