diff options
Diffstat (limited to 'merge/src/merge_dist.erl')
| -rw-r--r-- | merge/src/merge_dist.erl | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/merge/src/merge_dist.erl b/merge/src/merge_dist.erl index 8615f6c..2e7013f 100644 --- a/merge/src/merge_dist.erl +++ b/merge/src/merge_dist.erl @@ -97,7 +97,9 @@ do_dist(NodeAddress, 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, Start, Hashes, SendlogChunksize), - ok = merge_util:sendentries(NodeAddress, Hashes, SendentriesChunksize), + {ok, HashesMissingEncoded} = merge_util:missingentries(NodeAddress), + HashesMissing = lists:map(fun base64:decode/1, HashesMissingEncoded), + ok = merge_util:sendentries(NodeAddress, HashesMissing, SendentriesChunksize), {ok, NewSize} = frontend_verify_entries(NodeAddress, Start + N), lager:info("~p: Done distributing ~B entries.", [NodeAddress, NewSize-Start]), true = NTotal >= NewSize - Start, |