prosody
856dada099fa
net/server_epoll.lua
Software / code / prosody
Comparison
net/server_epoll.lua @ 11743:856dada099fa
net.server_epoll: Split, attempt to clarify dirty noise message
Only relevant because a "dirty" connection (with incoming data in
LuaSocket's buffer) does not count as "readable" according to epoll, so
special care needs to be taken to keep on processing it.
| author | Kim Alvefur <zash@zash.se> |
|---|---|
| date | Mon, 16 Aug 2021 20:15:38 +0200 |
| parent | 11741:dcf38ac6a38c |
| child | 11752:6427e2642976 |
comparison
equal
deleted
inserted
replaced
| 11742:9c450185bac1 | 11743:856dada099fa |
|---|---|
| 799 if t == false then return; end | 799 if t == false then return; end |
| 800 self:set(false); | 800 self:set(false); |
| 801 self._pausefor = addtimer(t, function () | 801 self._pausefor = addtimer(t, function () |
| 802 self._pausefor = nil; | 802 self._pausefor = nil; |
| 803 self:set(true); | 803 self:set(true); |
| 804 self:noise("Resuming after pause, connection is %s", not self.conn and "missing" or self.conn:dirty() and "dirty" or "clean"); | 804 self:noise("Resuming after pause"); |
| 805 if self.conn and self.conn:dirty() then | 805 if self.conn and self.conn:dirty() then |
| 806 self:noise("Have buffered incoming data to process"); | |
| 806 self:onreadable(); | 807 self:onreadable(); |
| 807 end | 808 end |
| 808 end); | 809 end); |
| 809 end | 810 end |
| 810 | 811 |
