anchor.diff:  % Message handling
   %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
   -spec on(message(), state()) -> state() | kill.
  -on({get_state_response, MyI}, State = 
  +on({get_state_response, MyI} = _Msg, State = 
          #rr_recon_state{ stage = req_shared_interval,
                           initiator = false,
                           method = Method,
                           struct = Params,
                           dhtNodePid = DhtPid,
                           dest_rr_pid = DestRRPid }) ->
  +    ?TRACE1(_Msg, State),
       % target node got sync request, asked for its interval
       % struct contains the interval of the initiator
       % -> client creates recon structure based on common interval, sends it to initiator
  
positive.code: fork_recon(Conf) ->
      NStats = rr_recon_stats:set([{session_id, null}], Conf#rr_recon_state.stats),
      State = Conf#rr_recon_state{ stats = NStats },
      comm:send_local(Conf#rr_recon_state.ownerPid, {recon_forked}),
      gen_component:start_link(?MODULE, fun ?MODULE:on/2, State, []).
  
  %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  
negative.code:     is_subtype(MaxItems,    pos_integer() | all).
  send_chunk_req(DhtPid, SrcPid, I, DestI, MaxItems) ->
      SrcPidReply = comm:reply_as(SrcPid, 4, {rr_recon, data, DestI, '_'}),
      send_local(
        DhtPid,
        {get_chunk, SrcPidReply, I, fun get_chunk_filter/1, fun get_chunk_value/1,
         MaxItems}).
  