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 | 855d8926f66a5162d0bc65540f7ead603f2e4386 (patch) | |
| tree | 4a27977b034c7f00854018e6518f1e14ed369a3c | |
| parent | fefdf7f98dddcb9cfcfbba36152ddc2422e1d185 (diff) | |
| download | rabbitmq-server-855d8926f66a5162d0bc65540f7ead603f2e4386.tar.gz | |
If given Credit=0 then don't accidentally return Unblocked=true.
| -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 a28c4a2f..5776fc3f 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, |