File

mod_measure_memory/mod_measure_memory.lua @ 2491:5fbca7de2088

mod_smacks: Send out more ack requests where needed Under some circumstances it was possible that more than "max_unacked_stanzas" where left in the outgoing stanza queue without forcing an ack. This could happen, when more stanzas entered the queue while the last ack request was still unanswered. Now the test "#queue > max_unacked_stanzas" is done upon receiving an ack as well as when sending out stanzas, which fixes this bug.
author tmolitor <thilo@eightysoft.de>
date Sun, 12 Feb 2017 19:27:50 +0100
parent 2436:a01a3fb96302
child 2708:07d6077d2db7
line wrap: on
line source

module:set_global();

local measure = require"core.statsmanager".measure;
local have_pposix, pposix = pcall(require, "util.pposix");

local measures = {};
setmetatable(measures, {
	__index = function (t, k)
		local m = measure("sizes", "memory."..k); t[k] = m; return m;
	end
});

module:hook("stats-update", function ()
	measures.lua(collectgarbage("count")*1024);
end);

if have_pposix and pposix.meminfo then
	module:hook("stats-update", function ()
		local m = measures;
		for k, v in pairs(pposix.meminfo()) do
			m[k](v);
		end
	end);
end

if require"lfs".attributes("/proc/self/statm", "mode") == "file" then
	local pagesize = module:get_option_number("memory_pagesize", 4096); -- getconf PAGESIZE

	module:hook("stats-update", function ()
		local statm, err = io.open("/proc/self/statm");
		if not statm then
			module:log("error", tostring(err));
			return;
		end
		-- virtual memory (caches, opened librarys, everything)
		measures.total(statm:read("*n") * pagesize);
		-- resident set size (actually used memory)
		measures.rss(statm:read("*n") * pagesize);
		statm:close();
	end);
end