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

fix(group): update interval

Browse Source
This commit is contained in:
fengzero
2022-08-19 07:34:22 +00:00
parent fa46c6b493
commit 4f70647fd7
3 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/adapter/driver/driver.c
+2
View File
@@ -347,6 +347,8 @@ int neu_adapter_driver_update_group(neu_adapter_driver_t *driver,
.usr_data = (void *) find,
};
neu_group_set_interval(find->group, interval);
param.cb = report_callback;
find->report = neu_adapter_add_timer((neu_adapter_t *) driver, param);
param.cb = read_callback;
src/base/group.c
+5
View File
@@ -92,6 +92,11 @@ uint32_t neu_group_get_interval(neu_group_t *group)
return interval;
}
void neu_group_set_interval(neu_group_t *group, uint32_t interval)
{
group->interval = interval;
}
int neu_group_update(neu_group_t *group, uint32_t interval)
{
if (group->interval != interval) {
src/base/group.h
+1
View File
@@ -31,6 +31,7 @@ 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);