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 | 61eefc62433751cdbc8fd7d186aff2bdc42fe805 (patch) | |
| tree | 6811ed03c5913908c9f4464030730f1cc5bfc658 | |
| parent | 940d220bfa4b4c473acaf44e9216510544a72dea (diff) | |
| download | rabbitmq-server-bug26115.tar.gz | |
eliminate accidental, crash-inducing assertionbug26115
| -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 ee9f7701..e5c3adac 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; [] -> |