diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2014-04-14 23:08:39 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2014-04-14 23:08:39 +0100 |
| commit | 1160d065888258946f9585b3aa40c00d3470728a (patch) | |
| tree | 6811ed03c5913908c9f4464030730f1cc5bfc658 | |
| parent | a84c01e0fabb44880dcad7ac593053e7f12e9de3 (diff) | |
| download | rabbitmq-server-git-1160d065888258946f9585b3aa40c00d3470728a.tar.gz | |
eliminate accidental, crash-inducing assertion
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index ee9f77012b..e5c3adac06 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -166,13 +166,13 @@ init_it(Self, GM, Node, QName) -> end; [SPid] -> case rabbit_misc:is_process_alive(SPid) of true -> existing; - false -> GMPids = [T || T = {_, S} <- GMPids, - S =/= SPid], + false -> GMPids1 = [T || T = {_, S} <- GMPids, + S =/= SPid], Q1 = Q#amqqueue{ slave_pids = SPids -- [SPid], - gm_pids = GMPids}, + gm_pids = GMPids1}, add_slave(Q1, Self, GM), - {new, QPid, GMPids} + {new, QPid, GMPids1} end end; [] -> |