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; }