diff options
-rw-r--r-- | merge/src/merge_backup.erl | 4 |
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), |