aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorKim Alvefur <zash@zash.se>2021-11-18 00:39:10 +0100
committerKim Alvefur <zash@zash.se>2021-11-18 00:39:10 +0100
commitd922bbb1ef53cb46ce084aa89830a0f6d1015bed (patch)
tree82a17bc619d02b71ad8ab443a5759e31bae4944d
parentce8107379d68766555cb4b3b7987fc3b3fa9cf73 (diff)
downloadprosody-d922bbb1ef53cb46ce084aa89830a0f6d1015bed.tar.gz
prosody-d922bbb1ef53cb46ce084aa89830a0f6d1015bed.zip
mod_csi_simple: Fire event when flushing due to client activity
So that the same things happen as when triggered by an outgoing stanza
-rw-r--r--plugins/mod_csi_simple.lua2
1 files changed, 2 insertions, 0 deletions
diff --git a/plugins/mod_csi_simple.lua b/plugins/mod_csi_simple.lua
index efac1e9d..641182ea 100644
--- a/plugins/mod_csi_simple.lua
+++ b/plugins/mod_csi_simple.lua
@@ -141,6 +141,8 @@ end
local function flush_buffer(data, session)
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 });
flush_reasons:with_labels("client activity"):add(1);
if session.csi_measure_buffer_hold then
session.csi_measure_buffer_hold();