anchor.diff:  index_terms(Pid, Terms, Timeout) ->
       %% Add the keyclock
       K = riak_search_utils:current_key_clock(),
  -    Terms1 = [{I,F,T,V,P,K} || {I,F,T,V,P} <- Terms],
  -    gen_fsm:sync_send_event(Pid, {index, Terms1}, Timeout).
  +    %% Terms1 = [{I,F,T,V,P,K} || {I,F,T,V,P} <- Terms],
  +    %% Rc = gen_fsm:sync_send_event(Pid, {index, Terms1}, Timeout),
  +    F = fun({I,F,T,V,P}, Status) ->
  +                NewStatus = gen_fsm:sync_send_event(Pid, {index, [{I,F,T,V,P,K}]}, Timeout),
  +                case Status of
  +                    ok ->
  +                        NewStatus;
  +                    _ ->
  +                        Status
  +                end
  +        end,
  +    lists:foldl(F, ok, Terms).
   
   %% Signal we are done and wait for the FSM to complete and exit
   -spec done(pid()) -> ok.
  
positive.code: %% Send the next batch of terms
  -spec send_batch(#state{}) -> {statename(), #state{}}.
  send_batch(#state{terms=[]}=State) ->
      gen_fsm:send_event(self(), empty),
      {idle, State};
  send_batch(State) ->
      {Rest, PlTerms, TermCount} = lookup_preflist(State#state.batch_size,
                                                   0,
  
negative.code: -define(RECV_TIMEOUT_USECS, 60000).
  -define(INDEX_TIMEOUT_USECS, 60000).
  
  -record(state, {total=0,           % Total number of terms sent to all vnodes
                  acks=0,            % Number of indexed messages received
                  timeouts=0,        % Number of timeout messages received
                  num_terms=0,       % Number of terms in the terms list below
                  ref,               % Reference for current batch of terms sent out
                  replies_left,      % Count of replies pending
                  timer,             % Timer reference for batch
                  overload_waiters=[], % List to reply to once out of overload
                  done_waiters=[],   % List to reply to once terms is empty
                  batch_size,        % Size of index batches to send
                  overload_thresh,   % Threshold for num_terms to trigger overload
                  terms=[]}).        % Terms left to index,
  
  
  -type index() :: term().
  