From b443d6f0b279d7689278ca2eb7ef51633d82f28b Mon Sep 17 00:00:00 2001 From: eeff Date: Wed, 26 Jan 2022 16:45:55 +0800 Subject: [PATCH] Add function neu_persist_subscription_infos_free --- src/persist/persist.h | 14 ++++++++++++++ 1 file changed, 14 insertions(+) diff --git a/src/persist/persist.h b/src/persist/persist.h index 7849898f..7bb7433f 100644 --- a/src/persist/persist.h +++ b/src/persist/persist.h @@ -88,6 +88,20 @@ static inline void neu_persist_datatag_infos_free(vector_t *datatag_infos) vector_free(datatag_infos); } +static inline void +neu_persist_subscription_infos_free(vector_t *subscription_infos) +{ + VECTOR_FOR_EACH(subscription_infos, iter) + { + neu_persist_subscription_info_t *p = + (neu_persist_subscription_info_t *) iterator_get(&iter); + free(p->src_adapter_name); + free(p->sub_adapter_name); + free(p->group_config_name); + } + vector_free(subscription_infos); +} + /** * Persister, provide methods to persist data */ typedef struct neu_persister neu_persister_t;