anchor.diff:  update_db_or_forward(RTLogEntry, Result, OwnProposal, DHT_Node_State) ->
       %% Check for DB responsibility:
       DB = dht_node_state:get(DHT_Node_State, db),
  -    Key = element(2, RTLogEntry),
  +    Key = tx_tlog:get_entry_key(RTLogEntry),
       case dht_node_state:is_db_responsible(Key, DHT_Node_State) of
           true ->
  -            %% call operation:Result={commit|abort} on DB
  -            apply(element(1, RTLogEntry), Result,
  +            apply(tx_tlog:get_entry_operation(RTLogEntry), Result,
                     [DB, RTLogEntry, OwnProposal]);
           false ->
               %% forward commit to now responsible node
  
positive.code:     %% (optimized: embed the proposer's accept message in registerTP message)
      dht_node_state:set_db(DHT_Node_State, NewDB).
  
  -spec on_tx_commitreply(tuple(), commit | abort, dht_node_state:state())
                         -> dht_node_state:state().
  on_tx_commitreply({PaxosId, RTLogEntry}, Result, DHT_Node_State) ->
      ?TRACE("tx_tp:on_tx_commitreply({, ...})~n", []),
  
negative.code:     pdb:delete(PaxosId, TP_DB),
      dht_node_state:set_db(DHT_Node_State, NewDB).
  
  -spec on_tx_commitreply_fwd(tx_tlog:tlog_entry(),
                              commit | abort, commit | abort,
                              dht_node_state:state())
                             -> dht_node_state:state().
  on_tx_commitreply_fwd(RTLogEntry, Result, OwnProposal, DHT_Node_State) ->
  