lihao/skynet
1
0
Fork 0
mirror of https://github.com/cloudwu/skynet.git synced 2026-07-24 20:23:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

clusterd support send

Browse Source
This commit is contained in:
Cloud Wu
2016-12-02 20:39:49 +08:00
parent d0a41eb494
commit ace41d7c22
2 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
lualib/cluster.lua
View File

@@ -8,6 +8,11 @@ function cluster.call(node, address, ...)
return skynet.call(clusterd, "lua", "req", node, address, skynet.pack(...)) return skynet.call(clusterd, "lua", "req", node, address, skynet.pack(...))
end end
function cluster.send(node, address, ...)
-- skynet.pack(...) will free by cluster.core.packrequest
skynet.send(clusterd, "lua", "req", node, address, skynet.pack(...))
end
function cluster.open(port) function cluster.open(port)
if type(port) == "string" then if type(port) == "string" then
skynet.call(clusterd, "lua", "listen", port) skynet.call(clusterd, "lua", "listen", port)

3
lualib/skynet.lua
View File

@@ -161,6 +161,9 @@ function suspend(co, result, command, param, size)
sleep_session[co] = param sleep_session[co] = param
elseif command == "RETURN" then elseif command == "RETURN" then
local co_session = session_coroutine_id[co] local co_session = session_coroutine_id[co]
if co_session == 0 then
return suspend(co, coroutine_resume(co, false)) -- send don't need ret
end
local co_address = session_coroutine_address[co] local co_address = session_coroutine_address[co]
if param == nil or session_response[co] then if param == nil or session_response[co] then
error(debug.traceback(co)) error(debug.traceback(co))