anchor.diff:  
   -type request() :: 
       {start, method(), DestKey::recon_dest()} |
  -    {continue, method(), stage(), struct(), Master::boolean()}.          
  +    {continue, method(), stage(), struct(), Initiator::boolean()}.          
   
   -type message() ::          
       %API
       request() |
       %tree sync msgs
  -    {check_node, MasterPid::comm:mypid(), intervals:interval(), merkle_tree:mt_node_key()} |
  +    {check_node, InitiatorPid::comm:mypid(), intervals:interval(), merkle_tree:mt_node_key()} |
       {check_node_response, tree_cmp_response(), intervals:interval(), [merkle_tree:mt_node_key()]} |
       %dht node response
       {get_state_response, intervals:interval()} |
  
positive.code:          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_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
           struct             = {}                                        :: struct() | {},
           stage              = req_shared_interval                       :: stage(),
           master             = false                                     :: boolean(),               %true if process is recon leader/initiators         
           stats              = rr_recon_stats:new()                      :: rr_recon_stats:stats()
           }).
  -type state() :: #rr_recon_state{}.
  
negative.code: -spec on(message(), state()) -> state().
  on({get_state_response, MyI}, State = 
         #rr_recon_state{ stage = req_shared_interval,
                          initiator = true,
                          stats = Stats,
                          method = Method,
                          dest_key = DestKey,
  