mirror of
https://github.com/cloudwu/skynet.git
synced 2026-07-25 04:33:05 +00:00
Don't use assert in message queue dispatching
This commit is contained in:
@@ -20,11 +20,16 @@ skynet.register_protocol {
|
|||||||
end
|
end
|
||||||
}
|
}
|
||||||
|
|
||||||
|
-- todo: write to log system
|
||||||
|
local function write_log(...)
|
||||||
|
return print(...)
|
||||||
|
end
|
||||||
|
|
||||||
local function report_error(succ, ...)
|
local function report_error(succ, ...)
|
||||||
if succ then
|
if succ then
|
||||||
return ...
|
return ...
|
||||||
else
|
else
|
||||||
print("Message queue dispatch error: ", ...)
|
write_log("Message queue dispatch error: ", ...)
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
@@ -41,7 +46,9 @@ local function message_dispatch(f)
|
|||||||
local msg = table.remove(message_queue,1)
|
local msg = table.remove(message_queue,1)
|
||||||
local session = msg.session
|
local session = msg.session
|
||||||
if session == 0 then
|
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
|
else
|
||||||
local data, size = skynet.pack(do_func(f,msg))
|
local data, size = skynet.pack(do_func(f,msg))
|
||||||
-- 1 means response
|
-- 1 means response
|
||||||
|
|||||||
Reference in New Issue
Block a user