aboutsummaryrefslogtreecommitdiff
path: root/eco_time.erl
diff options
context:
space:
mode:
authorNathan Lasseter <nathan@4574.co.uk>2014-05-30 08:05:19 +0100
committerNathan Lasseter <nathan@4574.co.uk>2014-05-30 08:05:19 +0100
commit59cee25c7f863e76bc82cd58b33f6f3b4e13770c (patch)
treecd238d062a4c58e4c174a322ac02e1bb7e942d69 /eco_time.erl
Initial Commit
Diffstat (limited to 'eco_time.erl')
-rw-r--r--eco_time.erl30
1 files changed, 30 insertions, 0 deletions
diff --git a/eco_time.erl b/eco_time.erl
new file mode 100644
index 0000000..587cca5
--- /dev/null
+++ b/eco_time.erl
@@ -0,0 +1,30 @@
+-module(eco_time).
+-export([ticker/4]).
+
+ticker(Watcher, Interval, ProcList, Timeout) ->
+ receive
+ {From, stop} ->
+ From ! {ok, stopped},
+ {ok, stopped}
+ after Interval ->
+ handle_tick(self(), ProcList, Timeout),
+ receive
+ {ok, endtick} ->
+ Watcher ! {endtick, self()},
+ ticker(Watcher, Interval, ProcList, Timeout);
+ {error, notock, Proc} ->
+ Watcher ! {error, notock, Proc, self()},
+ {error, notock, Proc}
+ end
+ end.
+
+handle_tick(Ticker, [], _) ->
+ Ticker ! {ok, endtick};
+handle_tick(Ticker, [This | Next], Timeout) ->
+ This ! {self(), tick},
+ receive
+ {This, tock} ->
+ handle_tick(Ticker, Next, Timeout)
+ after Timeout ->
+ Ticker ! {error, notock, This}
+ end.