diff options
| author | yangwei <[email protected]> | 2024-11-25 19:23:01 +0800 |
|---|---|---|
| committer | yangwei <[email protected]> | 2024-11-25 19:23:01 +0800 |
| commit | 73a8402a092564b76659a22acfd5e9bbb8146172 (patch) | |
| tree | 014d42332014532bef4734d20d62c63a2616f73f /infra/module_manager/module_manager_interna.h | |
| parent | ef5a65155b11fec8c6234f0a18678e11d7f79cf1 (diff) | |
🦄 refactor(module manager): rename polling API
Diffstat (limited to 'infra/module_manager/module_manager_interna.h')
| -rw-r--r-- | infra/module_manager/module_manager_interna.h | 11 |
1 files changed, 8 insertions, 3 deletions
diff --git a/infra/module_manager/module_manager_interna.h b/infra/module_manager/module_manager_interna.h index 08b285a..1b27bd7 100644 --- a/infra/module_manager/module_manager_interna.h +++ b/infra/module_manager/module_manager_interna.h @@ -27,11 +27,18 @@ struct module_descriptor }__attribute__((aligned(sizeof(void*)))); +struct polling_node +{ + on_polling_callback *on_polling; + void *polling_arg; + struct polling_node *next; +}; + struct module_manager { struct module_descriptor *descriptors; int n_descriptor; - int topic_polling_id; + struct polling_node *node_list; struct { char *toml_path; @@ -42,9 +49,7 @@ struct module_manager }__attribute__((aligned(sizeof(void*)))); -struct module_manager *module_manager_new_with_toml(const char *toml_path, int max_thread_num, struct mq_schema *mq_schema, struct logger *logger); -void module_manager_polling_dispatch(struct module_manager *mod_mgr); #ifdef __cplusplus } |
