diff options
| author | niubinghui <[email protected]> | 2024-08-16 11:50:23 +0800 |
|---|---|---|
| committer | niubinghui <[email protected]> | 2024-08-16 11:50:23 +0800 |
| commit | fce204c8b66bb1084f940f96f4cc5ea505d67a6e (patch) | |
| tree | 8b17b7ce4f8537e032799d4c28a89251a15c72d3 /src/lua_plugin_cfunc.c | |
| parent | 3b2baf28064a1fcaa9f193bd9b8f13c9c6f98af2 (diff) | |
【修改】调整部分头文件路径，替换部分测试函数
Diffstat (limited to 'src/lua_plugin_cfunc.c')
| -rw-r--r-- | src/lua_plugin_cfunc.c | 16 |
1 files changed, 9 insertions, 7 deletions
diff --git a/src/lua_plugin_cfunc.c b/src/lua_plugin_cfunc.c index 9fbb646..03d0b20 100644 --- a/src/lua_plugin_cfunc.c +++ b/src/lua_plugin_cfunc.c @@ -23,6 +23,8 @@ ************************************************************************/ #include "lua_plugin_manage_internal.h" +#include "stellar/session.h" + /* * Function: lpm_ctx_new_func * Input: | struct session * | sess | 会话信息 @@ -41,7 +43,7 @@ void *lpm_ctx_new_func( struct lua_model *env = (struct lua_model *)plugin_env; /* 获取插件ID并找到该插件 */ - int plugin_id = session_get_pluginid(sess); + int plugin_id = session_get_current_plugin_id(sess); // int plugin_id = 1; struct lua_plugin *plugin = NULL; while ((plugin = utarray_next(env->plugin_array, plugin))) @@ -55,7 +57,7 @@ void *lpm_ctx_new_func( return NULL; /* 获取当前的线程id并找到该线程对应的state */ - int thread_id = session_get_threadid(sess); + int thread_id = session_get_current_thread_id(sess); if (thread_id > global_schema->state_count) return NULL; lua_State *state = global_schema->thread_state[thread_id]; @@ -101,7 +103,7 @@ void lpm_ctx_free_func( struct lua_model *env = (struct lua_model *)plugin_env; /* 获取插件ID并找到该插件 */ - int plugin_id = session_get_pluginid(sess); + int plugin_id = session_get_current_plugin_id(sess); // int plugin_id = 1; struct lua_plugin *plugin = NULL; while ((plugin = utarray_next(env->plugin_array, plugin))) @@ -113,7 +115,7 @@ void lpm_ctx_free_func( /* 未找到该插件 */ return; - int thread_id = session_get_threadid(sess); + int thread_id = session_get_current_thread_id(sess); if (thread_id > global_schema->state_count) return; lua_State *state = global_schema->thread_state[thread_id]; @@ -150,7 +152,7 @@ void lpm_message_free_func( return; struct lua_message_mq *plugin_mq = (struct lua_message_mq *)msg_free_arg; - int thread_id = session_get_threadid(sess); + int thread_id = session_get_current_thread_id(sess); if (thread_id > global_schema->state_count) return; lua_State *state = global_schema->thread_state[thread_id]; @@ -194,7 +196,7 @@ void lpm_on_session_msg_func( struct lua_model *env = (struct lua_model *)plugin_env; /* 获取插件ID并找到该插件 */ - int plugin_id = session_get_pluginid(sess); + int plugin_id = session_get_current_plugin_id(sess); // int plugin_id = 1; struct lua_plugin *plugin = NULL; while ((plugin = utarray_next(env->plugin_array, plugin))) @@ -218,7 +220,7 @@ void lpm_on_session_msg_func( /* 判断该消息是由C端插件产生的还是由Lua插件产生的 */ struct lua_message_mq *message_mq = search_message_mq_by_id(topic_id); - int thread_id = session_get_threadid(sess); + int thread_id = session_get_current_thread_id(sess); if (thread_id > global_schema->state_count) return; lua_State *state = global_schema->thread_state[thread_id]; |