From bb75417a9173744f32d5a312293cf47555d71c85 Mon Sep 17 00:00:00 2001 From: Matthias Radestock Date: Thu, 18 Dec 2008 21:43:36 +0000 Subject: minor simplifications --- src/rabbit_limiter.erl | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/src/rabbit_limiter.erl b/src/rabbit_limiter.erl index 6e9b10a2..257950b3 100644 --- a/src/rabbit_limiter.erl +++ b/src/rabbit_limiter.erl @@ -113,11 +113,14 @@ code_change(_, State, _) -> %%---------------------------------------------------------------------------- maybe_notify(OldState, NewState) -> - case limit_reached(OldState) and not(limit_reached(NewState)) of + case limit_reached(OldState) andalso not(limit_reached(NewState)) of true -> forget_queues(NewState); false -> NewState end. +limit_reached(#lim{prefetch_count = Limit, in_use = InUse}) -> + Limit =/= 0 andalso InUse >= Limit. + remember_queue(QPid, State = #lim{queues = Queues}) -> case dict:is_key(QPid, Queues) of false -> MonitorRef = erlang:monitor(process, QPid), @@ -131,8 +134,3 @@ forget_queues(State = #lim{ch_pid = ChPid, queues = Queues}) -> rabbit_amqqueue:unblock(Q, ChPid) end, ok, Queues), State#lim{queues = dict:new()}. - -limit_reached(#lim{prefetch_count = 0}) -> - false; -limit_reached(#lim{prefetch_count = Limit, in_use = InUse}) -> - InUse >= Limit. -- cgit v1.2.1