root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Fix channel rate limiter for ack messages

This commit is contained in:
Arnaud Cogoluègnes 2021-07-26 10:12:42 +02:00
parent e610393c0d
commit 4486584166
No known key found for this signature in database
GPG Key ID: D5C8C4DFAD43AFA8
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
deps/rabbit/src/rabbit_channel.erl vendored
View File

@ -2121,13 +2121,13 @@ notify_limiter(Limiter, Acked) ->
%% common case. %% common case.
case rabbit_limiter:is_active(Limiter) of case rabbit_limiter:is_active(Limiter) of
false -> ok; false -> ok;
true -> case lists:foldl(fun ({_, CTag, _, _}, Acc) when is_integer(CTag) -> true -> case lists:foldl(fun (#pending_ack{tag = CTag}, Acc) when is_integer(CTag) ->
%% Quorum queues use integer CTags %% Quorum queues use integer CTags
%% classic queues use binaries %% classic queues use binaries
%% Quorum queues do not interact %% Quorum queues do not interact
%% with limiters %% with limiters
Acc; Acc;
({_, _, _, _}, Acc) -> Acc + 1 (_, Acc) -> Acc + 1
end, 0, Acked) of end, 0, Acked) of
0 -> ok; 0 -> ok;
Count -> rabbit_limiter:ack(Limiter, Count) Count -> rabbit_limiter:ack(Limiter, Count)