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

Rename function for clarity 

References #3753
This commit is contained in:
Arnaud Cogoluègnes 2022-04-07 09:34:18 +02:00
parent 8ccdd7b6f7
commit 68e8ae8673
No known key found for this signature in database
GPG Key ID: D5C8C4DFAD43AFA8
2 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
deps/rabbit/src/rabbit_stream_sac_coordinator.erl vendored
View File

@ -199,7 +199,6 @@ apply({register_consumer,
Owner,
SubscriptionId},
#?MODULE{groups = StreamGroups0} = State) ->
%% FIXME monitor virtual hosts as well?
rabbit_log:debug("New consumer ~p ~p in group ~p, partition index "
"is ~p",
[ConnectionPid,
@ -444,7 +443,10 @@ handle_connection_down(Pid,
undefined -> {S0, Eff0};
#group{consumers = Consumers} ->
%% iterate over the consumers of the group
%% and unregister the ones from this PID
%% and unregister the ones from this PID.
%% It may not be optimal, computing the new active consumer
%% from the purged group and notifying the remaining consumers
%% appropriately should avoid unwanted notifications and even rebalancing.
lists:foldl(fun (#consumer{pid = P,
subscription_id =
SubId},

6
deps/rabbitmq_stream/src/rabbit_stream_reader.erl vendored
View File

@ -818,7 +818,7 @@ open(info,
log = Log1},
Conn1 =
maybe_notify_consumer(Transport,
maybe_send_consumer_update(Transport,
Connection0,
SubId,
Active,
@ -2774,9 +2774,9 @@ maybe_register_consumer(VirtualHost,
SubscriptionId),
Active.
maybe_notify_consumer(_, Connection, _, _, false = _Sac, _) ->
maybe_send_consumer_update(_, Connection, _, _, false = _Sac, _) ->
Connection;
maybe_notify_consumer(Transport,
maybe_send_consumer_update(Transport,
#stream_connection{socket = S,
correlation_id_sequence = CorrIdSeq,
outstanding_requests =