diff options
| author | Jean-Sébastien Pédron <jean-sebastien.pedron@dumbbell.fr> | 2016-01-27 09:08:19 +0100 |
|---|---|---|
| committer | Jean-Sébastien Pédron <jean-sebastien.pedron@dumbbell.fr> | 2016-01-27 09:08:19 +0100 |
| commit | 44cd71d1a4eefdb3607a01d183908aec6cffc8cb (patch) | |
| tree | 74d0a695235749b1a0d22e9645d1e9cb7230047e /src | |
| parent | 9b96066d598c3aef947d13da916536e338dbe891 (diff) | |
| parent | cc2f0d2951a622986fa7ad6d028f29d9b8fa02d9 (diff) | |
| download | rabbitmq-server-git-44cd71d1a4eefdb3607a01d183908aec6cffc8cb.tar.gz | |
Merge pull request #535 from rabbitmq/rabbitmq-server-307
Ignore duplicate down_from_ch
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index 225c21dd54..9edb99c4d7 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -741,6 +741,7 @@ confirm_sender_death(Pid) -> forget_sender(_, running) -> false; forget_sender(down_from_gm, down_from_gm) -> false; %% [1] +forget_sender(down_from_ch, down_from_ch) -> false; forget_sender(Down1, Down2) when Down1 =/= Down2 -> true. %% [1] If another slave goes through confirm_sender_death/1 before we |