Added util/timer.lua - a timer API
authorWaqas Hussain <waqas20@gmail.com>
Fri, 20 Feb 2009 20:13:53 +0000 (01:13 +0500)
committerWaqas Hussain <waqas20@gmail.com>
Fri, 20 Feb 2009 20:13:53 +0000 (01:13 +0500)
util/timer.lua [new file with mode: 0644]

diff --git a/util/timer.lua b/util/timer.lua
new file mode 100644 (file)
index 0000000..889a8c4
--- /dev/null
@@ -0,0 +1,47 @@
+-- Prosody IM v0.3
+-- 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 ipairs = ipairs;
+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();
+       for _, d in ipairs(new_data) do
+               t_insert(data, d);
+       end
+       new_data = {};
+       for i = #data,1 do
+               local t, func = data[i][1], data[i][2];
+               if t <= current_time then
+                       data[i] = nil;
+                       local r = func();
+                       if type(r) == "number" then _add_task(r, func); end
+               end
+       end
+end);
+
+return _M;