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 warning

This commit is contained in:
Loïc Hoguin 2022-05-19 09:18:28 +02:00
parent d576ca9f8b
commit de93e89eb2
No known key found for this signature in database
GPG Key ID: C69E26E3A9DF618F
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
deps/rabbit/src/rabbit_variable_queue.erl vendored
View File

@ -1974,7 +1974,7 @@ count_pending_acks(#vqstate { ram_pending_ack = RPA,
gb_trees:size(RPA) + gb_trees:size(DPA) + gb_trees:size(QPA).
%% @todo This should set the out rate to infinity temporarily while we drop deltas.
purge_betas_and_deltas(DelsAndAcksFun, State = #vqstate { mode = Mode }) ->
purge_betas_and_deltas(DelsAndAcksFun, State) ->
State0 = #vqstate { q3 = Q3 } = maybe_deltas_to_betas(DelsAndAcksFun, State),
case ?QUEUE:is_empty(Q3) of