xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

add rd lock while range keys

This commit is contained in:
xiao77 2024-09-03 20:22:26 +08:00
parent 97bcdfb86c
commit 6497290926
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/libs/monitorfw/src/taos_counter.c
View File

@ -84,6 +84,7 @@ int taos_counter_get_vgroup_ids(taos_counter_t *self, char ***keys, int32_t **vg
*keys = (char **)taos_malloc(*list_size * sizeof(char *)); *keys = (char **)taos_malloc(*list_size * sizeof(char *));
if (keys == NULL) return 1; if (keys == NULL) return 1;
int index = 0; int index = 0;
pthread_rwlock_rdlock(self->rwlock);
for (taos_linked_list_node_t *current_key = key_list->head; current_key != NULL; current_key = current_key->next) { for (taos_linked_list_node_t *current_key = key_list->head; current_key != NULL; current_key = current_key->next) {
char *key = (char *)current_key->item; char *key = (char *)current_key->item;
int32_t vgroup_id = taos_metric_formatter_get_vgroup_id(key); int32_t vgroup_id = taos_metric_formatter_get_vgroup_id(key);
@ -91,6 +92,7 @@ int taos_counter_get_vgroup_ids(taos_counter_t *self, char ***keys, int32_t **vg
(*keys)[index] = key; (*keys)[index] = key;
index++; index++;
} }
pthread_rwlock_unlock(self->rwlock);
return r; return r;
} }