From 57ba762b7809b40e8719322dcc4236e9d1a2ee9a Mon Sep 17 00:00:00 2001 From: niubinghui Date: Fri, 16 Aug 2024 16:13:23 +0800 Subject: [PATCH] =?UTF-8?q?=E3=80=90BugFix=E3=80=91=E6=B5=8B=E8=AF=95?= =?UTF-8?q?=E8=BF=87=E7=A8=8B=E4=B8=AD=E5=8F=91=E7=8E=B0=E5=88=9D=E5=A7=8B?= =?UTF-8?q?=E5=8C=96=E9=A1=BA=E5=BA=8F=E6=9C=89=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/lua_plugin_manage.c | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/src/lua_plugin_manage.c b/src/lua_plugin_manage.c index 657ad33..725deed 100644 --- a/src/lua_plugin_manage.c +++ b/src/lua_plugin_manage.c @@ -319,8 +319,12 @@ struct lua_plugin_manage_schema *lua_plugin_manage_init( if (__glibc_unlikely(!new_schema)) return NULL; memset(new_schema, 0, sizeof(struct lua_plugin_manage_schema)); + global_schema = new_schema; new_schema->st = st; + /* 可能运行过程中创建新的topic, 此处进行初始化 */ + new_schema->mq_count = 0; + utarray_new(new_schema->message_mq_array, &lua_message_mq_icd); int thread_count = stellar_get_worker_thread_num(st); new_schema->state_count = thread_count; @@ -380,12 +384,7 @@ struct lua_plugin_manage_schema *lua_plugin_manage_init( } } - /* 可能运行过程中创建新的topic, 此处进行初始化 */ - new_schema->mq_count = 0; - utarray_new(new_schema->message_mq_array, &lua_message_mq_icd); - debug_lua_plugin_manage_schema(new_schema); - global_schema = new_schema; return new_schema; }