From 0070a4f70dd78f1f8aacb0657c741a2c311a7f32 Mon Sep 17 00:00:00 2001
From: Linus Nordberg <linus@nordu.net>
Date: Thu, 2 Feb 2017 02:25:42 +0100
Subject: Parallelised merge, backup phase.

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

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

diff --git a/merge/src/merge_backup_sup.erl b/merge/src/merge_backup_sup.erl
new file mode 100644
index 0000000..3c77a8f
--- /dev/null
+++ b/merge/src/merge_backup_sup.erl
@@ -0,0 +1,23 @@
+%%% Copyright (c) 2017, NORDUnet A/S.
+%%% See LICENSE for licensing information.
+
+-module(merge_backup_sup).
+-behaviour(supervisor).
+
+-export([start_link/1, init/1]).
+
+start_link([]) ->
+    supervisor:start_link({local, ?MODULE}, ?MODULE, []).
+
+init(_Args) ->
+    {ok, {{one_for_one, 3, 10}, children()}}.
+
+child_spec({Name, Address}) ->
+    {Name, {merge_backup, start_link, [[Name, Address]]},
+     permanent, 10000, worker, [merge_backup]}.
+
+children() ->
+    {ok, Nodes} = plopconfig:get_env(merge_secondaries),
+    {Names, _Addrs} = lists:unzip(Nodes),
+    lager:info("Starting merge backup for secondary merge nodes: ~p", [Names]),
+    [child_spec(Node) || Node <- Nodes].
-- 
cgit v1.1