summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2014-04-17 07:00:20 +0100
committerMatthias Radestock <matthias@rabbitmq.com>2014-04-17 07:00:20 +0100
commit0a9f4a46ec64da1259ec1c86863cf8629c9dbe2c (patch)
tree0ed0539f655909710d8102f7f7e63b9b1d26aa91
parentb0daeacbed4ca4036ba545223c607c856c09d0e4 (diff)
downloadrabbitmq-server-bug26126.tar.gz
remove last vestiges of squarenessbug26126
-rw-r--r--src/rabbit_amqqueue.erl4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl
index 1f11a77a..b80b4dbc 100644
--- a/src/rabbit_amqqueue.erl
+++ b/src/rabbit_amqqueue.erl
@@ -527,9 +527,9 @@ force_event_refresh(Ref) -> force_event_refresh(list(), Ref).
force_event_refresh(Qs, Ref) ->
{_, Bad} = gen_server2:mcall(
[{Q#amqqueue.pid, {force_event_refresh, Ref}} || Q <- Qs]),
- FailedPids = [Pid || {Pid, _Reason} <- Bad],
+ FailedPids = gb_sets:from_list([Pid || {Pid, _Reason} <- Bad]),
case [Name || #amqqueue{name = Name, pid = Pid} <- Qs,
- lists:member(Pid, FailedPids)] of
+ gb_sets:is_element(Pid, FailedPids)] of
[] -> ok;
Failed -> timer:sleep(?FAILOVER_WAIT_MILLIS),
force_event_refresh(lookup(Failed), Ref)