Skip to content

Commit

Permalink
add missing function clause repair_keys_range in convert_fold (#1839)
Browse files Browse the repository at this point in the history
* add missing function clause repair_keys_range in convert_fold, to unbreak aae_fold for that case

* thread converted aae_fold query in riak_client, to complete prev commit
  • Loading branch information
hmmr authored and martinsumner committed Dec 19, 2022
1 parent b7ea524 commit 7bfb59c
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 1 deletion.
2 changes: 1 addition & 1 deletion src/riak_client.erl
Original file line number Diff line number Diff line change
Expand Up @@ -907,7 +907,7 @@ aae_fold(Query, {?MODULE, [Node, _ClientId]}) ->
true ->
riak_kv_clusteraae_fsm_sup:start_clusteraae_fsm(Node,
[{raw, ReqId, Me},
[Query, TimeOut]]),
[Q0, TimeOut]]),
wait_for_fold_results(ReqId, TimeOut);
false ->
{error, "Invalid AAE fold definition"}
Expand Down
2 changes: 2 additions & 0 deletions src/riak_kv_clusteraae_fsm.erl
Original file line number Diff line number Diff line change
Expand Up @@ -893,6 +893,8 @@ convert_fold({find_tombs, B, KR, SF, MR}) ->
{find_tombs, B, KR, SF, convert_modrange(MR)};
convert_fold({reap_tombs, B, KR, SF, MR, CM}) ->
{reap_tombs, B, KR, SF, convert_modrange(MR), CM};
convert_fold({repair_keys_range, B, KR, MR, L}) ->
{repair_keys_range, B, KR, convert_modrange(MR), L};
convert_fold({erase_keys, B, KR, SF, MR, CM}) ->
{erase_keys, B, KR, SF, convert_modrange(MR), CM};
convert_fold(Fold) ->
Expand Down

0 comments on commit 7bfb59c

Please sign in to comment.