GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-19 05:51:27 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor(adapter): remove stop field in neu_adapter

Browse Source
This commit is contained in:
fengzero
2022-04-15 08:36:26 +00:00
parent 3548917bc6
commit fd03785205
2 changed files with 0 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/adapter/adapter.c
-7
View File
@@ -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);
src/adapter/adapter_internal.h
-3
View File
@@ -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;