mirrors/prosody
1
0
Fork 0
mirror of https://github.com/bjc/prosody.git synced 2025-04-04 05:37:39 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

statsmanager, prosody: New core module and API for gathering statistics about the running server

Browse source
This commit is contained in:
Matthew Wild 2015-01-20 12:33:20 +00:00
parent 4554389fc9
commit a88d04d1c4
2 changed files with 76 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

75
core/statsmanager.lua Normal file
View file

@ -0,0 +1,75 @@
local stats = require "util.statistics".new();
local config = require "core.configmanager";
local log = require "util.logger".init("stats");
local timer = require "util.timer";
local fire_event = prosody.events.fire_event;
local stats_config = config.get("*", "statistics_interval");
local stats_interval = tonumber(stats_config);
if stats_config and not stats_interval then
log("error", "Invalid 'statistics_interval' setting, statistics will be disabled");
end
local measure, collect;
local latest_stats = {};
local changed_stats = {};
local stats_extra = {};
if stats_interval then
log("debug", "Statistics collection is enabled every %d seconds", stats_interval);
function measure(type, name)
local f = assert(stats[type], "unknown stat type: "..type);
return f(name);
end
local mark_collection_start = measure("duration", "stats.collection_time");
local mark_processing_start = measure("duration", "stats.processing_time");
function collect()
local mark_collection_done = mark_collection_start();
changed_stats, stats_extra = {}, {};
for name, getter in pairs(stats.get_stats()) do
local type, value, extra = getter();
local stat_name = name..":"..type;
local old_value = latest_stats[stat_name];
latest_stats[stat_name] = value;
if value ~= old_value then
changed_stats[stat_name] = value;
end
if extra then
print(stat_name, extra)
stats_extra[stat_name] = extra;
if type == "duration" then
local rate = extra.rate;
local rate_name = name..":rate";
latest_stats[rate_name] = rate;
changed_stats[rate_name] = rate;
end
end
end
mark_collection_done();
local mark_processing_done = mark_processing_start();
fire_event("stats-updated", { stats = latest_stats, changed_stats = changed_stats, stats_extra = stats_extra });
mark_processing_done();
return stats_interval;
end
timer.add_task(stats_interval, collect);
else
log("debug", "Statistics collection is disabled");
-- nop
function measure()
return measure;
end
function collect()
end
end
return {
measure = measure;
collect = collect;
get_stats = function ()
return latest_stats, changed_stats, stats_extra;
end;
};

1
prosody
View file

@ -292,6 +292,7 @@ function load_secondary_libraries()
require "util.import"
require "util.xmppstream"
require "core.stanza_router"
require "core.statsmanager"
require "core.hostmanager"
require "core.portmanager"
require "core.modulemanager"