2 -- Copyright (C) 2008-2010 Matthew Wild
3 -- Copyright (C) 2008-2010 Waqas Hussain
5 -- This project is MIT/X11 licensed. Please see the
6 -- COPYING file in the source package for more information.
9 local server = require "net.server";
10 local math_min = math.min
11 local math_huge = math.huge
12 local get_time = require "socket".gettime;
13 local t_insert = table.insert;
23 if not server.event then
24 function _add_task(delay, callback)
25 local current_time = get_time();
26 delay = delay + current_time;
27 if delay >= current_time then
28 t_insert(new_data, {delay, callback});
30 local r = callback(current_time);
31 if r and type(r) == "number" then
32 return _add_task(r, callback);
37 server._addtimer(function()
38 local current_time = get_time();
40 for _, d in pairs(new_data) do
46 local next_time = math_huge;
47 for i, d in pairs(data) do
48 local t, callback = d[1], d[2];
49 if t <= current_time then
51 local r = callback(current_time);
52 if type(r) == "number" then
53 _add_task(r, callback);
54 next_time = math_min(next_time, r);
57 next_time = math_min(next_time, t - current_time);
63 local event = server.event;
64 local event_base = server.event_base;
65 local EVENT_LEAVE = (event.core and event.core.LEAVE) or -1;
67 function _add_task(delay, callback)
69 event_handle = event_base:addevent(nil, 0, function ()
70 local ret = callback(get_time());
73 elseif event_handle then