Mercurial > lxmppd-hg-xmllex / file revision

-- Prosody IM
-- Copyright (C) 2008-2009 Matthew Wild
-- Copyright (C) 2008-2009 Waqas Hussain
-- 
-- This project is MIT/X11 licensed. Please see the
-- COPYING file in the source package for more information.
--


local ns_addtimer = require "net.server".addtimer;
local get_time = os.time;
local t_insert = table.insert;
local t_remove = table.remove;
local ipairs, pairs = ipairs, pairs;
local type = type;

local data = {};
local new_data = {};

module "timer"

local function _add_task(delay, func)
	local current_time = get_time();
	delay = delay + current_time;
	if delay >= current_time then
		t_insert(new_data, {delay, func});
	else func(); end
end

add_task = _add_task;

ns_addtimer(function()
	local current_time = get_time();
	if #new_data > 0 then
		for _, d in pairs(new_data) do
			t_insert(data, d);
		end
		new_data = {};
	end
	
	for i, d in pairs(data) do
		local t, func = d[1], d[2];
		if t <= current_time then
			data[i] = nil;
			local r = func(current_time);
			if type(r) == "number" then _add_task(r, func); end
		end
	end
end);

return _M;