diff --git a/src/adapter/driver/driver.c b/src/adapter/driver/driver.c index ea87316e..3809295e 100644 --- a/src/adapter/driver/driver.c +++ b/src/adapter/driver/driver.c @@ -2186,6 +2186,13 @@ static void read_group_paginate(int64_t timestamp, int64_t timeout, tag_value.datatag.option = tag->option; memcpy(tag_value.datatag.meta, tag->meta, NEU_TAG_META_LENGTH); + if (tag->attribute == NEU_ATTRIBUTE_WRITE) { + tag_value.value.type = NEU_TYPE_STRING; + tag_value.value.value.str[0] = 0; + utarray_push_back(tag_values, &tag_value); + continue; + } + if (neu_driver_cache_meta_get(cache, group, tag->name, &value, tag_value.metas, NEU_TAG_META_SIZE) != 0) { diff --git a/src/base/group.c b/src/base/group.c index 344edd0b..8254c951 100644 --- a/src/base/group.c +++ b/src/base/group.c @@ -315,8 +315,8 @@ UT_array *neu_group_query_read_tag_paginate(neu_group_t *group, }; pthread_mutex_lock(&group->mtx); - array = filter_tags_by_page(group->tags, is_readable_and_match_query, &q, - current_page, page_size, total_count); + array = filter_tags_by_page(group->tags, match_query, &q, current_page, + page_size, total_count); pthread_mutex_unlock(&group->mtx); return array;