summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2012-02-06 13:00:09 +0000
committerMatthias Radestock <matthias@rabbitmq.com>2012-02-06 13:00:09 +0000
commitc16d3a27f9eabefab3a6d7e248997ee837819127 (patch)
tree927d1fb6650c52c0b16d99d0d6777c449743fcfe
parentc5199726b4d1a3b49f9c8674ade4e095aaaeeb75 (diff)
downloadrabbitmq-server-git-c16d3a27f9eabefab3a6d7e248997ee837819127.tar.gz
cosmetic
-rw-r--r--src/credit_flow.erl17
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],