anchor.diff:                      [UserCtxP2, FileCtx, #file_block{offset = Offset, size = 1}, false, undefined, Priority]))
           end, lists:seq(0,9)),
           rpc:call(WorkerP2, lfm, schedule_file_replication, [SessIdP2, {guid, File}, P2, undefined])
  -    end, Files),
  +    end, Files2),
   
       TransferIDs = lists:map(fun(Ans) ->
           {ok, TransferID} = ?assertMatch({ok, _}, Ans),
  
positive.code:         ct:pal("Node restarted")
      end,
  
      restart_test_base(Config, RestartFun).
  
  % TODO - delete fun
  node_restart_test2(Config) ->
      NewConfig = provider_onenv_test_utils:initialize(Config),
      node_restart_test(NewConfig).
  
  restart_test_base(Config, RestartFun) ->
      [P1, P2] = test_config:get_providers(Config),
      [WorkerP1] = test_config:get_provider_nodes(Config, P1),
      [WorkerP2] = test_config:get_provider_nodes(Config, P2),
  
negative.code:     lists:foreach(fun(TransferId) ->
          multi_provider_file_ops_test_base:await_replication_end(WorkerP2, TransferId, Attempts, get_effective)
      end, TransferIDs),
  
      FilesToCheckDistribution = case NodeRestart of
          true -> Files2;
          false -> AllFiles
      end,
      lists:foreach(fun(File) ->
          % Use root session as user session is not valid after restart
          ?assertMatch({ok, [
              #{<<"blocks">> := [[0, FileSize]], <<"totalBlocksSize">> := FileSize},
              #{<<"blocks">> := [[0, FileSize]], <<"totalBlocksSize">> := FileSize}
          ]}, rpc:call(WorkerP2, lfm, get_file_distribution, [?ROOT_SESS_ID, {guid, File}]), Attempts)
      end, FilesToCheckDistribution),
  
      ok.
  
  