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

fix: base group interface use const reference for read access

Browse Source
This commit is contained in:
eeff
2023-03-16 16:18:08 +08:00
parent 3af830c30f
commit cc07e6705b
2 changed files with 20 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/base/group.c
+7 -11
View File
@@ -73,16 +73,12 @@ void neu_group_destroy(neu_group_t *group)
free(group);
}
const char *neu_group_get_name(neu_group_t *group)
const char *neu_group_get_name(const neu_group_t *group)
{
static __thread char name[NEU_GROUP_NAME_LEN] = { 0 };
strncpy(name, group->name, sizeof(name));
return name;
return group->name;
}
uint32_t neu_group_get_interval(neu_group_t *group)
uint32_t neu_group_get_interval(const neu_group_t *group)
{
uint32_t interval = 0;
@@ -106,7 +102,7 @@ int neu_group_update(neu_group_t *group, uint32_t interval)
return 0;
}
int neu_group_add_tag(neu_group_t *group, neu_datatag_t *tag)
int neu_group_add_tag(neu_group_t *group, const neu_datatag_t *tag)
{
tag_elem_t *el = NULL;
@@ -125,7 +121,7 @@ int neu_group_add_tag(neu_group_t *group, neu_datatag_t *tag)
return 0;
}
int neu_group_update_tag(neu_group_t *group, neu_datatag_t *tag)
int neu_group_update_tag(neu_group_t *group, const neu_datatag_t *tag)
{
tag_elem_t *el = NULL;
int ret = NEU_ERR_TAG_NOT_EXIST;
@@ -160,7 +156,7 @@ int neu_group_del_tag(neu_group_t *group, const char *tag_name)
return ret;
}
UT_array *neu_group_get_tag(neu_group_t *group)
UT_array *neu_group_get_tag(const neu_group_t *group)
{
UT_array *array = NULL;
@@ -194,7 +190,7 @@ UT_array *neu_group_get_read_tag(neu_group_t *group)
return array;
}
uint16_t neu_group_tag_size(neu_group_t *group)
uint16_t neu_group_tag_size(const neu_group_t *group)
{
uint16_t size = 0;
src/base/group.h
+13 -13
View File
@@ -28,19 +28,19 @@
typedef struct neu_group neu_group_t;
neu_group_t * neu_group_new(const char *name, uint32_t interval);
const char * neu_group_get_name(neu_group_t *group);
uint32_t neu_group_get_interval(neu_group_t *group);
void neu_group_set_interval(neu_group_t *group, uint32_t interval);
void neu_group_destroy(neu_group_t *group);
int neu_group_update(neu_group_t *group, uint32_t interval);
int neu_group_add_tag(neu_group_t *group, neu_datatag_t *tag);
int neu_group_update_tag(neu_group_t *group, neu_datatag_t *tag);
int neu_group_del_tag(neu_group_t *group, const char *tag_name);
UT_array * neu_group_get_tag(neu_group_t *group);
UT_array * neu_group_query_tag(neu_group_t *group, const char *name);
UT_array * neu_group_get_read_tag(neu_group_t *group);
uint16_t neu_group_tag_size(neu_group_t *group);
neu_group_t *neu_group_new(const char *name, uint32_t interval);
const char * neu_group_get_name(const neu_group_t *group);
uint32_t neu_group_get_interval(const neu_group_t *group);
void neu_group_set_interval(neu_group_t *group, uint32_t interval);
void neu_group_destroy(neu_group_t *group);
int neu_group_update(neu_group_t *group, uint32_t interval);
int neu_group_add_tag(neu_group_t *group, const neu_datatag_t *tag);
int neu_group_update_tag(neu_group_t *group, const neu_datatag_t *tag);
int neu_group_del_tag(neu_group_t *group, const char *tag_name);
UT_array * neu_group_get_tag(const neu_group_t *group);
UT_array * neu_group_query_tag(neu_group_t *group, const char *name);
UT_array * neu_group_get_read_tag(neu_group_t *group);
uint16_t neu_group_tag_size(const neu_group_t *group);
neu_datatag_t *neu_group_find_tag(neu_group_t *group, const char *tag);
void neu_group_split_static_tags(neu_group_t *group, UT_array **static_tags,
UT_array **other_tags);