summaryrefslogtreecommitdiff
path: root/infra/module_manager/module_manager_interna.h
diff options
context:
space:
mode:
authoryangwei <[email protected]>2024-11-25 19:23:01 +0800
committeryangwei <[email protected]>2024-11-25 19:23:01 +0800
commit73a8402a092564b76659a22acfd5e9bbb8146172 (patch)
tree014d42332014532bef4734d20d62c63a2616f73f /infra/module_manager/module_manager_interna.h
parentef5a65155b11fec8c6234f0a18678e11d7f79cf1 (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.h11
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
}