anchor.diff:      T1State =
           lists:foldl(
             fun(X, AccState) ->
  -                  DB = get_prbr_state(AccState, X),
  +                  DB = get(AccState, X),
                     TDB = db_prbr:stop_record_changes(DB, MovingInterval),
                     XDB =
                         if Remove -> db_prbr:delete_entries(TDB, MovingInterval);
  
positive.code: 
  -spec new(?RT:external_rt(), RMState::rm_loop:state(), db_dht:db()) -> state().
  new(RT, RMState, DB) ->
      #state{rt = RT,
             rm_state = RMState,
             join_time = os:timestamp(),
  
negative.code:           }.
  
  -spec new_on_recover(?RT:external_rt(), RMState::rm_loop:state(), 
                       PRBR_KV_DB::prbr:state(),
                       TXID_DBs::list(prbr:state()),
                       Lease_DBs::list(prbr:state()),
                       LeaseList::lease_list:lease_list()) -> state().
  new_on_recover(RT, RMState, 
                 PRBR_KV_DB,
                 TXID_DBs,
                 Lease_DBs,
                 LeaseList) ->
      #state{rt = RT,
             rm_state = RMState,
  