anchor.diff:      process_flag(trap_exit, true),
       lager:info("Starting 2i repair at speed ~p for partitions ~p",
                  [Speed, Partitions]),
  -    {ok, next_partition, #state{partitions=Partitions, remaining=Partitions,
  -                                speed=Speed, caller=Caller}, 0}.
  +    {ok, first_partition, #state{partitions=Partitions, remaining=Partitions,
  +                                 speed=Speed, caller=Caller}, 0}.
   
   %% @doc Notifies caller for certain cases involving a single partition
   %% so the user sees an error condition from the command line.
  
positive.code:             State
      end,
      demonitor(Mon, [flush]),
      {reply, ok, next_partition,
       State2#state{remaining=Rem,
                    results=[{Partition, Res}|Results],
                    worker_monitor=undefined,
                    worker_status=starting,
                    index_scan_count=0,
                    hashtree_population_count=0,
                    exchange_count=0},
       0}.
  
  %% @doc Process async worker status updates during a repair
  wait_for_repair({index_scan_update, Count}, State) ->
  
negative.code: 
  -export([start/2, stop/1, get_status/0, to_report/1]).
  
  -export([first_partition/2, wait_for_aae_pid/2, wait_for_repair/3,
           wait_for_repair/2]).
  
  %% gen_fsm callbacks
  