diff options
| author | Kim Alvefur <zash@zash.se> | 2021-10-21 15:59:16 +0200 |
|---|---|---|
| committer | Kim Alvefur <zash@zash.se> | 2021-10-21 15:59:16 +0200 |
| commit | 2408c299f020c5132edfc78a3566de83aa729f91 (patch) | |
| tree | 9c06b3e2080f3263d9f7ebe828653dd3951f05ea /net | |
| parent | aed2ada774adb4dda55266ec1b0620aa861d93e7 (diff) | |
| download | prosody-2408c299f020c5132edfc78a3566de83aa729f91.tar.gz prosody-2408c299f020c5132edfc78a3566de83aa729f91.zip | |
net.server_epoll: Process all queued events from epoll before timers
Should call timers less frequently when many sockets are waiting for
processing. May help under heavy load.
Requested by Ge0rG
Diffstat (limited to 'net')
| -rw-r--r-- | net/server_epoll.lua | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/net/server_epoll.lua b/net/server_epoll.lua index e4fea5c1..0a0f89c5 100644 --- a/net/server_epoll.lua +++ b/net/server_epoll.lua @@ -1033,7 +1033,7 @@ local function loop(once) repeat local t = runtimers(cfg.max_wait, cfg.min_wait); local fd, r, w = poll:wait(t); - if fd then + while fd do local conn = fds[fd]; if conn then if r then @@ -1046,7 +1046,9 @@ local function loop(once) log("debug", "Removing unknown fd %d", fd); poll:del(fd); end - elseif r ~= "timeout" and r ~= "signal" then + fd, r, w = poll:wait(0); + end + if r ~= "timeout" and r ~= "signal" then log("debug", "epoll_wait error: %s[%d]", r, w); end until once or (quitting and next(fds) == nil); |