anchor.diff:      {ok, State}.
   
   process_results(_VNode, {error, Reason}, _State) ->
  +    io:format("in riak_kv_index_fsm process_results (1)~n"),
       {error, Reason};
   process_results(_VNode, {From, _Bucket, _Results}, State=#state{max_results=X, results_sent=Y})  when Y >= X ->
  +
       riak_kv_vnode:stop_fold(From),
       {done, State};
   process_results(VNode, {From, Bucket, Results}, State) ->
  
positive.code:     end,
      %% Construct the key listing request
      Req = req(Bucket, ItemFilter, Query),
      {Req, all, NVal, 1, riak_kv, riak_kv_vnode_master, Timeout,
       #state{from=From, max_results=MaxResults, pagination_sort=PgSort}}.
  
  plan(CoverageVNodes, State = #state{pagination_sort=true}) ->
  
negative.code: init(From={_, _, _}, [Bucket, ItemFilter, Query, Timeout, MaxResults]) ->
      init(From, [Bucket, ItemFilter, Query, Timeout, MaxResults, undefined]);
  init(From={_, _, _}, [Bucket, ItemFilter, Query, Timeout, MaxResults, PgSort0]) ->
      gg:format("in riak_kv_index_fsm:init with MaxResults of:~n- ~p~n",
  	      [MaxResults]),
      %% Get the bucket n_val for use in creating a coverage plan
      BucketProps = riak_core_bucket:get_bucket(Bucket),
      NVal = proplists:get_value(n_val, BucketProps),
      Paginating = is_integer(MaxResults) andalso MaxResults > 0,
      PgSort = case {Paginating, PgSort0} of
          {true, _} ->
              true;
  