anchor.diff:                    dht_node_state:state()) -> dht_node_state:state().
   %% messages handled in dht_node context:
   %% PreCond: check for DB responsibility must still be valid (ref. lookup_fin handling)
  -on_init_TP({Tid, RTMs, Accs, TM, RTLogEntry, ItemId, PaxId, _SnapNo} = Params, DHT_Node_State) ->
  +on_init_TP({Tid, RTMs, Accs, TM, RTLogEntry, ItemId, PaxId, _SnapNo}, DHT_Node_State) ->
       %?TRACE("tx_tp:on_init_TP({..., ...})~n", []),
       %% validate locally via callback
       DB = dht_node_state:get(DHT_Node_State, db),
  
positive.code:                 end,
              comm:send(TM, {?tp_committed, TMItemId}),
              % check if snapshot is running and if so, if it's already done
              SnapState = dht_node_state:get(DHT_Node_State, snapshot_state),            
              case {snapshot_state:is_in_progress(SnapState),?DB:snapshot_is_running(Res),?DB:snapshot_is_lockfree(Res)} of
                  {true,true,true} ->
                      ?TRACE("~p tx_tp:update_db_or_forward snapshot is finally done~n",[comm:this()]),
  
negative.code: %% @copyright 2009-2013 Zuse Institute Berlin
  
  %   Licensed under the Apache License, Version 2.0 (the "License");
  %   you may not use this file except in compliance with the License.
  