lihao/skynet
1
0
Fork 0
mirror of https://github.com/cloudwu/skynet.git synced 2026-07-25 12:43:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix #979

Browse Source
This commit is contained in:
Cloud Wu
2019-04-02 17:43:24 +08:00
parent 3c6c0f7aa4
commit 2011596de0
1 changed files with 11 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
service/clusterd.lua
View File

@@ -143,10 +143,18 @@ function command.proxy(source, node, name)
end end
end end
local fullname = node .. "." .. name local fullname = node .. "." .. name
if proxy[fullname] == nil then local p = proxy[fullname]
proxy[fullname] = skynet.newservice("clusterproxy", node, name) if p == nil then
p = skynet.newservice("clusterproxy", node, name)
-- double check
if proxy[fullname] then
skynet.kill(p)
p = proxy[fullname]
else
proxy[fullname] = p
end
end end
skynet.ret(skynet.pack(proxy[fullname])) skynet.ret(skynet.pack(p))
end end
local cluster_agent = {} -- fd:service local cluster_agent = {} -- fd:service