gfwleak/niubinghui-luapluginmanage
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

【修改】多个线程在修改同一个message时可能出现的问题

Browse Source
This commit is contained in:
niubinghui
2024-09-02 16:14:37 +08:00
parent 81145f1f81
commit 8f9d966962
1 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/lua_binding_functions.c
View File

@@ -489,6 +489,9 @@ int lua_mq_update_topic(lua_State *state)
luaL_unref(state, LUA_REGISTRYINDEX, private_ref); luaL_unref(state, LUA_REGISTRYINDEX, private_ref);
return 0; return 0;
} }
#ifdef LUAPLUGIN_BASIC_UNITTEST
LOGDEBUG("update topic, id %d %d %d", topic_id, private_ref, free_ref);
#endif
mq->freemessage_ref = free_ref; mq->freemessage_ref = free_ref;
mq->mq_private_ref = private_ref; mq->mq_private_ref = private_ref;
@@ -503,12 +506,15 @@ int lua_mq_update_topic(lua_State *state)
lua_rawgeti(state, LUA_REGISTRYINDEX, private_ref); lua_rawgeti(state, LUA_REGISTRYINDEX, private_ref);
lua_pushlightuserdata(state, (void *)mq); /* stack top new_mq */ lua_pushlightuserdata(state, (void *)mq); /* stack top new_mq */
lua_setfield(state, -2, LUA_MQ_ENV_DEFAULT_KEY); /* stack top table */ lua_setfield(state, -2, LUA_MQ_ENV_DEFAULT_KEY); /* stack top table */
luaL_unref(state, LUA_REGISTRYINDEX, mq->mq_private_ref); // luaL_unref(state, LUA_REGISTRYINDEX, mq->mq_private_ref);
mq->mq_private_ref = private_ref; mq->mq_private_ref = private_ref;
/* 更新free function ref */ /* 更新free function ref */
luaL_unref(state, LUA_REGISTRYINDEX, mq->freemessage_ref); // luaL_unref(state, LUA_REGISTRYINDEX, mq->freemessage_ref);
mq->freemessage_ref = free_ref; mq->freemessage_ref = free_ref;
#ifdef LUAPLUGIN_BASIC_UNITTEST
LOGDEBUG("update topic, id %d %d %d", topic_id, private_ref, free_ref);
#endif
} }
lua_settop(state, 0); lua_settop(state, 0);