diff options
author | Kim Alvefur <zash@zash.se> | 2016-08-12 00:25:19 +0200 |
---|---|---|
committer | Kim Alvefur <zash@zash.se> | 2016-08-12 00:25:19 +0200 |
commit | 360563ba3a9ad8141c3fe772f869811400ffabc9 (patch) | |
tree | 5e8021daf0b3b52f8f237f5dee27112c2adc22a0 | |
parent | f77c81d9284a1170fae0d1637f73868b5f799e4c (diff) | |
download | prosody-360563ba3a9ad8141c3fe772f869811400ffabc9.tar.gz prosody-360563ba3a9ad8141c3fe772f869811400ffabc9.zip |
net.server_epoll: Fix calculation of next timer event
-rw-r--r-- | net/server_epoll.lua | 16 |
1 files changed, 7 insertions, 9 deletions
diff --git a/net/server_epoll.lua b/net/server_epoll.lua index 100d3340..c6778e2b 100644 --- a/net/server_epoll.lua +++ b/net/server_epoll.lua @@ -79,24 +79,22 @@ local function runtimers() if diff < next_delay then next_delay = diff; end - return next_delay; + break; end local new_timeout = f(now); if new_timeout then - local t_diff = t + new_timeout - now; - if t_diff < 1e-6 then - t_diff = 1e-6; - end - if t_diff < next_delay then - next_delay = t_diff; - end timer[1] = t + new_timeout; resort_timers = true; else t_remove(timers, i); end end - if next_delay < 1e-6 then + if resort_timers or next_delay < 1e-6 then + -- Timers may be added from within a timer callback. + -- Those would not be considered for next_dela, + -- and we might sleep for too long, so instead + -- we return a shorter timeout so we can + -- properly sort all new timers. next_delay = 1e-6; end return next_delay; |