anchor.diff:  
   -spec on_init_TP({tx_state:tx_id(),
                     [comm:mypid()], comm:mypid(),
  -                  any(),
  +                  tx_tlog:tlog_entry(),
                     tx_item_state:tx_item_id(),
                     tx_item_state:paxos_id()},
                     dht_node_state:state()) -> dht_node_state:state().
  
positive.code: 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),
      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,
                    [DB, RTLogEntry, OwnProposal]);
          false ->
              %% forward commit to now responsible node
  
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) ->
  