From 3dfdc2a18bef760518407ae5a5f203bd82a5ef4e Mon Sep 17 00:00:00 2001 From: fengzero Date: Mon, 26 Dec 2022 07:19:50 +0000 Subject: [PATCH] fix group timer --- src/adapter/driver/driver.c | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/adapter/driver/driver.c b/src/adapter/driver/driver.c index 61dd7058..6c37ff45 100644 --- a/src/adapter/driver/driver.c +++ b/src/adapter/driver/driver.c @@ -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;