umgeher/leveled
0
Fork 0
Code Issues Pull requests Releases Activity Actions

Switch to binary response

Browse source 
Force header in fold_heads to be a binary ... as this is what KV expects
This commit is contained in:
martinsumner 2017-04-07 17:08:40 +00:00
parent 6d42abbc1a
commit 60b0b88226
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
src/leveled_bookie.erl
View file

@ -1091,7 +1091,7 @@ accumulate_objects(FoldObjectsFun, InkerClone, Tag, DeferredFetch) ->
MDBin, MDBin,
Size, Size,
{fun fetch_value/2, InkerClone, JK}}, {fun fetch_value/2, InkerClone, JK}},
FoldObjectsFun(B, K, Value, Acc); FoldObjectsFun(B, K, term_to_binary(Value), Acc);
false -> false ->
R = fetch_value(InkerClone, JK), R = fetch_value(InkerClone, JK),
case R of case R of
@ -1520,7 +1520,7 @@ foldobjects_vs_hashtree_test() ->
{proxy_object, {proxy_object,
_MDBin, _MDBin,
_Size, _Size,
{FetchFun, Clone, JK}} = ProxyV, {FetchFun, Clone, JK}} = binary_to_term(ProxyV),
V = FetchFun(Clone, JK), V = FetchFun(Clone, JK),
[{B, K, erlang:phash2(term_to_binary(V))}|Acc] [{B, K, erlang:phash2(term_to_binary(V))}|Acc]
end, end,
@ -1536,7 +1536,7 @@ foldobjects_vs_hashtree_test() ->
{proxy_object, {proxy_object,
MD, MD,
_Size, _Size,
_Fetcher} = ProxyV, _Fetcher} = binary_to_term(ProxyV),
{Hash, _Size} = MD, {Hash, _Size} = MD,
[{B, K, Hash}|Acc] [{B, K, Hash}|Acc]
end, end,
@ -1595,7 +1595,7 @@ foldobjects_vs_foldheads_bybucket_test() ->
{proxy_object, {proxy_object,
_MDBin, _MDBin,
_Size, _Size,
{FetchFun, Clone, JK}} = ProxyV, {FetchFun, Clone, JK}} = binary_to_term(ProxyV),
V = FetchFun(Clone, JK), V = FetchFun(Clone, JK),
[{B, K, erlang:phash2(term_to_binary(V))}|Acc] [{B, K, erlang:phash2(term_to_binary(V))}|Acc]
end, end,