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

thread lock result

This commit is contained in:
xiao77 2024-09-05 13:38:51 +08:00
parent e4f8485697
commit ab2477510b
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -76,18 +76,18 @@ int taos_counter_get_vgroup_ids(taos_counter_t *self, char ***keys, int32_t **vg
return 1; return 1;
} }
if (self->samples == NULL) return 1; if (self->samples == NULL) return 1;
pthread_rwlock_rdlock(self->rwlock); (void)pthread_rwlock_rdlock(self->rwlock);
taos_linked_list_t *key_list = self->samples->keys; taos_linked_list_t *key_list = self->samples->keys;
*list_size = key_list->size; *list_size = key_list->size;
int r = 0; int r = 0;
*vgroup_ids = (int32_t *)taos_malloc(*list_size * sizeof(int32_t)); *vgroup_ids = (int32_t *)taos_malloc(*list_size * sizeof(int32_t));
if (vgroup_ids == NULL) { if (vgroup_ids == NULL) {
pthread_rwlock_unlock(self->rwlock); (void)pthread_rwlock_unlock(self->rwlock);
return 1; return 1;
} }
*keys = (char **)taos_malloc(*list_size * sizeof(char *)); *keys = (char **)taos_malloc(*list_size * sizeof(char *));
if (keys == NULL) { if (keys == NULL) {
pthread_rwlock_unlock(self->rwlock); (void)pthread_rwlock_unlock(self->rwlock);
return 1; return 1;
} }
int index = 0; int index = 0;
@ -98,7 +98,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); (void)pthread_rwlock_unlock(self->rwlock);
return r; return r;
} }