diff options
author | Matthias Radestock <matthias@rabbitmq.com> | 2014-04-17 07:00:20 +0100 |
---|---|---|
committer | Matthias Radestock <matthias@rabbitmq.com> | 2014-04-17 07:00:20 +0100 |
commit | 0a9f4a46ec64da1259ec1c86863cf8629c9dbe2c (patch) | |
tree | 0ed0539f655909710d8102f7f7e63b9b1d26aa91 | |
parent | b0daeacbed4ca4036ba545223c607c856c09d0e4 (diff) | |
download | rabbitmq-server-bug26126.tar.gz |
remove last vestiges of squarenessbug26126
-rw-r--r-- | src/rabbit_amqqueue.erl | 4 |
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) |