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:                         method = RMethod,        
                          struct = Params,                    
                          dhtNodePid = DhtNodePid,
                          master = SyncMaster,
                          stats = Stats }) ->
      SyncI = proplists:get_value(interval, Params),    
      ToBuild = ?IIF(RMethod =:= art, ?IIF(SyncMaster, merkle_tree, art), RMethod),
      {BuildTime, SyncStruct} =
          case merkle_tree:is_merkle_tree(Params) of
              true ->
  
negative.code:                                                 ownerRemotePid = OwnerPid,
                                                  dest_recon_pid = DestReconPid,
                                                  dest_rr_pid = DestRRPid,                                       
                                                  initiator = Initiator, 
                                                  stats = Stats }) ->
      ?TRACE("BEGIN SYNC", []),
      Round = rr_recon_stats:get(round, Stats),
      case Method of
          merkle_tree -> 
              case Initiator of
                  true -> comm:send(DestReconPid, 
                                    {check_node, comm:this(), 
                                     merkle_tree:get_interval(SyncStruct), 
  