From 4291e0e4a16a05033f7601845409d14c77c4b074 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E4=BA=91=E9=A3=8E?= Date: Wed, 30 Oct 2013 19:51:29 +0800 Subject: [PATCH] Don't use assert in message queue dispatching --- lualib/mqueue.lua | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/lualib/mqueue.lua b/lualib/mqueue.lua index 681001b0..a0913eff 100644 --- a/lualib/mqueue.lua +++ b/lualib/mqueue.lua @@ -20,11 +20,16 @@ skynet.register_protocol { end } +-- todo: write to log system +local function write_log(...) + return print(...) +end + local function report_error(succ, ...) if succ then return ... else - print("Message queue dispatch error: ", ...) + write_log("Message queue dispatch error: ", ...) end end @@ -41,7 +46,9 @@ local function message_dispatch(f) local msg = table.remove(message_queue,1) local session = msg.session if session == 0 then - assert(do_func(f, msg) == nil, "message in queue returns value") + if do_func(f, msg) ~= nil then + write_log("Message queue returns value, maybe need call this service") + end else local data, size = skynet.pack(do_func(f,msg)) -- 1 means response