Revert "bugfix:cluster初始化节点的时候有可能导致消息乱序"

This reverts commit 9ba0860c70.
This commit is contained in:
云风
2019-04-18 15:40:09 +08:00
parent 201becd3d1
commit e0729a483d

View File

@@ -3,26 +3,11 @@ local skynet = require "skynet"
local clusterd
local cluster = {}
local sender = {}
local inquery_name = {}
local function get_sender(t, node)
local waitco = inquery_name[node]
if waitco then
local co=coroutine.running()
table.insert(waitco, co)
skynet.wait(co)
return rawget(t, node)
else
waitco = {}
inquery_name[node] = waitco
local c = skynet.call(clusterd, "lua", "sender", node)
inquery_name[node] = nil
t[node] = c
for _, co in ipairs(waitco) do
skynet.wakeup(co)
end
return c
end
local c = skynet.call(clusterd, "lua", "sender", node)
t[node] = c
return c
end
setmetatable(sender, { __index = get_sender } )