mirrors/prosody
1
0
Fork 0
mirror of https://github.com/bjc/prosody.git synced 2025-04-04 21:57:45 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

net.server_epoll: Improve efficiency of opportunistic writes

Browse source 
Should prevent further opportunistic write attempts after the kernel
buffers are full and stops accepting writes.

When combined with `keep_buffers = false` it should stop it from
repeatedly recreating the buffer table and concatenating it back into a
string when there's a lot to write.
This commit is contained in:
Kim Alvefur 2021-08-14 13:07:29 +02:00
parent a049793c95
commit d4b9f814fe
1 changed files with 3 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

4
net/server_epoll.lua
View file

@ -484,6 +484,7 @@ function interface:onwritable()
end end
end end
local ok, err, partial = self.conn:send(data); local ok, err, partial = self.conn:send(data);
self._writable = ok;
if ok then if ok then
self:set(nil, false); self:set(nil, false);
if cfg.keep_buffers and type(buffer) == "table" then if cfg.keep_buffers and type(buffer) == "table" then
@ -539,7 +540,7 @@ function interface:write(data)
self.writebuffer = data; self.writebuffer = data;
end end
if not self._write_lock then if not self._write_lock then
if cfg.opportunistic_writes and not self._opportunistic_write then if self._writable and cfg.opportunistic_writes and not self._opportunistic_write then
self._opportunistic_write = true; self._opportunistic_write = true;
local ret, err = self:onwritable(); local ret, err = self:onwritable();
self._opportunistic_write = nil; self._opportunistic_write = nil;
@ -745,6 +746,7 @@ function interface:onacceptable()
local client = wrapsocket(conn, self, nil, self.listeners); local client = wrapsocket(conn, self, nil, self.listeners);
client:debug("New connection %s on server %s", client, self); client:debug("New connection %s on server %s", client, self);
client:defaultoptions(); client:defaultoptions();
client._writable = cfg.opportunistic_writes;
if self.tls_direct then if self.tls_direct then
client:add(true, true); client:add(true, true);
client:inittls(self.tls_ctx, true); client:inittls(self.tls_ctx, true);