anchor.diff:           ownerLocalPid      = ?required(rr_recon_state, ownerLocalPid)  :: comm:erl_local_pid(),
            ownerRemotePid     = ?required(rr_recon_state, ownerRemotePid) :: comm:mypid(),
            dhtNodePid         = ?required(rr_recon_state, dhtNodePid)     :: comm:erl_local_pid(),
  -         dest_key           = random                                    :: recon_dest(),             %dest dht node pid
  +         dest_key           = random                                    :: recon_dest(),
            dest_rr_pid        = undefined                                 :: comm:mypid() | undefined, %dest rrepair pid
            dest_recon_pid     = undefined                                 :: comm:mypid() | undefined, %dest recon process pid
  -         method             = undefined                                 :: method(),                 %reconciliation method
  +         method             = undefined                                 :: method(),
            struct             = {}                                        :: struct() | {},
            stage              = req_shared_interval                       :: stage(),
  -         master             = false                                     :: boolean(),               %true if process is recon leader/initiators         
  +         initiator          = false                                     :: boolean(),
            stats              = rr_recon_stats:new()                      :: rr_recon_stats:stats()
            }).
   -type state() :: #rr_recon_state{}.
  
positive.code: -spec on(message(), state()) -> state().
  on({get_state_response, MyI}, State = 
         #rr_recon_state{ stage = req_shared_interval,
                          master = true,
                          stats = Stats,
                          method = Method,
                          dest_key = DestKey,
  
negative.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_initiator}),
              DestReconPid =/= undefined andalso
                  comm:send(DestReconPid, {shutdown, no_interval_intersection});
          true ->
  