Parallelised merge, distribution phase.

1 files changed, 29 insertions, 0 deletions

diff --git a/merge/src/merge_dist_sup.erl b/merge/src/merge_dist_sup.erl
new file mode 100644
index 0000000..050ddc5
--- /dev/null
+++ b/merge/src/merge_dist_sup.erl
@@ -0,0 +1,29 @@
+%%% Copyright (c) 2017, NORDUnet A/S.
+%%% See LICENSE for licensing information.
+
+-module(merge_dist_sup).
+-behaviour(supervisor).
+
+-export([start_link/1, init/1]).
+
+start_link([]) ->
+    {ok, Nodes} = application:get_env(plop, frontend_nodes),
+    lager:info("starting merge dist for frontend nodes: ~p", [Nodes]),
+    {ok, Pid} = supervisor:start_link({local, ?MODULE}, ?MODULE, []),
+    lists:map(fun(Node) ->
+                      lager:debug("starting dist worker: ~p", [Node]),
+                      {ok, Child} =
+                          supervisor:start_child(?MODULE, [Node]),
+                      Child
+              end, Nodes),
+    {ok, Pid}.
+
+init(_Args) ->
+    {ok,
+     {{simple_one_for_one, 3, 10},
+      [
+       {ignored,
+        {merge_dist, start_link, []},
+        permanent, 10000, worker,
+        [merge_dist]}
+      ]}}.