aboutsummaryrefslogtreecommitdiffstats
path: root/plugins
diff options
context:
space:
mode:
authorKim Alvefur <zash@zash.se>2020-05-09 17:47:03 +0200
committerKim Alvefur <zash@zash.se>2020-05-09 17:47:03 +0200
commitd4c1384269b98e3a0e21b4cf3615a6d116100fd6 (patch)
tree1dc74c8fd07bc8781c11c6f665f216f7159d8034 /plugins
parentedd59660621f044d6402966a4a77ca9867d1f619 (diff)
downloadprosody-d4c1384269b98e3a0e21b4cf3615a6d116100fd6.tar.gz
prosody-d4c1384269b98e3a0e21b4cf3615a6d116100fd6.zip
mod_csi_simple: Collect stats on flush reasons
Diffstat (limited to 'plugins')
-rw-r--r--plugins/mod_csi_simple.lua11
1 files changed, 11 insertions, 0 deletions
diff --git a/plugins/mod_csi_simple.lua b/plugins/mod_csi_simple.lua
index c0871c8d..0c428c4a 100644
--- a/plugins/mod_csi_simple.lua
+++ b/plugins/mod_csi_simple.lua
@@ -103,6 +103,15 @@ end
local measure_buffer_hold = module:measure("buffer_hold", "times");
+local flush_reasons = setmetatable({}, {
+ __index = function (t, reason)
+ local m = module:measure("flush_reason."..reason:gsub("%W", "_"), "rate");
+ t[reason] = m;
+ return m;
+ end;
+ });
+
+
local function manage_buffer(stanza, session)
local ctr = session.csi_counter or 0;
local flush, why = should_flush(stanza, session, ctr);
@@ -111,6 +120,7 @@ local function manage_buffer(stanza, session)
session.csi_measure_buffer_hold();
session.csi_measure_buffer_hold = nil;
end
+ flush_reasons[why or "important"]();
session.log("debug", "Flushing buffer (%s; queue size is %d)", why or "important", session.csi_counter);
session.conn:resume_writes();
else
@@ -123,6 +133,7 @@ end
local function flush_buffer(data, session)
session.log("debug", "Flushing buffer (%s; queue size is %d)", "client activity", session.csi_counter);
+ flush_reasons["client activity"]();
if session.csi_measure_buffer_hold then
session.csi_measure_buffer_hold();
session.csi_measure_buffer_hold = nil;