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 /plugins | |
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.
Diffstat (limited to 'plugins')
-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 |