diff options
| author | daurnimator <quae@daurnimator.com> | 2014-10-20 16:13:24 -0400 |
|---|---|---|
| committer | daurnimator <quae@daurnimator.com> | 2014-10-20 16:13:24 -0400 |
| commit | e51cc17dcbb1c6d8d614ff92ae48e412bf97fb73 (patch) | |
| tree | 032ae646f40566f31102c4e76aacd8f843181945 /net/server_event.lua | |
| parent | 54d833e318feb0a6b6b44af42a6241b79fc5bce7 (diff) | |
| download | prosody-e51cc17dcbb1c6d8d614ff92ae48e412bf97fb73.tar.gz prosody-e51cc17dcbb1c6d8d614ff92ae48e412bf97fb73.zip | |
Move timer code out of util.timer and into relevant net.server backends
Diffstat (limited to 'net/server_event.lua')
| -rw-r--r-- | net/server_event.lua | 18 |
1 files changed, 18 insertions, 0 deletions
diff --git a/net/server_event.lua b/net/server_event.lua index 480d876d..fa6dda19 100644 --- a/net/server_event.lua +++ b/net/server_event.lua @@ -848,6 +848,23 @@ local function link(sender, receiver, buffersize) sender:set_mode("*a"); end +local add_task do + local EVENT_LEAVE = (event.core and event.core.LEAVE) or -1; + local socket_gettime = socket.gettime + function add_task(delay, callback) + local event_handle; + event_handle = base:addevent(nil, 0, function () + local ret = callback(socket_gettime()); + if ret then + return 0, ret; + elseif event_handle then + return EVENT_LEAVE; + end + end + , delay); + end +end + return { cfg = cfg, @@ -864,6 +881,7 @@ return { closeall = closeallservers, get_backend = get_backend, hook_signal = hook_signal, + add_task = add_task, __NAME = SCRIPT_NAME, __DATE = LAST_MODIFIED, |