bugfix: fork a new thread when message dispatch error

2026-07-22 02:53:09 +00:00 · 2014-04-01 20:58:49 +08:00
parent b02d07f124
commit 043311e654
1 changed files with 1 additions and 0 deletions
--- a/lualib/mqueue.lua
+++ b/lualib/mqueue.lua
@@ -41,6 +41,7 @@ local function message_dispatch(f)
 						error(string.format("[:%x] send a message to [:%x] return something", msg.addr, skynet.self()))
 					end
 				else
+					skynet.fork(message_dispatch,f)
 					error(string.format("[:%x] send a message to [:%x] throw an error : %s", msg.addr, skynet.self(),msg))
 				end
 			else