diff options
| author | Kim Alvefur <zash@zash.se> | 2021-11-20 22:50:51 +0100 |
|---|---|---|
| committer | Kim Alvefur <zash@zash.se> | 2021-11-20 22:50:51 +0100 |
| commit | 349968eb674b1a4f3f42edc97637126e790448cc (patch) | |
| tree | d142c06f287784bbcca10866dab00223c170788a | |
| parent | 3fb3e862280b90a743ac99ff044535b90ed2f4c0 (diff) | |
| download | prosody-349968eb674b1a4f3f42edc97637126e790448cc.tar.gz prosody-349968eb674b1a4f3f42edc97637126e790448cc.zip | |
mod_csi_simple: Early return on client activity while flushing buffer
Cuts down on log and measurement noise. We only want to do these things
here when initiating a flush.
| -rw-r--r-- | plugins/mod_csi_simple.lua | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/plugins/mod_csi_simple.lua b/plugins/mod_csi_simple.lua index a727f427..a2aeceef 100644 --- a/plugins/mod_csi_simple.lua +++ b/plugins/mod_csi_simple.lua @@ -143,7 +143,7 @@ end local function flush_buffer(data, session) local ctr = session.csi_counter or 0; - if ctr == 0 then return data end + if ctr == 0 or session.state == "flushing" then return data end session.log("debug", "Flushing buffer (%s; queue size is %d)", "client activity", session.csi_counter); session.state = "flushing"; module:fire_event("csi-flushing", { session = session }); |