【BugFix】测试过程中发现初始化顺序有问题

This commit is contained in:
niubinghui
2024-08-16 16:13:23 +08:00
parent fce204c8b6
commit 57ba762b78

View File

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