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

fix socketchannel closed thread not wakeup (#2020)

Browse Source
This commit is contained in:
华仔
2024-12-30 21:26:40 +08:00
committed by GitHub
parent 7c3942cdbd
commit 474f04e864
1 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
lualib/skynet/socketchannel.lua
View File

@@ -116,6 +116,11 @@ local function dispatch_by_session(self)
end end
skynet.wakeup(co) skynet.wakeup(co)
end end
if not self.__sock then
-- closed
wakeup_all(self, "channel_closed")
break
end
else else
self.__thread[session] = nil self.__thread[session] = nil
skynet.error("socket: unknown session :", session) skynet.error("socket: unknown session :", session)
@@ -211,6 +216,11 @@ local function dispatch_by_order(self)
self.__result_data[co] = result_data self.__result_data[co] = result_data
end end
skynet.wakeup(co) skynet.wakeup(co)
if not self.__sock then
-- closed
wakeup_all(self, "channel_closed")
break
end
else else
close_channel_socket(self) close_channel_socket(self)
local errmsg local errmsg