diff options
| -rw-r--r-- | src/rabbit_limiter.erl | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/src/rabbit_limiter.erl b/src/rabbit_limiter.erl index 35703efac9..8ed1adc711 100644 --- a/src/rabbit_limiter.erl +++ b/src/rabbit_limiter.erl @@ -193,15 +193,12 @@ decr_credit(CTag, Len, ChPid, Cred, Credits) -> write_credit(CTag, NewCredit, Drain, Credits). maybe_drain(0, true, CTag, ChPid, Credit) -> - send_drained(ChPid, CTag, Credit), + rabbit_channel:send_drained(ChPid, CTag, Credit), 0; %% Magic reduction to 0 maybe_drain(_, _, _, _, Credit) -> Credit. -send_drained(ChPid, CTag, CreditDrained) -> - rabbit_channel:send_drained(ChPid, CTag, CreditDrained). - update_credit(CTag, Len, ChPid, Credit, Drain, Credits) -> NewCredit = maybe_drain(Len, Drain, CTag, ChPid, Credit), NewCredits = write_credit(CTag, NewCredit, Drain, Credits), |