From 1020c403dce2c18cc2ab9dae143a2b708c220e25 Mon Sep 17 00:00:00 2001
From: Cloud Wu <cloudwu@gmail.com>
Date: Thu, 15 Apr 2021 08:33:48 +0000
Subject: [PATCH] revert wakeup_response

---
 lualib/skynet/socketchannel.lua | 17 ++++-------------
 1 file changed, 4 insertions(+), 13 deletions(-)

diff --git a/lualib/skynet/socketchannel.lua b/lualib/skynet/socketchannel.lua
index 6849dc6f..521d9832 100644
--- a/lualib/skynet/socketchannel.lua
+++ b/lualib/skynet/socketchannel.lua
@@ -125,17 +125,6 @@ local function pop_response(self)
 		end
 		self.__wait_response = coroutine.running()
 		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
 
@@ -146,7 +135,6 @@ local function autoclose_cb(self, fd)
 		-- closed by peer
 		skynet.error("socket closed by peer : ", self.__host, self.__port)
 		close_channel_socket(self)
-		wakeup_response(self)
 	end
 end
 
@@ -158,7 +146,10 @@ local function push_response(self, response, co)
 		-- response is a function, push it to __request
 		table.insert(self.__request, response)
 		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