diff options
| author | Kim Alvefur <zash@zash.se> | 2020-05-09 13:50:58 +0200 |
|---|---|---|
| committer | Kim Alvefur <zash@zash.se> | 2020-05-09 13:50:58 +0200 |
| commit | cabd89913a6d1101defb663f964116c6ec9ba37b (patch) | |
| tree | 017c0eb480dc1f24f5a9af8bc2114f88b92fa0d2 | |
| parent | 749ed917c1c1a5d34ffb92b0da4cf1cc3f22cf50 (diff) | |
| download | prosody-cabd89913a6d1101defb663f964116c6ec9ba37b.tar.gz prosody-cabd89913a6d1101defb663f964116c6ec9ba37b.zip | |
mod_csi_simple: Fix flushing when client sent something
Forgot to unset the flag afterwards, so it would only work once.
The flag is not even needed, it works as intended without it.
| -rw-r--r-- | plugins/mod_csi_simple.lua | 5 |
1 files changed, 0 insertions, 5 deletions
diff --git a/plugins/mod_csi_simple.lua b/plugins/mod_csi_simple.lua index 8c6f75c8..a44237d1 100644 --- a/plugins/mod_csi_simple.lua +++ b/plugins/mod_csi_simple.lua @@ -116,10 +116,6 @@ local function manage_buffer(stanza, session) end local function flush_buffer(data, session) - if session.csi_flushing then - return data; - end - session.csi_flushing = true; session.log("debug", "Client sent something, flushing buffer once (queue size is %d)", session.csi_counter); session.conn:resume_writes(); return data; @@ -136,7 +132,6 @@ function enable_optimizations(session) end function disable_optimizations(session) - session.csi_flushing = nil; filters.remove_filter(session, "stanzas/out", manage_buffer); filters.remove_filter(session, "bytes/in", flush_buffer); if session.conn and session.conn.resume_writes then |