summaryrefslogtreecommitdiff
path: root/merge/src/merge_dist.erl
diff options
context:
space:
mode:
authorLinus Nordberg <linus@nordu.net>2017-02-23 14:50:54 +0100
committerLinus Nordberg <linus@nordu.net>2017-02-23 14:50:54 +0100
commitdbb1123d2ae73b58dd9020240a965343c3a26278 (patch)
tree58ebee18e01b20c441cb2805966206aa359efb6d /merge/src/merge_dist.erl
parent4be6d0b6539e37b23adea73f9e583b86b6474e12 (diff)
Add debug printouts and error handling.
Diffstat (limited to 'merge/src/merge_dist.erl')
-rw-r--r--merge/src/merge_dist.erl1
1 files changed, 1 insertions, 0 deletions
diff --git a/merge/src/merge_dist.erl b/merge/src/merge_dist.erl
index 2e7013f..ddc7159 100644
--- a/merge/src/merge_dist.erl
+++ b/merge/src/merge_dist.erl
@@ -98,6 +98,7 @@ do_dist(NodeAddress, Start, NTotal) ->
SendentriesChunksize = application:get_env(plop, merge_dist_sendentries_chunksize, 100),
ok = merge_util:sendlog(NodeAddress, Start, Hashes, SendlogChunksize),
{ok, HashesMissingEncoded} = merge_util:missingentries(NodeAddress),
+ lager:debug("number of missing entries: ~B", [length(HashesMissingEncoded)]),
HashesMissing = lists:map(fun base64:decode/1, HashesMissingEncoded),
ok = merge_util:sendentries(NodeAddress, HashesMissing, SendentriesChunksize),
{ok, NewSize} = frontend_verify_entries(NodeAddress, Start + N),