Still WIPmergefetch

1 files changed, 30 insertions, 0 deletions

diff --git a/merge/src/merge_fetch_fetch_sup.erl b/merge/src/merge_fetch_fetch_sup.erl
new file mode 100644
index 0000000..fb89ab4
--- /dev/null
+++ b/merge/src/merge_fetch_fetch_sup.erl
@@ -0,0 +1,30 @@
+%%% Copyright (c) 2017, NORDUnet A/S.
+%%% See LICENSE for licensing information.
+
+-module(merge_fetch_fetch_sup).
+-behaviour(supervisor).
+
+-export([start_link/1, init/1]).
+
+start_link(Nodes) ->
+    {ok, Pid} = 
+        supervisor:start_link({local, ?MODULE}, ?MODULE, []),
+    Children = 
+        lists:map(fun({NodeName, NodeAddress}) -> 
+                          lager:info("starting fetch worker: ~p", [NodeName]),
+
+                          {ok, Child} = supervisor:start_child(
+                                          ?MODULE, 
+                                          [{NodeName, NodeAddress}]),
+                          Child
+                  end, Nodes),
+    lager:debug("~p started newentry workers: ~p", [Pid, Children]),
+    {ok, Pid}.
+
+init([]) ->
+    {ok,
+     {{simple_one_for_one, 3, 10},
+      [{ignored,
+        {merge_fetch_fetch, start_link, []},
+        permanent, 10000, worker,
+        [merge_fetch_fetch]}]}}.