anchor.diff:      % disable op_worker healthcheck in onepanel, so nodes are not started up automatically
       onenv_test_utils:disable_panel_healthcheck(Config),
   
  +    % Create test files
       Files1 = file_ops_test_utils:create_files(WorkerP1, SessIdP1, SpaceGuid, FilesCount),
       Files2 = file_ops_test_utils:create_files(WorkerP1, SessIdP1, SpaceGuid, FilesCount),
       AllFiles = Files1 ++ Files2,
   
  +    % Wait until dbsync synchronizes all files
       lists:foreach(fun(File) ->
           ?assertMatch({ok, #file_attr{type = ?REGULAR_FILE_TYPE, size = FileSize}},
               lfm_proxy:stat(WorkerP2, SessIdP2, {guid, File}), Attempts)
       end, AllFiles),
   
  +    % Schedule on_the_fly blocks replications
       lists_utils:pforeach(fun(File) ->
           FileCtx = file_ctx:new_by_guid(File),
           lists:foreach(fun(Offset) ->
  
positive.code: 
  get_transfer_links_from_db(Prefix, SpaceId, Acc0) ->
      Ctx = #{model => transfer, memory_driver => undefined},
      datastore_model:fold_links(Ctx, <<Prefix/binary, "_", SpaceId/binary>>, all, fun
          (#link{target = TransferId}, Acc) ->
              {ok, sets:add_element(TransferId, Acc)}
      end, Acc0, #{}).
negative.code: 
  -export([
      rtransfer_restart_test/1,
      node_gentle_restart_test/1,
      node_kill_test/1
  ]).
  
  % For RPC
  -export([count_missing_transfer_links_in_db/2, get_transfer_links/4]).
  
  all() -> [
      rtransfer_restart_test,
      node_gentle_restart_test,
      node_kill_test
  ].
  
  -define(FILE_DATA, <<"1234567890abcd">>).
  