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

revert wakeup_response

Browse Source
This commit is contained in:
Cloud Wu
2021-04-15 08:33:48 +00:00
parent f0d24ac718
commit 1020c403dc
1 changed files with 4 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
lualib/skynet/socketchannel.lua
View File

@@ -125,17 +125,6 @@ local function pop_response(self)
end end
self.__wait_response = coroutine.running() self.__wait_response = coroutine.running()
skynet.wait(self.__wait_response) skynet.wait(self.__wait_response)
if not self.__sock then
-- disconnected before request, terminate dispatch_by_order
return
end
end
end
local function wakeup_response(self)
if self.__wait_response then
skynet.wakeup(self.__wait_response)
self.__wait_response = nil
end end
end end
@@ -146,7 +135,6 @@ local function autoclose_cb(self, fd)
-- closed by peer -- closed by peer
skynet.error("socket closed by peer : ", self.__host, self.__port) skynet.error("socket closed by peer : ", self.__host, self.__port)
close_channel_socket(self) close_channel_socket(self)
wakeup_response(self)
end end
end end
@@ -158,7 +146,10 @@ local function push_response(self, response, co)
-- response is a function, push it to __request -- response is a function, push it to __request
table.insert(self.__request, response) table.insert(self.__request, response)
table.insert(self.__thread, co) table.insert(self.__thread, co)
wakeup_response(self) if self.__wait_response then
skynet.wakeup(self.__wait_response)
self.__wait_response = nil
end
end end
end end