Clear request queue when channel disconnected

2026-07-23 19:43:09 +00:00 · 2014-04-24 19:59:50 +08:00
parent 0e5f17e232
commit b65757d8bf
1 changed files with 3 additions and 0 deletions
--- a/lualib/socketchannel.lua
+++ b/lualib/socketchannel.lua
@@ -51,6 +51,9 @@ local function close_channel_socket(self)
 end

 local function wakeup_all(self, errmsg)
+	for i = 1, #self.__request do
+		self.__request[i] = nil
+	end
 	for i = 1, #self.__thread do
 		local co = self.__thread[i]
 		self.__thread[i] = nil