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 query by tags

Browse Source
This commit is contained in:
fengzero
2026-01-20 01:55:34 +00:00
parent abb76d3e80
commit e3d2cb7336
1 changed files with 28 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/core/node_manager.c
+28 -2
View File
@@ -271,10 +271,36 @@ UT_array *neu_node_manager_filter(neu_node_manager_t *mgr, int type,
continue;
}
if (strlen(node) > 0) {
if (strstr(el->adapter->name, node) == NULL &&
(el->tags == NULL || strstr(el->tags, node) == NULL)) {
char *name_find = strstr(el->adapter->name, node);
if (name_find == NULL && el->tags == NULL) {
continue;
}
if (el->tags != NULL) {
size_t index = 0;
char tag_split_array[10][NEU_NODE_TAGS_LEN] = { 0 };
char * token = strtok((char *) node, ",");
while (token != NULL &&
index < sizeof(tag_split_array) /
sizeof(tag_split_array[0])) {
strncpy(tag_split_array[index], token,
NEU_NODE_TAGS_LEN - 1);
index++;
token = strtok(NULL, ",");
}
bool tag_found = true;
for (size_t i = 0; i < index; i++) {
if (strstr(el->tags, tag_split_array[i]) == NULL) {
tag_found = false;
break;
}
}
if (!tag_found && name_find == NULL) {
continue;
}
}
}
if (q_state) {
if (el->adapter->state !=