diff options
| -rw-r--r-- | merge/src/merge_sth.erl | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/merge/src/merge_sth.erl b/merge/src/merge_sth.erl index 17a6a0d..a34179d 100644 --- a/merge/src/merge_sth.erl +++ b/merge/src/merge_sth.erl @@ -63,18 +63,16 @@ make_sth(CurSize, State) -> true = BackupQuorumSize =< length(MergeSecondaryNames), NewSize = lists:nth(BackupQuorumSize + 1, Sizes), lager:debug("new size at backup quorum ~B: ~B", [BackupQuorumSize, NewSize]), - Wait = - if - NewSize < CurSize -> + case NewSize < CurSize of + true -> lager:info("Waiting for enough backups to reach ~B, now at ~B.", [CurSize, NewSize]), 1; - true -> + false -> ok = do_make_sth(NewSize), max(1, round(application:get_env(plop, merge_delay, 600) / 60)) end, - Timer = erlang:start_timer(Wait * 1000, self(), make_sth), {noreply, State#state{timer = Timer}}. |