anchor.diff:  	{continue_recon, SenderRRPid::comm:mypid(), session_id() | null, ReqMsg::rr_recon:request()} |
       {request_resolve, session_id() | null, rr_resolve:operation(), rr_resolve:options()} |
       {recon_forked} |
  -    {request_sync_complete, session()} |
       % misc
       {web_debug_info, Requestor::comm:erl_local_pid()} |
       % rr statistics
  
positive.code:     Merge = rr_resolve:merge_stats(Old, New),
      S#session{ rs_stats = Merge, rs_finish = RSCount + 1 }.
  
  -spec check_session_complete(session()) -> ok.
  check_session_complete(#session{ rc_stats = RCStats,
                                   rs_called = C, rs_finish = C } = S) 
    when RCStats =/= none->
      case rr_recon_stats:get(status, RCStats) of
          X when X =:= finish orelse X =:= abort ->
              comm:send_local(self(), {request_sync_complete, S});
          wait -> ok
      end;
  check_session_complete(_Session) ->
      ok.
  
  %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  % Startup
  
negative.code: on({recon_forked}, State) ->
      State#rrepair_state{ open_recon = State#rrepair_state.open_recon + 1 };
  
  %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  
  on({rr_stats, Msg}, State) ->
  