From 829ab97fccb991832445862ec8246197a225ecec Mon Sep 17 00:00:00 2001
From: Linus Nordberg <linus@nordu.net>
Date: Fri, 27 Jan 2017 15:11:42 +0100
Subject: Parallelised merge, distribution phase.

---
 merge/src/merge_dist_sup.erl | 29 +++++++++++++++++++++++++++++
 1 file changed, 29 insertions(+)
 create mode 100644 merge/src/merge_dist_sup.erl

(limited to 'merge/src/merge_dist_sup.erl')

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]}
+      ]}}.
-- 
cgit v1.1