diff options
| author | Linus Nordberg <linus@nordu.net> | 2017-07-06 17:34:48 +0200 |
|---|---|---|
| committer | Linus Nordberg <linus@nordu.net> | 2017-07-06 17:34:48 +0200 |
| commit | 05235680257a54f112c44c7854b3afe8300acd40 (patch) | |
| tree | 25fe5447ec40e8bd59170241bcbd107f2e56f45d /merge/src/merge_backup.erl | |
| parent | 0d7c7bb15f449656e35801dac5ba410f16261c6f (diff) | |
| parent | df2441c6315de4b245e1faf5b72517c5199fe179 (diff) | |
Diffstat (limited to 'merge/src/merge_backup.erl')
| -rw-r--r-- | merge/src/merge_backup.erl | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/merge/src/merge_backup.erl b/merge/src/merge_backup.erl index 068725c..3c19527 100644 --- a/merge/src/merge_backup.erl +++ b/merge/src/merge_backup.erl @@ -20,6 +20,7 @@ start_link(Args) -> init([Name, Address]) -> lager:info("~p:~p: starting (~p)", [?MODULE, Name, Address]), Timer = erlang:start_timer(1000, self(), backup), + bench:timingpoint("merge_backup", Name, "start"), {ok, #state{timer = Timer, node_name = Name, node_address = Address}}. handle_call(stop, _From, State) -> @@ -42,14 +43,17 @@ terminate(Reason, #state{timer = Timer}) -> backup(Size, #state{node_name = NodeName, node_address = NodeAddress} = State) -> lager:debug("~p: logorder size ~B", [NodeName, Size]), + bench:timingpoint("merge_backup", NodeName, "idle"), ht:load_tree(Size - 1), % TODO: Make sure this is OK to do from multiple processes and that it's not "moving backwards". try {ok, VerifiedSize} = verified_size(NodeName, NodeAddress), + bench:timingpoint("merge_backup", NodeName, "verifiedsize"), lager:debug("~p: verifiedsize ~B", [NodeName, VerifiedSize]), case VerifiedSize == Size of true -> TreeHead = ht:root(Size - 1), ok = check_root(NodeName, NodeAddress, Size, TreeHead), + bench:timingpoint("merge_backup", NodeName, "verifyroot"), ok = write_backupfile(NodeName, Size, TreeHead); false -> true = VerifiedSize < Size, % Secondary ahead of primary? @@ -69,13 +73,17 @@ do_backup(NodeName, NodeAddress, Start, NTotal) -> N = min(NTotal, plopconfig:get_env(merge_backup_winsize, 1000)), Hashes = index:getrange(logorder, Start, Start + N - 1), ok = merge_util:sendlog(NodeAddress, NodeName, Start, Hashes, plopconfig:get_env(merge_backup_sendlog_chunksize, 1000)), + bench:timingpoint("merge_backup", NodeName, "sendlog"), {ok, HashesMissingEncoded} = merge_util:missingentries(NodeAddress, NodeName), HashesMissing = lists:map(fun base64:decode/1, HashesMissingEncoded), ok = merge_util:sendentries(NodeAddress, NodeName, HashesMissing, plopconfig:get_env(merge_backup_sendentries_chunksize, 100)), + bench:timingpoint("merge_backup", NodeName, "sendentries"), Size = Start + N, TreeHead = ht:root(Size - 1), ok = check_root(NodeName, NodeAddress, Size, TreeHead), + bench:timingpoint("merge_backup", NodeName, "verifyroot"), ok = setverifiedsize(NodeName, NodeAddress, Size), + bench:timingpoint("merge_backup", NodeName, "setverifiedsize"), ok = write_backupfile(NodeName, Size, TreeHead), true = NTotal >= N, do_backup(NodeName, NodeAddress, Size, NTotal - N). |