bugfix: double check in SUB

kuafu · Apr 30, 2014 · 9033c5c · 9033c5c
1 parent 5d0da82
commit 9033c5c
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/service/multicastd.lua b/service/multicastd.lua
@@ -137,8 +137,11 @@ function command.SUB(source, c)
 			if skynet.call(node_address[node], "lua", "SUBR", c) then
 				return
 			end
-			channel[c] = {}
-			channel_n[c] = 0
+			if channel[c] == nil then
+				-- double check, because skynet.call whould yield, other SUB may occur.
+				channel[c] = {}
+				channel_n[c] = 0
+			end
 		end
 	end
 	local group = channel[c]