From 7bfb59c31cc4fdc1ab896981c7ea10cd100c39d5 Mon Sep 17 00:00:00 2001 From: Andrei Zavada Date: Thu, 1 Dec 2022 15:41:00 +0200 Subject: [PATCH] add missing function clause repair_keys_range in convert_fold (#1839) * 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 --- src/riak_client.erl | 2 +- src/riak_kv_clusteraae_fsm.erl | 2 ++ 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/src/riak_client.erl b/src/riak_client.erl index c01ebf906..7c18dd9bf 100644 --- a/src/riak_client.erl +++ b/src/riak_client.erl @@ -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"} diff --git a/src/riak_kv_clusteraae_fsm.erl b/src/riak_kv_clusteraae_fsm.erl index 66b9f779e..d92fcda1a 100644 --- a/src/riak_kv_clusteraae_fsm.erl +++ b/src/riak_kv_clusteraae_fsm.erl @@ -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) ->