anchor.diff:       GLocalLearner  :: comm:mypid(),
        %% reference counting on subscriptions inside RTMs
        Subs           :: [{comm:mypid(), non_neg_integer()}],
  -     OpenTxNum      :: non_neg_integer(),
  -     QueuedMessages :: msg_queue:msg_queue()}.
  +     OpenTxNum      :: non_neg_integer()}.
   
   %% initialize: return initial state.
   -spec init([]) -> state() | {'$gen_component', [{on_handler, on_init},...],
  
positive.code: on_init({tx_tm_rtm_commit, _Client, _ClientsID, _TransLog} = Msg, State) ->
      %% only in tx_tm
      tx_tm = state_get_role(State),
      QueuedMessages = state_get_qmsg(State),
      NewQueuedMessages = msg_queue:add(QueuedMessages, Msg),
      state_set_qmsg(State, NewQueuedMessages);
  
  on_init({crash, _Pid} = Msg, State) ->
      %% only in tx_tm
  
negative.code:     case lists:keymember(unknown, 2, NewRTMs) of %% filled all entries?
          false ->
              rtms_of_same_dht_node(NewRTMs),
              gen_component:change_handler(state_set_RTMs(State, NewRTMs), on);
          _ -> state_set_RTMs(State, NewRTMs)
      end;
  
  