anchor.diff:              ok
       end.
   
  +change_owner_pids(DHTNodes) ->
  +    Self = comm:this(),
  +    F = fun(State) ->
  +                change_owner_pid(Self, State, leases_1, lease_db1),
  +                change_owner_pid(Self, State, leases_2, lease_db2),
  +                change_owner_pid(Self, State, leases_3, lease_db3),
  +                change_owner_pid(Self, State, leases_4, lease_db4),
  +                State
  +        end,
  +    lists:foreach(fun (Node) ->
  +                          comm:send_local(Node, {set_state, comm:this(), F}),
  +                          receive
  +                              {set_state_response, _NewState} ->
  +                                  ok
  +                          end
  +                  end, DHTNodes).
  +    
   
   %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
   %
  
positive.code: 
      generic_crash_recovery_test(F, 4).
  
  
  %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  %
  
negative.code: %
  %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  
  change_owner_pid(Pid, State, DBName, _PRBRName) ->
      LeaseDB = dht_node_state:get_prbr_state(State, DBName),
      ct:pal("LeaseDB ~p", [LeaseDB]),
      [ 
        prbr:set_entry({Key, 
                        {ReadRound, ReadClientId, ReadWriteFilter}, 
                        {WriteRound, WriteClientId, WriteWriteFilter}, 
                        l_on_cseq:set_owner(Lease, Pid)}, LeaseDB)
  
        || {Key, 
            {ReadRound, ReadClientId, ReadWriteFilter}, 
            {WriteRound, WriteClientId, WriteWriteFilter},
            Lease} 
               <- prbr:tab2list_raw_unittest(LeaseDB)],
      ok.
  
  
  reset_read_and_write_rounds(State, DBName, _PRBRName) ->
      LeaseDB = dht_node_state:get_prbr_state(State, DBName),
      ct:pal("LeaseDB ~p", [LeaseDB]),
      [ 
  