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

Merge pull request #999 from fengzeroz/v2.3

Browse Source 
fix group timer
This commit is contained in:
fengzeroz
2022-12-26 15:22:28 +08:00
committed by GitHub
parent 7025f71f7d 3dfdc2a18b
commit fe2b827655
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/adapter/driver/driver.c
+3 -2
View File
@@ -422,7 +422,7 @@ int neu_adapter_driver_add_group(neu_adapter_driver_t *driver, const char *name,
.second = interval / 1000,
.millisecond = interval % 1000,
.usr_data = (void *) find,
.type = NEU_EVENT_TIMER_NOBLOCK,
.type = NEU_EVENT_TIMER_BLOCK,
};
find->driver = driver;
@@ -431,9 +431,9 @@ int neu_adapter_driver_add_group(neu_adapter_driver_t *driver, const char *name,
find->grp.group_name = strdup(name);
find->grp.tags = neu_group_get_tag(find->group);
param.type = driver->adapter.module->timer_type;
param.cb = report_callback;
find->report = neu_adapter_add_timer((neu_adapter_t *) driver, param);
param.type = driver->adapter.module->timer_type;
param.cb = read_callback;
find->read = neu_event_add_timer(driver->driver_events, param);
@@ -472,6 +472,7 @@ int neu_adapter_driver_update_group(neu_adapter_driver_t *driver,
neu_group_set_interval(find->group, interval);
param.type = driver->adapter.module->timer_type;
param.cb = report_callback;
find->report = neu_adapter_add_timer((neu_adapter_t *) driver, param);
param.cb = read_callback;