From 201becd3d163ddca333ad9f078a1fbea901d597e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E4=BA=91=E9=A3=8E?= Date: Thu, 18 Apr 2019 15:40:09 +0800 Subject: [PATCH] =?UTF-8?q?Revert=20"=E9=81=BF=E5=85=8D=E5=A4=B1=E8=B4=A5?= =?UTF-8?q?=E5=8D=A1=E4=BD=8F"?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit This reverts commit 77e264372816f22f96eb936149da0a901b7dc846. --- lualib/skynet/cluster.lua | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/lualib/skynet/cluster.lua b/lualib/skynet/cluster.lua index e32569f4..926d387f 100644 --- a/lualib/skynet/cluster.lua +++ b/lualib/skynet/cluster.lua @@ -11,19 +11,16 @@ local function get_sender(t, node) local co=coroutine.running() table.insert(waitco, co) skynet.wait(co) - return assert(rawget(t, node)) + return rawget(t, node) else waitco = {} inquery_name[node] = waitco - local ok,c = pcall(skynet.call, clusterd, "lua", "sender", node) - if ok then - t[node] = c - end + 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 - assert(ok,c) return c end end