From 42aa45e6f6d567be8533f45ac67810ff63b87e62 Mon Sep 17 00:00:00 2001 From: fengzero Date: Tue, 2 Aug 2022 09:55:04 +0000 Subject: [PATCH] fix(adapter): close plugin when destroy adapter --- src/adapter/adapter.c | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/adapter/adapter.c b/src/adapter/adapter.c index 056eef66..15100534 100644 --- a/src/adapter/adapter.c +++ b/src/adapter/adapter.c @@ -591,6 +591,8 @@ static int adapter_loop(enum neu_event_io_type type, int fd, void *usr_data) void neu_adapter_destroy(neu_adapter_t *adapter) { + adapter->module->intf_funs->close(adapter->plugin); + nng_dialer_close(adapter->dialer); nng_close(adapter->sock); neu_persister_destroy(adapter->persister); @@ -620,7 +622,6 @@ int neu_adapter_uninit(neu_adapter_t *adapter) } neu_event_del_timer(adapter->events, adapter->timer); - adapter->module->intf_funs->close(adapter->plugin); nlog_info("Stop the adapter(%s)", adapter->name); return 0;