anchor.diff:      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.
   
  
positive.code:                     [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),
  
      TransferIDs = lists:map(fun(Ans) ->
          {ok, TransferID} = ?assertMatch({ok, _}, Ans),
  
negative.code:         ct:pal("Rtransfer restarted")
      end,
  
      restart_test_base(Config, RestartFun, false).
  
  % TODO - delete fun
  rtransfer_restart_test2(Config) ->
  