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 | 6f60cb0639b8cdcaaf0f160f7c7f65ee567cf95d (patch) | |
tree | 017c0eb480dc1f24f5a9af8bc2114f88b92fa0d2 | |
parent | d182923d72aac40aaa95bee9e3dac7b3c63d6fc8 (diff) | |
download | prosody-6f60cb0639b8cdcaaf0f160f7c7f65ee567cf95d.tar.gz prosody-6f60cb0639b8cdcaaf0f160f7c7f65ee567cf95d.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 |