Skip to content

Commit

Permalink
Merged bug25849 into stable
Browse files Browse the repository at this point in the history
  • Loading branch information
Emile Joubert committed Nov 1, 2013
2 parents 7987ede + 0abea4c commit 6712c60
Showing 1 changed file with 5 additions and 0 deletions.
5 changes: 5 additions & 0 deletions src/rabbit_mirror_queue_slave.erl
Original file line number Diff line number Diff line change
Expand Up @@ -672,8 +672,13 @@ confirm_sender_death(Pid) ->
ok.

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

%% [1] If another slave goes through confirm_sender_death/1 before we
%% do we can get two GM sender_death messages in a row for the same
%% channel - don't treat that as anything special.

%% Record and process lifetime events from channels. Forget all about a channel
%% only when down notifications are received from both the channel and from gm.
maybe_forget_sender(ChPid, ChState, State = #state { sender_queues = SQ,
Expand Down

0 comments on commit 6712c60

Please sign in to comment.