anchor.diff:             end,
       ?TRACE("START_TO_DEST ~p", [DestKey]),
       comm:send_local(DhtPid, {?lookup_aux, DKey, 0, Msg}),    
  -    comm:send_local(self(), {shutdown, negotiate_interval_master}),
  +    comm:send_local(self(), {shutdown, negotiate_interval_initiator}),
       State;
   
   on({get_state_response, MyI}, State = 
          #rr_recon_state{ stage = req_shared_interval,
  -                        master = false,
  +                        initiator = false,
                           method = Method,
                           struct = Params,                        
                           dhtNodePid = DhtPid,
  
positive.code:     State#rr_recon_state{ struct = {},
                            method = Method,
                            dest_key = DestKey,
                            master = true };
  
  on({continue, Method, Stage, Struct, Master}, State) ->
      comm:send_local(State#rr_recon_state.dhtNodePid, {get_state, comm:this(), my_range}),
      State#rr_recon_state{ stage = Stage, 
                            struct = Struct,
                            method = Method,
                            master = Master orelse Stage =:= res_shared_interval };
  
  on({crash, Pid}, State) ->
      comm:send_local(self(), {shutdown, {fail, crash_of_recon_node, Pid}}),
  
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;
  
  %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  