diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2013-02-12 21:57:24 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2013-02-12 21:57:24 +0000 |
| commit | d26fd217e64a1f28a4a4e5667c13c3d7c21fe7d9 (patch) | |
| tree | b8b24c409696cd2c5bbd7e831b65539a651b1150 /src | |
| parent | cd41df2496814386fb0ce16127f5a7566af27399 (diff) | |
| download | rabbitmq-server-git-d26fd217e64a1f28a4a4e5667c13c3d7c21fe7d9.tar.gz | |
remove icky use of element/2
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_misc.erl | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/src/rabbit_mirror_queue_misc.erl b/src/rabbit_mirror_queue_misc.erl index cc2d7c77af..5cba2d4333 100644 --- a/src/rabbit_mirror_queue_misc.erl +++ b/src/rabbit_mirror_queue_misc.erl @@ -324,10 +324,11 @@ update_mirrors(OldQ = #amqqueue{pid = QPid}, update_mirrors0(OldQ = #amqqueue{name = QName}, NewQ = #amqqueue{name = QName}) -> - All = fun (Tuple) -> [element(1, Tuple) | element(2, Tuple)] end, - OldNodes = All(actual_queue_nodes(OldQ)), - NewNodes = All(suggested_queue_nodes(NewQ)), - add_mirrors(QName, NewNodes -- OldNodes), + {OldMNode, OldSNodes, _} = actual_queue_nodes(OldQ), + {NewMNode, NewSNodes} = suggested_queue_nodes(NewQ), + OldNodes = [OldMNode | OldSNodes], + NewNodes = [NewMNode | NewSNodes], + add_mirrors (QName, NewNodes -- OldNodes), drop_mirrors(QName, OldNodes -- NewNodes), ok. |