Ignore the return value from ack_keys.

Resolves:

riak_kv_index_fsm.erl:127: Expression produces a value of type {_,'ok'}, but this value is unmatched
riak_kv_index_fsm.erl:134: Expression produces a value of type {_,'ok'}, but this value is unmatched
riak_kv_index_fsm.erl:191: Expression produces a value of type {_,'ok'}, but this value is unmatched
riak_kv_keys_fsm.erl:104: Expression produces a value of type {_,'ok'}, but this value is unmatched
riak_kv_pb_bucket.erl:129: Expression produces a value of type {_,'ok'}, but this value is unmatched
riak_kv_pb_bucket.erl:136: Expression produces a value of type {_,'ok'}, but this value is unmatched
riak_kv_pipe_listkeys.erl:102: Expression produces a value of type {_,'ok'}, but this value is unmatched

Author: cmeiklejohn

src/riak_kv_index_fsm.erl

@@ -124,14 +124,14 @@ process_results(VNode, {From, Bucket, Results}, State) ->
             VNodeCount = dict:fetch(VNode, PerNode),
             case VNodeCount < MaxResults of
                 true ->
-                    riak_kv_vnode:ack_keys(From),
+                    _ = riak_kv_vnode:ack_keys(From),
                     {ok, State2};
                 false ->
                     riak_kv_vnode:stop_fold(From),
                     {done, State2}
             end;
         {ok, State2} ->
-            riak_kv_vnode:ack_keys(From),
+            _ = riak_kv_vnode:ack_keys(From),
             {ok, State2};
         {done, State2} ->
             riak_kv_vnode:stop_fold(From),
@@ -188,7 +188,7 @@ process_results({error, Reason}, _State) ->
 process_results({From, Bucket, Results},
                 StateData=#state{from={raw, ReqId, ClientPid}}) ->
     process_query_results(Bucket, Results, ReqId, ClientPid),
-    riak_kv_vnode:ack_keys(From), % tell that vnode we're ready for more
+    _ = riak_kv_vnode:ack_keys(From), % tell that vnode we're ready for more
     {ok, StateData};
 process_results({Bucket, Results},
                 StateData=#state{from={raw, ReqId, ClientPid}}) ->

src/riak_kv_keys_fsm.erl

@@ -101,7 +101,7 @@ process_results({From, Bucket, Keys},
     %% TODO: have caller give us the Idx number.
     ?DTRACE(?C_KEYS_PROCESS_RESULTS, [length(Keys)], []),
     process_keys(Bucket, Keys, ReqId, ClientPid),
-    riak_kv_vnode:ack_keys(From), % tell that vnode we're ready for more
+    _ = riak_kv_vnode:ack_keys(From), % tell that vnode we're ready for more
     {ok, StateData};
 process_results({error, Reason}, _State) ->
     ?DTRACE(?C_KEYS_PROCESS_RESULTS, [-1], []),

src/riak_kv_pb_bucket.erl

@@ -126,14 +126,14 @@ process_stream({ReqId, done}, ReqId,
     {done, #rpblistkeysresp{done = 1}, State};
 process_stream({ReqId, From, {keys, []}}, ReqId,
                State=#state{req=#rpblistkeysreq{}, req_ctx=ReqId}) ->
-    riak_kv_keys_fsm:ack_keys(From),
+    _ = riak_kv_keys_fsm:ack_keys(From),
     {ignore, State};
 process_stream({ReqId, {keys, []}}, ReqId,
                State=#state{req=#rpblistkeysreq{}, req_ctx=ReqId}) ->
     {ignore, State};
 process_stream({ReqId, From, {keys, Keys}}, ReqId,
                State=#state{req=#rpblistkeysreq{}, req_ctx=ReqId}) ->
-    riak_kv_keys_fsm:ack_keys(From),
+    _ = riak_kv_keys_fsm:ack_keys(From),
     {reply, #rpblistkeysresp{keys = Keys}, State};
 process_stream({ReqId, {keys, Keys}}, ReqId,
                State=#state{req=#rpblistkeysreq{}, req_ctx=ReqId}) ->

src/riak_kv_pipe_listkeys.erl

@@ -99,7 +99,7 @@ keysend_loop(ReqId, Partition, FittingDetails) ->
             Result = keysend(Bucket, Keys, Partition, FittingDetails),
             case Result of
                 ok ->
-                    riak_kv_vnode:ack_keys(From),
+                    _ = riak_kv_vnode:ack_keys(From),
                     keysend_loop(ReqId, Partition, FittingDetails);
                 Error ->
                     Error