anchor.diff:                api_dht_raw:unreliable_lookup(Key, {get_rtm, This, Key, Name})
             end
             || RTM <- RTMs],
  -    msg_delay:send_trigger(Delay, %config:read(tx_rtm_update_interval) div 1000,
  -                           TriggerMsg),
       ok.
   
   %% functions for tx processing
  
positive.code:     handle_crash(Pid, State, on_init).
  
  %% functions for periodic RTM updates
  -spec rtm_update(rtms(), pos_integer(), {update_RTMs} | {update_RTMs_on_init}) -> ok.
  rtm_update(RTMs, Delay, TriggerMsg) ->
      This = comm:this(),
      _ = [ begin
                Name = get_nth_rtm_name(get_nth(RTM)),
  
negative.code:                   {[rtm_entry_new(X, unknown, I, unknown) | Acc ], I - 1}
                  end,
                  {[], length(RTM_ids) - 1}, RTM_ids),
      rtm_update_once(NewRTMs),
      state_set_RTMs(State, NewRTMs);
  
  on_init({update_RTMs}, State) ->
      %% only in tx_tm not in rtm processes!
      ?DBG_ASSERT(tx_tm =:= state_get_role(State)),
      rtm_update_trigger(state_get_RTMs(State)),
      State;
  on_init({update_RTMs_on_init}, State) ->
      ?TRACE_RTM_MGMT("tx_tm_rtm:on_init:update_RTMs in Pid ~p ~n", [self()]),
      %% only in tx_tm not in rtm processes!
      ?DBG_ASSERT(tx_tm =:= state_get_role(State)),
      rtm_update_once(state_get_RTMs(State)),
      msg_delay:send_trigger(1, {update_RTMs_on_init}),
      State;
  
  on_init({get_rtm_reply, InKey, InPid, InAcceptor}, State) ->
  