diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-02-06 13:00:09 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-02-06 13:00:09 +0000 |
| commit | c16d3a27f9eabefab3a6d7e248997ee837819127 (patch) | |
| tree | 927d1fb6650c52c0b16d99d0d6777c449743fcfe | |
| parent | c5199726b4d1a3b49f9c8674ade4e095aaaeeb75 (diff) | |
| download | rabbitmq-server-git-c16d3a27f9eabefab3a6d7e248997ee837819127.tar.gz | |
cosmetic
| -rw-r--r-- | src/credit_flow.erl | 17 |
1 files changed, 7 insertions, 10 deletions
diff --git a/src/credit_flow.erl b/src/credit_flow.erl index ada3e16d2c..edbf4fb5af 100644 --- a/src/credit_flow.erl +++ b/src/credit_flow.erl @@ -64,12 +64,11 @@ ack(To) -> ack(To, ?DEFAULT_CREDIT). ack(To, {MaxCredit, MoreCreditAt}) -> MoreCreditAt1 = MoreCreditAt + 1, - Credit = - case get({credit_to, To}, MaxCredit) of - MoreCreditAt1 -> grant(To, MaxCredit - MoreCreditAt), - MaxCredit; - C -> C - 1 - end, + Credit = case get({credit_to, To}, MaxCredit) of + MoreCreditAt1 -> grant(To, MaxCredit - MoreCreditAt), + MaxCredit; + C -> C - 1 + end, put({credit_to, To}, Credit). handle_bump_msg({From, MoreCredit}) -> @@ -81,8 +80,7 @@ handle_bump_msg({From, MoreCredit}) -> false -> ok end. -blocked() -> - get(credit_blocked, []) =/= []. +blocked() -> get(credit_blocked, []) =/= []. send(From) -> send(From, ?DEFAULT_CREDIT). @@ -112,8 +110,7 @@ grant(To, Quantity) -> put(credit_deferred, [{To, Msg} | Deferred]) end. -block(From) -> - put(credit_blocked, [From | get(credit_blocked, [])]). +block(From) -> put(credit_blocked, [From | get(credit_blocked, [])]). unblock(From) -> NewBlocks = get(credit_blocked, []) -- [From], |
