aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorMatthew Wild <mwild1@gmail.com>2011-10-21 17:12:45 -0400
committerMatthew Wild <mwild1@gmail.com>2011-10-21 17:12:45 -0400
commitd53889185ac93c9744ee2ad35eee863929267903 (patch)
tree109749f485021ffbb405a19c7b570db1353645f2
parent3df40be7ea0c5515d05180f7b19c0b5d8e887dab (diff)
downloadprosody-d53889185ac93c9744ee2ad35eee863929267903.tar.gz
prosody-d53889185ac93c9744ee2ad35eee863929267903.zip
util.watchdog: Watchdog timer library
-rw-r--r--util/watchdog.lua34
1 files changed, 34 insertions, 0 deletions
diff --git a/util/watchdog.lua b/util/watchdog.lua
new file mode 100644
index 00000000..96031415
--- /dev/null
+++ b/util/watchdog.lua
@@ -0,0 +1,34 @@
+local timer = require "util.timer";
+local setmetatable = setmetatable;
+local os_time = os.time;
+
+module "watchdog"
+
+local watchdog_methods = {};
+local watchdog_mt = { __index = watchdog_methods };
+
+function new(timeout, callback)
+ local watchdog = setmetatable({ timeout = timeout, last_reset = os_time(), callback = callback }, watchdog_mt);
+ timer.add_task(timeout+1, function (current_time)
+ local last_reset = watchdog.last_reset;
+ if not last_reset then
+ return;
+ end
+ local time_left = (last_reset + timeout) - current_time;
+ if time_left < 0 then
+ return watchdog.callback();
+ end
+ return time_left + 1;
+ end);
+ return watchdog;
+end
+
+function watchdog_methods:reset()
+ self.last_reset = os_time();
+end
+
+function watchdog_methods:cancel()
+ self.last_reset = nil;
+end
+
+return _M;