From 64a0ed4bfaf5ef9ca5728f2cfea3271bbe07f901 Mon Sep 17 00:00:00 2001 From: Cloud Wu Date: Thu, 27 Jun 2024 08:31:30 +0800 Subject: [PATCH] Try to fix #1948 --- service/clusteragent.lua | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/service/clusteragent.lua b/service/clusteragent.lua index 541b3f5d..bae068a0 100644 --- a/service/clusteragent.lua +++ b/service/clusteragent.lua @@ -9,11 +9,10 @@ gate = tonumber(gate) fd = tonumber(fd) local large_request = {} -local inquery_name = {} local register_name_mt = { __index = function(self, name) - local waitco = inquery_name[name] + local waitco = self.__inquery_name[name] if waitco then local co=coroutine.running() table.insert(waitco, co) @@ -21,12 +20,12 @@ local register_name_mt = { __index = return rawget(self, name) else waitco = {} - inquery_name[name] = waitco + self.__inquery_name[name] = waitco local addr = skynet.call(clusterd, "lua", "queryname", name:sub(2)) -- name must be '@xxxx' if addr then self[name] = addr end - inquery_name[name] = nil + self.__inquery_name[name] = nil for _, co in ipairs(waitco) do skynet.wakeup(co) end @@ -36,7 +35,7 @@ local register_name_mt = { __index = } local function new_register_name() - return setmetatable({}, register_name_mt) + return setmetatable({ __inquery_name = {} }, register_name_mt) end local register_name = new_register_name()