diff options
author | Waqas Hussain <waqas20@gmail.com> | 2009-02-21 01:13:53 +0500 |
---|---|---|
committer | Waqas Hussain <waqas20@gmail.com> | 2009-02-21 01:13:53 +0500 |
commit | 97ea70c7d325fcdd6342a84464e9b7b26d9da177 (patch) | |
tree | d3fd4c44b4cc0bdd838faa71275bc01be0cd41f8 /util/timer.lua | |
parent | 8f0b93e738a6df64a7eb70766ff31873c880d436 (diff) | |
download | prosody-97ea70c7d325fcdd6342a84464e9b7b26d9da177.tar.gz prosody-97ea70c7d325fcdd6342a84464e9b7b26d9da177.zip |
Added util/timer.lua - a timer API
Diffstat (limited to 'util/timer.lua')
-rw-r--r-- | util/timer.lua | 47 |
1 files changed, 47 insertions, 0 deletions
diff --git a/util/timer.lua b/util/timer.lua new file mode 100644 index 00000000..889a8c4c --- /dev/null +++ b/util/timer.lua @@ -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; |