diff --git a/src/adapter/adapter.c b/src/adapter/adapter.c index 5152cea3..91785777 100644 --- a/src/adapter/adapter.c +++ b/src/adapter/adapter.c @@ -1410,7 +1410,6 @@ neu_adapter_t *neu_adapter_create(neu_adapter_info_t *info, adapter->manager = manager; adapter->trans_kind = NEURON_TRANS_DATAVAL; adapter->node_id = neu_manager_adapter_id_to_node_id(manager, info->id); - adapter->stop = false; adapter->cb_funs = callback_funs; rv = nng_mtx_alloc(&adapter->mtx); @@ -1476,7 +1475,6 @@ int adapter_loop(enum neu_event_io_type type, int fd, void *usr_data) if (rv == NNG_ECLOSED) { nng_mtx_lock(adapter->mtx); adapter->state = ADAPTER_STATE_IDLE; - adapter->stop = true; nng_mtx_unlock(adapter->mtx); log_warn("nng socket closed."); @@ -1501,7 +1499,6 @@ int adapter_loop(enum neu_event_io_type type, int fd, void *usr_data) adapter->plugin_module->intf_funs->uninit(adapter->plugin); nng_mtx_lock(adapter->mtx); adapter->state = ADAPTER_STATE_IDLE; - adapter->stop = true; nng_mtx_unlock(adapter->mtx); log_info("adapter(%s) exit loop by exit_code=%d", adapter->name, @@ -1911,10 +1908,6 @@ int neu_adapter_uninit(neu_adapter_t *adapter) neu_adapter_driver_uninit((neu_adapter_driver_t *) adapter); } - nng_mtx_lock(adapter->mtx); - adapter->stop = true; - nng_mtx_unlock(adapter->mtx); - neu_event_del_io(adapter->events, adapter->nng_io); nng_dialer_close(adapter->dialer); diff --git a/src/adapter/adapter_internal.h b/src/adapter/adapter_internal.h index 1b032a93..1fd507ea 100644 --- a/src/adapter/adapter_internal.h +++ b/src/adapter/adapter_internal.h @@ -48,14 +48,11 @@ struct neu_adapter { nng_mtx * mtx; nng_mtx * sub_grp_mtx; adapter_state_e state; - bool stop; char * name; neu_manager_t * manager; - nng_pipe pipe; nng_socket sock; nng_dialer dialer; int recv_fd; - nng_thread * thrd; uint32_t new_req_id; plugin_id_t plugin_id; plugin_kind_e plugin_kind;