diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-01-09 10:52:30 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-01-09 10:52:30 +0000 |
| commit | 6212861309962a136e7b2ed0480d77c00dcb395b (patch) | |
| tree | 724afd37ad792664c99b4a0ba58e12c2d0b00bbd /src/rabbit_limiter.erl | |
| parent | 5a59d423b33af1efb3c89af31326788bb0d40da1 (diff) | |
| download | rabbitmq-server-6212861309962a136e7b2ed0480d77c00dcb395b.tar.gz | |
Oops, don't explode in the empty=true drain=false case!
Diffstat (limited to 'src/rabbit_limiter.erl')
| -rw-r--r-- | src/rabbit_limiter.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_limiter.erl b/src/rabbit_limiter.erl index 4e1e299c..10e00fa3 100644 --- a/src/rabbit_limiter.erl +++ b/src/rabbit_limiter.erl @@ -278,7 +278,7 @@ is_consumer_blocked(#qstate{credits = Credits}, CTag) -> credit(Limiter = #qstate{credits = Credits}, CTag, _Credit, true, true) -> Limiter#qstate{credits = update_credit(CTag, 0, true, Credits)}; -credit(Limiter = #qstate{credits = Credits}, CTag, Credit, false, Drain) -> +credit(Limiter = #qstate{credits = Credits}, CTag, Credit, _IsEmpty, Drain) -> Limiter#qstate{credits = update_credit(CTag, Credit, Drain, Credits)}. drained(Limiter = #qstate{credits = Credits}) -> |