diff options
Diffstat (limited to 'merge/src/merge_dist.erl')
| -rw-r--r-- | merge/src/merge_dist.erl | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/merge/src/merge_dist.erl b/merge/src/merge_dist.erl index 3c38401..23c9d19 100644 --- a/merge/src/merge_dist.erl +++ b/merge/src/merge_dist.erl @@ -21,6 +21,7 @@ start_link(Args) -> init([Name, Address]) -> lager:info("~p:~p: starting (~p)", [?MODULE, Name, Address]), Timer = erlang:start_timer(1000, self(), dist), + bench:timingpoint("merge_dist", Name, "start"), {ok, #state{timer = Timer, node_name = Name, node_address = Address, @@ -51,6 +52,7 @@ dist({struct, PropList} = STH, #state{node_address = NodeAddress, node_name = NodeName, sth_timestamp = LastTimestamp} = State) -> + bench:timingpoint("merge_dist", NodeName, "idle"), Treesize = proplists:get_value(<<"tree_size">>, PropList), Timestamp = proplists:get_value(<<"timestamp">>, PropList), RootHash = base64:decode(proplists:get_value(<<"sha256_root_hash">>, PropList)), @@ -59,12 +61,14 @@ dist({struct, PropList} = STH, TS = case Timestamp > LastTimestamp of true -> true = plop:verify_sth(Treesize, Timestamp, RootHash, Signature), + bench:timingpoint("merge_dist", NodeName, "verify_sth"), try lager:info("~p: starting dist, sth at ~B, logorder at ~B", [NodeAddress, Treesize, Logordersize]), statusreport:report("merge_dist", NodeName, "targetsth", Treesize), ok = do_dist(NodeAddress, NodeName, min(Treesize, Logordersize)), ok = publish_sth(NodeName, NodeAddress, STH), + bench:timingpoint("merge_dist", NodeName, "publish_sth"), statusreport:report("merge_dist", NodeName, "sth", Treesize), lager:info("~p: Published STH with size ~B and timestamp " ++ "~p.", [NodeAddress, Treesize, Timestamp]), @@ -101,12 +105,16 @@ do_dist(NodeAddress, NodeName, Start, NTotal) -> SendlogChunksize = application:get_env(plop, merge_dist_sendlog_chunksize, 1000), SendentriesChunksize = application:get_env(plop, merge_dist_sendentries_chunksize, 100), ok = merge_util:sendlog(NodeAddress, NodeName, Start, Hashes, SendlogChunksize), + bench:timingpoint("merge_dist", NodeName, "sendlog"), statusreport:report("merge_dist", NodeName, "sendlog", Start + N), {ok, HashesMissingEncoded} = merge_util:missingentries(NodeAddress, NodeName), + bench:timingpoint("merge_dist", NodeName, "missingentries"), lager:debug("number of missing entries: ~B", [length(HashesMissingEncoded)]), HashesMissing = lists:map(fun base64:decode/1, HashesMissingEncoded), ok = merge_util:sendentries(NodeAddress, NodeName, HashesMissing, SendentriesChunksize), + bench:timingpoint("merge_dist", NodeName, "sendentries"), {ok, NewSize} = frontend_verify_entries(NodeName, NodeAddress, Start + N), + bench:timingpoint("merge_dist", NodeName, "verifyentries"), lager:info("~p: Done distributing ~B out of ~B entries.", [NodeAddress, NewSize-Start, NTotal]), statusreport:report("merge_dist", NodeName, "verified", Start + N), |