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

Merge pull request #452 from fengzeroz/main

Browse Source 
fix(driver): check group_free before call group_free
This commit is contained in:
fengzeroz
2022-04-27 15:00:37 +08:00
committed by GitHub
parent 491bc737cd b7992c04c0
commit ba4eef8a6d
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/adapter/driver/driver.c
+6 -3
View File
@@ -182,7 +182,8 @@ int neu_adapter_driver_uninit(neu_adapter_driver_t *driver)
HASH_DEL(driver->grps, sg);
neu_adapter_del_timer((neu_adapter_t *) driver, sg->report);
neu_event_del_timer(driver->driver_events, sg->read);
sg->grp.group_free(&sg->grp);
if (sg->grp.group_free != NULL)
sg->grp.group_free(&sg->grp);
free(sg);
}
@@ -291,7 +292,8 @@ void neu_adapter_driver_process_msg(neu_adapter_driver_t *driver,
HASH_DEL(driver->grps, sg);
neu_adapter_del_timer((neu_adapter_t *) driver, sg->report);
neu_event_del_timer(driver->driver_events, sg->read);
sg->grp.group_free(&sg->grp);
if (sg->grp.group_free != NULL)
sg->grp.group_free(&sg->grp);
for (neu_datatag_t **tag =
(neu_datatag_t **) utarray_front(sg->grp.tags);
@@ -349,7 +351,8 @@ static int read_callback(void *usr_data)
neu_taggrp_cfg_get_name(sg->group));
assert(new_config != NULL);
sg->grp.group_free(&sg->grp);
if (sg->grp.group_free != NULL)
sg->grp.group_free(&sg->grp);
for (neu_datatag_t **tag =
(neu_datatag_t **) utarray_front(sg->grp.tags);