diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2011-07-26 16:53:03 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2011-07-26 16:53:03 +0100 |
| commit | ff8a4b4b9f5594cdf1172b9b9b83e23cd21df0d7 (patch) | |
| tree | 354010a19c57584c953bc42c086f1c8fb21b1dc4 | |
| parent | 6c67ac02d6e980d1da0ac23d4a0f59f6c0a98608 (diff) | |
| download | rabbitmq-server-git-ff8a4b4b9f5594cdf1172b9b9b83e23cd21df0d7.tar.gz | |
cosmetic
| -rw-r--r-- | src/rabbit_limiter.erl | 15 |
1 files changed, 7 insertions, 8 deletions
diff --git a/src/rabbit_limiter.erl b/src/rabbit_limiter.erl index b80ad6cc2b..8f9ab0321a 100644 --- a/src/rabbit_limiter.erl +++ b/src/rabbit_limiter.erl @@ -204,11 +204,10 @@ remember_queue(QPid, State = #lim{queues = Queues}) -> forget_queue(QPid, State = #lim{ch_pid = ChPid, queues = Queues}) -> case orddict:find(QPid, Queues) of - {ok, {MRef, _}} -> - true = erlang:demonitor(MRef), - ok = rabbit_amqqueue:unblock(QPid, ChPid), - State#lim{queues = orddict:erase(QPid, Queues)}; - error -> State + {ok, {MRef, _}} -> true = erlang:demonitor(MRef), + ok = rabbit_amqqueue:unblock(QPid, ChPid), + State#lim{queues = orddict:erase(QPid, Queues)}; + error -> State end. limit_queue(QPid, State = #lim{queues = Queues}) -> @@ -218,9 +217,9 @@ limit_queue(QPid, State = #lim{queues = Queues}) -> notify_queues(State = #lim{ch_pid = ChPid, queues = Queues}) -> {QList, NewQueues} = orddict:fold(fun (_QPid, {_, false}, Acc) -> Acc; - (QPid, {MRef, true}, {L, D}) -> - {[QPid | L], orddict:store(QPid, {MRef, false}, D)} - end, {[], Queues}, Queues), + (QPid, {MRef, true}, {L, D}) -> + {[QPid | L], orddict:store(QPid, {MRef, false}, D)} + end, {[], Queues}, Queues), case length(QList) of 0 -> ok; L -> |