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

clusterd wait for cluster.reload when the name no exist

Browse Source
This commit is contained in:
Cloud Wu
2018-01-04 14:18:29 +08:00
parent 5d5112257c
commit b792c7144d
2 changed files with 21 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
examples/cluster2.lua
View File

@@ -18,6 +18,11 @@ skynet.start(function()
cluster.send("db2", sdb, "PING", "db2:longstring" .. largevalue)
-- test snax service
local pingserver = cluster.snax("db", "pingserver")
skynet.timeout(300,function()
cluster.reload {
db3 = "127.0.0.1:2529"
}
end)
local pingserver = cluster.snax("db3", "pingserver")
print(pingserver.req.ping "hello")
end)

16
service/clusterd.lua
View File

@@ -26,7 +26,16 @@ local function open_channel(t, key)
end
ct = {}
connecting[key] = ct
local host, port = string.match(node_address[key], "([^:]+):(.*)$")
local address = node_address[key]
if address == nil then
local co = coroutine.running()
assert(ct.namequery == nil)
ct.namequery = co
skynet.error("Wating for cluster node [".. key.."]")
skynet.wait(co)
address = assert(node_address[key])
end
local host, port = string.match(address, "([^:]+):(.*)$")
local c = sc.channel {
host = host,
port = tonumber(port),
@@ -67,6 +76,11 @@ local function loadconfig(tmp)
end
node_address[name] = address
end
local ct = connecting[name]
if ct and ct.namequery then
skynet.error(string.format("Cluster node [%s] resloved : %s", name, address))
skynet.wakeup(ct.namequery)
end
end
end