anchor.diff:      Guid = write_file(W2, SessId2, ?FILE_PATH(FileName), Size),
   
       % read file on W1 to replicate it
  +    ?assertDistribution(W1, SessId, ?DISTS([DomainP2], [Size]), Guid),
       read_file(W1, SessId, Guid, Size),
   
       ?assertDistribution(W1, SessId, ?DISTS([DomainP1, DomainP2], [0, Size]), Guid),
  
positive.code: end, __Distributions))).
  
  -define(assertDistribution(Worker, SessionId, ExpectedDistribution, FileGuid),
      ?assertEqual(?normalizeDistribution(ExpectedDistribution), try
          {ok, __FileBlocks} = lfm_proxy:get_file_distribution(Worker, SessionId, {guid, FileGuid}),
          lists:sort(__FileBlocks)
      catch
          _:_ ->
              error
      end, ?ATTEMPTS)).
  
  -define(assertFilesInView(Worker, SpaceId, ExpectedGuids),
      ?assertMatch([], begin
  
negative.code:             max_monthly_moving_average => ?RULE_SETTING(1)
      }}),
  
      ?assertDistribution(W1, SessId, ?DISTS([DomainP2], [Size]), Guid),
      % read file to be replicated and leave it opened
      {ok, H} = ?assertMatch({ok, _}, lfm_proxy:open(W1, SessId, {guid, Guid}, read), ?ATTEMPTS),
      {ok, _} = ?assertMatch({ok, _}, lfm_proxy:read(W1, H, 0, Size), ?ATTEMPTS),
  