diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_flow.erl | 10 |
1 files changed, 2 insertions, 8 deletions
diff --git a/src/rabbit_flow.erl b/src/rabbit_flow.erl index 9759e72624..54d019cd10 100644 --- a/src/rabbit_flow.erl +++ b/src/rabbit_flow.erl @@ -51,7 +51,7 @@ blocked() -> get(credit_blocked, []) =/= []. send(From) -> - Credit = get_credit(From) - 1, + Credit = get({credit_from, From}, ?MAX_CREDIT) - 1, case Credit of 0 -> block(From); _ -> ok @@ -60,7 +60,7 @@ send(From) -> receiver_down(From) -> unblock(From), - put({credit_from, From}, quiescing). + erase({credit_from, From}). %% -------------------------------------------------------------------------- @@ -89,9 +89,3 @@ get(Key, Default) -> undefined -> Default; Value -> Value end. - -get_credit(From) -> - case get({credit_from, From}, ?MAX_CREDIT) of - quiescing -> 1; - Credit -> Credit - end. |