anchor.diff:              case riak_kv_index_hashtree:get_lock(State#state.local_tree,
                                                    local_fsm) of
                   ok ->
  -                    exchange_remote_request(RemoteVN, IndexN),
  +                    remote_exchange_request(RemoteVN, IndexN),
                       next_state_with_timeout(prepare_exchange, State);
                   _ ->
                       send_exchange_status(already_locked, State),
  
positive.code: 
      update_request(LocalTree, LocalVN, IndexN),
      update_request(RemoteTree, RemoteVN, IndexN),
      next_state_with_timeout(update_trees, State);
  
  update_trees(timeout, State) ->
      do_timeout(State);
  update_trees({not_responsible, VNodeIdx, IndexN}, State) ->
      lager:debug("VNode ~p does not cover preflist ~p", [VNodeIdx, IndexN]),
      send_exchange_status({not_responsible, VNodeIdx, IndexN}, State),
  
negative.code:                      end
               end).
  
  remote_exchange_request(RemoteVN, IndexN) ->
      FsmPid = self(),
      as_event(fun() ->
                       riak_kv_entropy_manager:start_exchange_remote(RemoteVN,
  