diff --git a/examples/cluster1.lua b/examples/cluster1.lua index 10b2e2f2..921453d8 100644 --- a/examples/cluster1.lua +++ b/examples/cluster1.lua @@ -19,8 +19,8 @@ skynet.start(function() print(skynet.call(sdb, "lua", "SET", "b", "foobar2")) print(skynet.call(sdb, "lua", "GET", "a")) print(skynet.call(sdb, "lua", "GET", "b")) - cluster.open "db" - cluster.open "db2" + skynet.error("Open db", cluster.open "db") + skynet.error("Open db2", cluster.open "db2") -- unique snax service snax.uniqueservice "pingserver" end) diff --git a/lualib/skynet/cluster.lua b/lualib/skynet/cluster.lua index 8118c2f6..e3437b43 100644 --- a/lualib/skynet/cluster.lua +++ b/lualib/skynet/cluster.lua @@ -77,9 +77,9 @@ end function cluster.open(port) if type(port) == "string" then - skynet.call(clusterd, "lua", "listen", port) + return skynet.call(clusterd, "lua", "listen", port) else - skynet.call(clusterd, "lua", "listen", "0.0.0.0", port) + return skynet.call(clusterd, "lua", "listen", "0.0.0.0", port) end end diff --git a/service/clusterd.lua b/service/clusterd.lua index d9f61cd4..440cb865 100644 --- a/service/clusterd.lua +++ b/service/clusterd.lua @@ -148,8 +148,8 @@ function command.listen(source, addr, port) local address = assert(node_address[addr], addr .. " is down") addr, port = string.match(address, "([^:]+):(.*)$") end - skynet.call(gate, "lua", "open", { address = addr, port = port }) - skynet.ret(skynet.pack(nil)) + local addr, port = skynet.call(gate, "lua", "open", { address = addr, port = port }) + skynet.ret(skynet.pack(addr, port)) end function command.sender(source, node)