anchor.diff:      enable_file_popularity(W1, ?SPACE_ID),
       Guid = write_file(W1, SessId, ?FILE_PATH(FileName), Size),
   
  -    % read file on W2 to replicate it
  -    read_file(W2, SessId2, Guid, Size),
  +    ?assertDistribution(W2, SessId2, ?DISTS([DomainP1], [Size]), Guid),
  +    schedule_file_replication(W2, SessId2, Guid, DomainP2),
   
       ?assertDistribution(W1, SessId, ?DISTS([DomainP1, DomainP2], [Size, Size]), Guid),
       ?assertFilesInView(W1, ?SPACE_ID, [Guid]),
  
positive.code: end, __Distributions))).
  
  -define(assertDistribution(Worker, SessionId, ExpectedDistribution, FileGuid),
      ?assertEqual(?normalizeDistribution(ExpectedDistribution), begin
          {ok, __FileBlocks} = lfm_proxy:get_file_distribution(Worker, SessionId, {guid, FileGuid}),
          lists:sort(__FileBlocks)
      end, ?ATTEMPTS)
  ).
  
  -define(assertFilesInView(Worker, SpaceId, ExpectedGuids),
      ?assertMatch([], begin
  
negative.code:     enable_file_popularity(W1, ?SPACE_ID),
      Guid = write_file(W1, SessId, ?FILE_PATH(FileName), Size),
  
      % replicate file to W2
      ?assertDistribution(W2, SessId2, ?DISTS([DomainP1], [Size]), Guid),
      schedule_file_replication(W2, SessId2, Guid, DomainP2),
  
      ?assertDistribution(W1, SessId, ?DISTS([DomainP1, DomainP2], [Size, Size]), Guid),
      ?assertFilesInView(W1, ?SPACE_ID, [Guid]),
  