anchor.diff:  
   -export([start/2, stop/1, get_status/0, to_report/1]).
   
  --export([next_partition/2, wait_for_aae_pid/2, wait_for_repair/3,
  +-export([first_partition/2, wait_for_aae_pid/2, wait_for_repair/3,
            wait_for_repair/2]).
   
   %% gen_fsm callbacks
  
positive.code:     gen_fsm:reply(From, Reply),
      State#state{reply_to=undefined}.
  
  
  %% @doc Process next partition or finish if no more remaining.
  next_partition(timeout, State=#state{remaining=[]}) ->
      %% We are done. Report results
      Status = to_simple_state(State),
      Report = to_report(Status),
      lager:info("Finished 2i repair:\n~s", [Report]),
      {stop, normal, State};
  next_partition(timeout, State=#state{remaining=[Partition|_]}) ->
      ReqId = make_ref(),
      riak_kv_vnode:request_hashtree_pid(Partition, {fsm, ReqId, self()}),
      {next_state, wait_for_aae_pid, State#state{aae_pid_req_id=ReqId}, ?AAE_PID_TIMEOUT}.
  
  %% @doc Waiting for vnode to send back the Pid of the AAE tree process.
  wait_for_aae_pid(timeout, State) ->
      State2 = maybe_notify(State, {error, no_aae_pid}),
      {stop, no_aae_pid, State2};
  wait_for_aae_pid({ReqId, {error, Err}}, State=#state{aae_pid_req_id=ReqId}) ->
      State2 = maybe_notify(State, {error, {no_aae_pid, Err}}),
      {stop, no_aae_pid, State2};
  wait_for_aae_pid({ReqId, {ok, TreePid}},
                   State=#state{aae_pid_req_id=ReqId, speed=Speed,
                                remaining=[Partition|_]}) ->
      WorkerFun =
      fun() ->
              Res =
  
negative.code:             gen_fsm:sync_send_event(?MODULE, {repair_result, Res}, infinity)
      end,
      Mon = monitor(process, spawn_link(WorkerFun)),
      {next_state, wait_for_repair, State#state{worker_monitor=Mon,
                                               aae_pid_timer=undefined}}.
  
  add_result(Result, State=#state{remaining=[Partition|Rem],
                                  results=Results}) ->
      State#state{remaining=Rem, results=[{Partition, Result}|Results]}.
  
  %% @doc Waiting for a partition repair process to finish
  wait_for_repair({lock_acquired, Partition},
  