anchor.diff:  
   on({shutdown, Reason}, #rr_recon_state{ ownerLocalPid = Owner, 
                                           stats = Stats,
  -                                        master = Master }) ->
  +                                        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(), Master, NewStats}),
  +    comm:send_local(Owner, {recon_progress_report, self(), Initiator, NewStats}),
       kill;
   
   %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  
positive.code: 
  -type request() :: 
      {start, method(), DestKey::recon_dest()} |
      {continue, method(), stage(), struct(), Master::boolean()}.          
  
  -type message() ::          
      %API
      request() |
      %tree sync msgs
      {check_node, MasterPid::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()} |
  
negative.code:             Stats;
          art ->
              {AOk, ARStats} = 
                  case Initiator of
                      true -> art_recon(SyncStruct, proplists:get_value(art, Params), State);                    
                      false ->
                          ArtParams = [{interval, art:get_interval(SyncStruct)},
  