Skip to content

Commit 6712c60

Browse files
author
Emile Joubert
committed
Merged bug25849 into stable
2 parents 7987ede + 0abea4c commit 6712c60

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

src/rabbit_mirror_queue_slave.erl

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -672,8 +672,13 @@ confirm_sender_death(Pid) ->
672672
ok.
673673

674674
forget_sender(_, running) -> false;
675+
forget_sender(down_from_gm, down_from_gm) -> false; %% [1]
675676
forget_sender(Down1, Down2) when Down1 =/= Down2 -> true.
676677

678+
%% [1] If another slave goes through confirm_sender_death/1 before we
679+
%% do we can get two GM sender_death messages in a row for the same
680+
%% channel - don't treat that as anything special.
681+
677682
%% Record and process lifetime events from channels. Forget all about a channel
678683
%% only when down notifications are received from both the channel and from gm.
679684
maybe_forget_sender(ChPid, ChState, State = #state { sender_queues = SQ,

0 commit comments

Comments
 (0)