net/server_epoll.lua
branch0.11
changeset 11266 2c559953ad41
parent 11067 30d3f6f85eb8
child 11268 2cdcf55c6dd5
child 11269 957d417eb56e
--- a/net/server_epoll.lua	Thu Dec 24 17:57:28 2020 +0100
+++ b/net/server_epoll.lua	Fri Jan 08 21:57:19 2021 +0100
@@ -97,10 +97,10 @@
 	-- Any timers at all?
 	local now = gettime();
 	local peek = timers:peek();
+	local readd;
 	while peek do
 
 		if peek > now then
-			next_delay = peek - now;
 			break;
 		end
 
@@ -109,13 +109,29 @@
 		if ok and type(ret) == "number"  then
 			local next_time = now+ret;
 			timer[1] = next_time;
-			timers:insert(timer, next_time);
+			-- Delay insertion of timers to be re-added
+			-- so they don't get called again this tick
+			if readd then
+				readd[id] = timer;
+			else
+				readd = { [id] = timer };
+			end
 		end
 
 		peek = timers:peek();
 	end
+
+	if readd then
+		for _, timer in pairs(readd) do
+			timers:insert(timer, timer[2]);
+		end
+		peek = timers:peek();
+	end
+
 	if peek == nil then
 		return next_delay;
+	else
+		next_delay = peek - now;
 	end
 
 	if next_delay < min_wait then