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:     Workers = test_config:get_all_op_worker_nodes(Config),
      test_utils:set_env(Workers, ?APP_NAME, minimal_sync_request, 1),
      test_utils:set_env(Workers, ?APP_NAME, synchronizer_block_suiting, false),
      lfm_proxy:init(Config, false).
  
  
  end_per_testcase(_Case, Config) ->
      lfm_proxy:teardown(Config),
      Config.
  
  end_per_suite(_Config) ->
      ok.
negative.code:     SessId = fun(P) -> test_config:get_user_session_id_on_provider(Config, User1, P) end,
      SessIdP1 = SessId(P1),
      SessIdP2 = SessId(P2),
      Attempts = 60,
      FileSize = byte_size(?FILE_DATA),
      Priority = 32,
      UserCtxP2 = rpc:call(WorkerP2, user_ctx, new, [SessIdP2]),
  