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 | d094617b184b34fea32ef61528810f068191f0af (patch) | |
| tree | 724afd37ad792664c99b4a0ba58e12c2d0b00bbd /src | |
| parent | c2bd02f507ffbfbb55b138753c2bb5839ae16e0e (diff) | |
| download | rabbitmq-server-git-d094617b184b34fea32ef61528810f068191f0af.tar.gz | |
Oops, don't explode in the empty=true drain=false case!
Diffstat (limited to 'src')
| -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 4e1e299c54..10e00fa303 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}) -> |