From 5fd18b89f3dac2d228d5d2880253edd2e4796b4d Mon Sep 17 00:00:00 2001 From: Martin Sumner Date: Mon, 11 Sep 2023 10:21:53 +0100 Subject: [PATCH 1/2] Correct Key/Clock handling --- src/riakc_pb_socket.erl | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/src/riakc_pb_socket.erl b/src/riakc_pb_socket.erl index fd361c1e..d7946bd3 100644 --- a/src/riakc_pb_socket.erl +++ b/src/riakc_pb_socket.erl @@ -2771,10 +2771,9 @@ process_response(#request{msg = #rpbaaefoldfindkeysreq{}}, {ok, {keys, lists:map(fun unpack_keycount_fun/1, KeysCount)}}, State}; process_response(#request{msg = #rpbaaefoldfindtombsreq{}}, - #rpbaaefoldkeycountresp{keys_count = KeysDH}, + #rpbaaefoldkeyvalueresp{response_type = <<"clock">>} = Rsp, State) -> - %% In this case the integer value in each entry is not a count but a - %% delete hash + KeysNClocks = Rsp#rpbaaefoldkeyvalueresp.keys_value, {reply, {ok, {keys, lists:map(fun unpack_keycount_fun/1, KeysDH)}}, State}; From db4294dec08f21e047fa0afdf5aecc715678966d Mon Sep 17 00:00:00 2001 From: Martin Sumner Date: Tue, 14 Nov 2023 11:16:05 +0000 Subject: [PATCH 2/2] Update riakc_pb_socket.erl --- src/riakc_pb_socket.erl | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/riakc_pb_socket.erl b/src/riakc_pb_socket.erl index d7946bd3..5cfffea5 100644 --- a/src/riakc_pb_socket.erl +++ b/src/riakc_pb_socket.erl @@ -2775,7 +2775,7 @@ process_response(#request{msg = #rpbaaefoldfindtombsreq{}}, State) -> KeysNClocks = Rsp#rpbaaefoldkeyvalueresp.keys_value, {reply, - {ok, {keys, lists:map(fun unpack_keycount_fun/1, KeysDH)}}, + {ok, {keysclocks, lists:map(fun unpack_keyclock_fun/1, KeysNClocks)}}, State}; process_response(#request{msg = #rpbaaefoldreaptombsreq{}}, #rpbaaefoldkeycountresp{response_type = ReapTag,