anchor.diff:  -spec on(message(), state()) -> state().
   on({get_state_response, MyI}, State = 
          #rr_recon_state{ stage = req_shared_interval,
  -                        master = true,
  +                        initiator = true,
                           stats = Stats,
                           method = Method,
                           dest_key = DestKey,
  
positive.code:     MyIntersec = find_intersection(MyI, DestI),
      case intervals:is_subset(MyIntersec, MyI) and not intervals:is_empty(MyIntersec) of
          false ->
              comm:send_local(self(), {shutdown, negotiate_interval_master}),
              DestReconPid =/= undefined andalso
                  comm:send(DestReconPid, {shutdown, no_interval_intersection});
          true ->
  
negative.code: 
  on({shutdown, Reason}, #rr_recon_state{ ownerLocalPid = Owner, 
                                          stats = Stats,
                                          initiator = Initiator }) ->
      ?TRACE("SHUTDOWN Round=~p Reason=~p", [rr_recon_stats:get(round, Stats), Reason]),
      NewStats = rr_recon_stats:set([{finish, Reason =:= sync_finished}], Stats),
      comm:send_local(Owner, {recon_progress_report, self(), Initiator, NewStats}),
      kill;
  
  %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  