anchor.diff:           reply_to,
            early_reply,
            aae_pid_req_id :: pid() | undefined,
  +         aae_pid_timer :: reference() | undefined,
            worker_monitor :: reference() | undefined,
            worker_status :: worker_status(),
            index_scan_count = 0 :: integer(),
  
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:             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},
  