diff options
author | Kim Alvefur <zash@zash.se> | 2016-08-10 20:47:40 +0200 |
---|---|---|
committer | Kim Alvefur <zash@zash.se> | 2016-08-10 20:47:40 +0200 |
commit | ae36bc18d511f6eb006fcbf7f637fc0a1e285972 (patch) | |
tree | ced46a97c6916344813b5dcef4b8bb33536fb7a8 | |
parent | 67e89b14aa010121b550aeb657030109da133489 (diff) | |
download | prosody-ae36bc18d511f6eb006fcbf7f637fc0a1e285972.tar.gz prosody-ae36bc18d511f6eb006fcbf7f637fc0a1e285972.zip |
net.server_epoll: Remove last traces of code for bypassing buffering on writable sockets
-rw-r--r-- | net/server_epoll.lua | 10 |
1 files changed, 2 insertions, 8 deletions
diff --git a/net/server_epoll.lua b/net/server_epoll.lua index bfe5f18f..9808b8ea 100644 --- a/net/server_epoll.lua +++ b/net/server_epoll.lua @@ -253,14 +253,12 @@ function interface:onwriteable() else self:setwritetimeout(); end - self._writable = true; elseif partial then buffer[1] = data:sub(partial+1) for i = #buffer, 2, -1 do buffer[i] = nil; end self:setwritetimeout(); - self._writable = false; end if err == "wantwrite" or err == "timeout" then self:setflags(nil, true); @@ -290,12 +288,8 @@ function interface:write(data) else self.writebuffer = { data }; end - if self._writable and false then - self:onwriteable(); - else - self:setwritetimeout(); - self:setflags(nil, true); - end + self:setwritetimeout(); + self:setflags(nil, true); return #data; end interface.send = interface.write; |