lihao/skynet
1
0
Fork 0
mirror of https://github.com/cloudwu/skynet.git synced 2026-07-24 20:23:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

reset pause after wait

Browse Source
This commit is contained in:
Cloud Wu
2020-10-15 20:25:29 +08:00
parent 2eea8be7ac
commit 6dfdebc1a2
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
lualib/skynet/socket.lua
View File

@@ -46,9 +46,11 @@ local function suspend(s)
skynet.yield() -- there are subsequent socket messages in mqueue, maybe. skynet.yield() -- there are subsequent socket messages in mqueue, maybe.
skynet.error(string.format("Resume socket (%d)", s.id)) skynet.error(string.format("Resume socket (%d)", s.id))
driver.start(s.id) driver.start(s.id)
skynet.wait(s.co)
s.pause = nil s.pause = nil
else
skynet.wait(s.co)
end end
skynet.wait(s.co)
-- wakeup closing corouting every time suspend, -- wakeup closing corouting every time suspend,
-- because socket.close() will wait last socket buffer operation before clear the buffer. -- because socket.close() will wait last socket buffer operation before clear the buffer.
if s.closing then if s.closing then