anchor.diff:          gen_test_env(Config),
   
       {ok, #file_attr{guid = Guid}} = lfm_proxy:stat(P1, User1, {path, <<"/space4">>}),
  -    
  +
       FileSize = 500*1024*1024, % 500 MB
   
       ProviderId = initializer:domain_to_provider_id(?GET_DOMAIN(P1)),
       % Upload File1 500MB to space4
       do_multipart(P1, User1, 100, 1048576, 5, Guid, File1),
  -    
  +
       {ok, FileHandle} = lfm_proxy:open(P1, User1, f(<<"space4">>, File1), rdwr),
       ok = lfm_proxy:fsync(P1, FileHandle),
       ?assertMatch(FileSize, current_size(P1, <<"space_id4">>)),
  -    
  +
       % Upload File2 800MB to space4
       do_multipart(P1, User1, 160, 1048576, 5, Guid, File2),
       ok = lfm_proxy:fsync(P1, User1, f(<<"space4">>, File2), ProviderId),
  
positive.code: 
      SpaceSize = available_size(SupportingProvider, SpaceId),
      RootGuid = fslogic_uuid:spaceid_to_space_dir_guid(SpaceId),
      
      {ok, {Conn, _}} = fuse_test_utils:connect_via_macaroon(P1, [{active, true}], SessId(P1)),
      SubId = rpc:call(P1, subscription,  generate_id, [<<"quota_exceeded">>]),
      rpc:call(P1, event, subscribe, [#subscription{id = SubId, type = #quota_exceeded_subscription{}}, SessId(P1)]),
  
negative.code: 
  gen_test_env(Config) ->
      Workers = ?config(op_worker_nodes, Config),
      Workers1 = lists:filter(fun(W) ->
          case re:run(atom_to_list(W), "p1") of
              nomatch -> false;
              _ -> true
          end
      end, Workers),
      Workers2 = Workers -- Workers1,
      P1 = lists:last(Workers1),
  