summaryrefslogtreecommitdiff
path: root/merge/src/merge_backup.erl
diff options
context:
space:
mode:
Diffstat (limited to 'merge/src/merge_backup.erl')
-rw-r--r--merge/src/merge_backup.erl4
1 files changed, 3 insertions, 1 deletions
diff --git a/merge/src/merge_backup.erl b/merge/src/merge_backup.erl
index 0686e32..bf20f23 100644
--- a/merge/src/merge_backup.erl
+++ b/merge/src/merge_backup.erl
@@ -69,7 +69,9 @@ 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, Start, Hashes, plopconfig:get_env(merge_backup_sendlog_chunksize, 1000)),
- ok = merge_util:sendentries(NodeAddress, Hashes, plopconfig:get_env(merge_backup_sendentries_chunksize, 100)),
+ {ok, HashesMissingEncoded} = merge_util:missingentries(NodeAddress),
+ HashesMissing = lists:map(fun base64:decode/1, HashesMissingEncoded),
+ ok = merge_util:sendentries(NodeAddress, HashesMissing, plopconfig:get_env(merge_backup_sendentries_chunksize, 100)),
Size = Start + N,
TreeHead = ht:root(Size - 1),
ok = check_root(NodeAddress, Size, TreeHead),