diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-02-03 13:44:19 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-02-03 13:44:19 +0000 |
| commit | 7597e6871940458eccea7592e73a021da0021725 (patch) | |
| tree | 4a27977b034c7f00854018e6518f1e14ed369a3c /src | |
| parent | 0e37e829315d198e3352158189f7f36e336f9828 (diff) | |
| download | rabbitmq-server-git-7597e6871940458eccea7592e73a021da0021725.tar.gz | |
If given Credit=0 then don't accidentally return Unblocked=true.
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 a28c4a2f7d..5776fc3f7a 100644 --- a/src/rabbit_limiter.erl +++ b/src/rabbit_limiter.erl @@ -279,7 +279,7 @@ ack_from_queue(Limiter = #qstate{credits = Credits}, CTag, Credit) -> case gb_trees:lookup(CTag, Credits) of {value, C = #credit{mode = auto, credit = C0}} -> {update_credit(CTag, C#credit{credit = C0 + Credit}, Credits), - C0 =:= 0}; + C0 =:= 0 andalso Credit =/= 0}; _ -> {Credits, false} end, |