diff options
| author | Linus Nordberg <linus@nordu.net> | 2017-02-08 11:55:27 +0100 |
|---|---|---|
| committer | Linus Nordberg <linus@nordu.net> | 2017-02-08 11:55:27 +0100 |
| commit | 0e635b850809c843295b822551ef902ffeb19142 (patch) | |
| tree | f2c2051d77dbf7549f4324471042de37ee5a77fb /merge/src/merge_dist.erl | |
| parent | c5506779dac2d13ca407ae26f97ba6e6e85a6ad7 (diff) | |
Make merge dist workers one_for_one.
Look like dist backup, in preparation for reloadable config wrt
frontend nodes.
Also pass node names as well as addresses.
Diffstat (limited to 'merge/src/merge_dist.erl')
| -rw-r--r-- | merge/src/merge_dist.erl | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/merge/src/merge_dist.erl b/merge/src/merge_dist.erl index 25e13ec..6e9b879 100644 --- a/merge/src/merge_dist.erl +++ b/merge/src/merge_dist.erl @@ -10,6 +10,7 @@ -record(state, { timer :: reference(), + node_name :: string(), node_address :: string(), sth_timestamp :: non_neg_integer() }). @@ -17,11 +18,12 @@ start_link(Args) -> gen_server:start_link(?MODULE, Args, []). -init(Node) -> - lager:info("~p:~p: starting", [?MODULE, Node]), +init([Name, Address]) -> + lager:info("~p:~p: starting (~p)", [?MODULE, Name, Address]), Timer = erlang:start_timer(1000, self(), dist), {ok, #state{timer = Timer, - node_address = Node, + node_name = Name, + node_address = Address, sth_timestamp = 0}}. handle_call(stop, _From, State) -> |