aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorMatthew Wild <mwild1@gmail.com>2009-11-21 02:40:21 +0000
committerMatthew Wild <mwild1@gmail.com>2009-11-21 02:40:21 +0000
commit89fa12376ae294bde2e264a665d8e22373bc5a52 (patch)
tree3bef53757e40818e755a73eff72255aa4860d8f0
parent2a8668dd30b4e52cd7e7f916527ae31694f01701 (diff)
downloadprosody-89fa12376ae294bde2e264a665d8e22373bc5a52.tar.gz
prosody-89fa12376ae294bde2e264a665d8e22373bc5a52.zip
util.timer: Use libevent for lightweight timers if available and configured (use_libevent option)
-rw-r--r--util/timer.lua68
1 files changed, 44 insertions, 24 deletions
diff --git a/util/timer.lua b/util/timer.lua
index c0c7f25a..4c9a3ea9 100644
--- a/util/timer.lua
+++ b/util/timer.lua
@@ -8,6 +8,8 @@
local ns_addtimer = require "net.server".addtimer;
+local event = require "net.server".event;
+
local get_time = os.time;
local t_insert = table.insert;
local t_remove = table.remove;
@@ -19,33 +21,51 @@ 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);
+local _add_task;
+if not event then
+ 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
- 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
+
+ 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);
+else
+ local EVENT_LEAVE = (event.core and event.core.LEAVE) or -1;
+ function _add_task(delay, func)
+ event.base:addevent(nil, event.EV_TIMEOUT, function ()
+ local ret = func();
+ if ret then
+ _add_task(ret, func);
+ else
+ return EVENT_LEAVE;
+ end
+ end
+ , delay);
end
-end);
+end
+
+add_task = _add_task;
return _M;