From 149943566af4c53b61e633fad16dd7dc8d48401d Mon Sep 17 00:00:00 2001 From: Linus Nordberg Date: Wed, 8 Feb 2017 12:44:37 +0100 Subject: Do do missingentries in merge dist. --- merge/src/merge_util.erl | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) (limited to 'merge/src/merge_util.erl') diff --git a/merge/src/merge_util.erl b/merge/src/merge_util.erl index 1df1409..a6c435b 100644 --- a/merge/src/merge_util.erl +++ b/merge/src/merge_util.erl @@ -2,7 +2,7 @@ %%% See LICENSE for licensing information. -module(merge_util). --export([sendlog/4, sendentries/3]). +-export([sendlog/4, sendentries/3, missingentries/1]). -export([request/2, request/4]). -export([readfile/1, nfetched/0]). @@ -48,6 +48,16 @@ sendlog_request(NodeAddress, Start, Hashes) -> throw({request_error, result, DebugTag, Err}) end. +missingentries(NodeAddress) -> + DebugTag = "missingentries", + URL = NodeAddress ++ "missingentries", + case request(DebugTag, URL) of + {<<"ok">>, PropList} -> + {ok, proplists:get_value(<<"entries">>, PropList)}; + Err -> + throw({request_error, result, DebugTag, Err}) + end. + sendentries(NodeAddress, Hashes, Chunksize) -> {ChunkOfHashes, RestOfHashes} = lists:split(min(Chunksize, length(Hashes)), Hashes), sendentries_chunk(NodeAddress, {ChunkOfHashes, RestOfHashes}, Chunksize). -- cgit v1.1