anchor.diff:                  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),            
  +            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()]),
  
positive.code:                     ?TRACE("~p tx_tp:update_db_or_forward db: ~p~n",[comm:this(),Res]),
                      ?TRACE("~p tx_tp:update_db_or_forward db data: ~p~n",[comm:this(),?DB:get_data(Res)]),
                      ?TRACE("~p tx_tp:update_db_or_forward snapshot data: ~p~n",[comm:this(),?DB:get_snapshot_data(Res)]);
                  _ ->                    
                      ok
              end,
              Res;
  
negative.code:                   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}, DHT_Node_State) ->
      %?TRACE("tx_tp:on_init_TP({..., ...})~n", []),
      %% validate locally via callback
      DB = dht_node_state:get(DHT_Node_State, db),
  