anchor.diff:      fun
           (expected_failure, #api_test_ctx{env = #{files_to_transfer := FilesToTransfer, other_files := OtherFiles}}) ->
               Files = FilesToTransfer ++ OtherFiles,
  -            assert_distribution(Node, SessId, ?BYTES_NUM, [SrcProvider], Files),
  +            assert_distribution(Node, SessId, Files, [{SrcProvider, ?BYTES_NUM}]),
               true;
           (expected_success, #api_test_ctx{env = #{files_to_transfer := FilesToTransfer, other_files := OtherFiles}}) ->
  -            assert_distribution(Node, SessId, ?BYTES_NUM, [SrcProvider], OtherFiles),
  -            assert_distribution(Node, SessId, ?BYTES_NUM, [SrcProvider, DstProvider], FilesToTransfer),
  +            assert_distribution(Node, SessId, OtherFiles, [{SrcProvider, ?BYTES_NUM}]),
  +            assert_distribution(
  +                Node, SessId, FilesToTransfer,
  +                [{SrcProvider, ?BYTES_NUM}, {DstProvider, ?BYTES_NUM}]
  +            ),
               true
       end.
   
   
   %% @private
   create_verify_eviction_env(Node, UserId, SrcProvider, DstProvider, Config) ->
  +    SessId = ?SESS_ID(UserId, Node, Config),
  +
  +    fun
  +        (expected_failure, #api_test_ctx{env = #{files_to_transfer := FilesToTransfer, other_files := OtherFiles}}) ->
  +            assert_distribution(Node, SessId, OtherFiles, [{SrcProvider, ?BYTES_NUM}]),
  +            assert_distribution(
  +                Node, SessId, FilesToTransfer,
  +                [{SrcProvider, ?BYTES_NUM}, {DstProvider, ?BYTES_NUM}]
  +            ),
  +            true;
  +        (expected_success, #api_test_ctx{env = #{files_to_transfer := FilesToTransfer, other_files := OtherFiles}}) ->
  +            assert_distribution(Node, SessId, OtherFiles, [{SrcProvider, ?BYTES_NUM}]),
  +            assert_distribution(
  +                Node, SessId, FilesToTransfer,
  +                [{SrcProvider, 0}, {DstProvider, ?BYTES_NUM}]
  +            ),
  +            true
  +    end.
  +
  +
  +%% @private
  +create_verify_migration_env(Node, UserId, SrcProvider, DstProvider, Config) ->
       SessId = ?SESS_ID(UserId, Node, Config),
   
       fun
           (expected_failure, #api_test_ctx{env = #{files_to_transfer := FilesToTransfer, other_files := OtherFiles}}) ->
               Files = FilesToTransfer ++ OtherFiles,
  -            assert_distribution(Node, SessId, ?BYTES_NUM, [SrcProvider, DstProvider], Files),
  +            assert_distribution(Node, SessId, Files, [{SrcProvider, ?BYTES_NUM}]),
               true;
           (expected_success, #api_test_ctx{env = #{files_to_transfer := FilesToTransfer, other_files := OtherFiles}}) ->
  -            assert_distribution(Node, SessId, ?BYTES_NUM, [SrcProvider, DstProvider], OtherFiles),
  -            assert_distribution(Node, SessId, ?BYTES_NUM, [DstProvider], FilesToTransfer),
  -            true
  -    end.
  -
  -
  -%% @private
  -create_verify_migration_env(Node, UserId, SrcProvider, DstProvider, Config) ->
  -    SessId = ?SESS_ID(UserId, Node, Config),
  -
  -    fun
  -        (expected_failure, #api_test_ctx{env = #{files_to_transfer := FilesToTransfer, other_files := OtherFiles}}) ->
  -            Files = FilesToTransfer ++ OtherFiles,
  -            assert_distribution(Node, SessId, ?BYTES_NUM, [SrcProvider], Files),
  -            true;
  -        (expected_success, #api_test_ctx{env = #{files_to_transfer := FilesToTransfer, other_files := OtherFiles}}) ->
  -            assert_distribution(Node, SessId, ?BYTES_NUM, [SrcProvider], OtherFiles),
  -            assert_distribution(Node, SessId, ?BYTES_NUM, [DstProvider], FilesToTransfer),
  +            assert_distribution(Node, SessId, OtherFiles, [{SrcProvider, ?BYTES_NUM}]),
  +            assert_distribution(
  +                Node, SessId, FilesToTransfer,
  +                [{SrcProvider, 0}, {DstProvider, ?BYTES_NUM}]
  +            ),
               true
       end.
   
  
positive.code:             error -> {ValidId, Data0}
          end,
          #gs_args{
              operation = create,
              gri = #gri{type = op_replica, id = GriId, aspect = Aspect, scope = Scope},
              data = Data3
          }
  
negative.code: 
  -export([
      create_file_replication/1,
  
      create_view_replication/1,
      create_view_eviction/1
  ]).
  
  all() ->
      ?ALL([
          create_file_replication,
  
          create_view_replication,
          create_view_eviction
      ]).
  
  
  