lihao/skynet
1
0
Fork 0
mirror of https://github.com/cloudwu/skynet.git synced 2026-07-22 02:53:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

more stable

Browse Source
This commit is contained in:
Cloud Wu
2018-08-17 21:27:14 +08:00
parent 4613fde654
commit 7b3c1631d1
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
lualib/skynet/socketchannel.lua
View File

@@ -113,7 +113,6 @@ local function dispatch_by_session(self)
wakeup_all(self, errormsg)
end
end
self.__dispatch_thread = nil
end
local function pop_response(self)
@@ -190,7 +189,6 @@ local function dispatch_by_order(self)
wakeup_all(self, errmsg)
end
end
self.__dispatch_thread = nil
end
local function dispatch_function(self)
@@ -254,7 +252,11 @@ local function connect_once(self)
end
self.__sock = setmetatable( {fd} , channel_socket_meta )
self.__dispatch_thread = skynet.fork(dispatch_function(self), self)
self.__dispatch_thread = skynet.fork(function()
pcall(dispatch_function(self), self)
-- clear dispatch_thread
self.__dispatch_thread = nil
end)
if self.__auth then
self.__authcoroutine = coroutine.running()