anchor.diff:      DomainP2 = ?GET_DOMAIN_BIN(W2),
       enable_file_popularity(W1, ?SPACE_ID),
       Guid = write_file(W1, SessId, ?FILE_PATH(FileName), Size),
  +    ?assertDistribution(W2, SessId2, ?DISTS([DomainP1], [Size]), Guid),
       % read file on W2 to replicate it
       read_file(W2, SessId2, Guid, Size),
   
  
positive.code:     rpc:call(Worker, autocleaning_api, list_reports, [SpaceId, LinkId, Offset, Limit]).
  
  get_run_report(Worker, ARId) ->
      Result = rpc:call(Worker, autocleaning_api, get_run_report, [ARId]),
      % todo remove this log
      ct:print("Result: ~p", [Result]),
      Result.
  
  delete(Worker, SpaceId, ARId) ->
      rpc:call(Worker, autocleaning_run, delete, [ARId, SpaceId]).
  
negative.code:     end, lists:seq(1, Num)).
  
  read_file(Worker, SessId, Guid, Size) ->
      ?assertEqual(Size, try
          {ok, H} = lfm_proxy:open(Worker, SessId, {guid, Guid}, read),
          {ok, Data} = lfm_proxy:read(Worker, H, 0, Size),
          ok = lfm_proxy:close(Worker, H),
          byte_size(Data)
      catch
          _:_ ->
              error
      end, ?ATTEMPTS).
  
  schedule_file_replication(Worker, SessId, Guid, ProviderId) ->
      ?assertMatch({ok, _}, lfm_proxy:stat(Worker, SessId, {guid, Guid}), ?ATTEMPTS),
  