diff options
| author | Alvaro Videla <videlalvaro@gmail.com> | 2015-05-05 18:02:32 +0200 |
|---|---|---|
| committer | Alvaro Videla <videlalvaro@gmail.com> | 2015-09-11 11:20:12 +0200 |
| commit | 68351a279fb5f8f20c809c9bb3e76a1379ae659c (patch) | |
| tree | 48238215d9303966ef0d0043fba22a9c0e1f21e7 /src | |
| parent | 1393a458941e9b1193c51366b9a9bce9cf088d36 (diff) | |
| download | rabbitmq-server-git-68351a279fb5f8f20c809c9bb3e76a1379ae659c.tar.gz | |
Allows credit flow Credits to be set via configuration
Backports this fix from master into stable
Fixes rabbitmq/rabbitmq-server#143
Diffstat (limited to 'src')
| -rw-r--r-- | src/credit_flow.erl | 15 |
1 files changed, 14 insertions, 1 deletions
diff --git a/src/credit_flow.erl b/src/credit_flow.erl index e7f13a66dc..3e6ef75128 100644 --- a/src/credit_flow.erl +++ b/src/credit_flow.erl @@ -28,7 +28,20 @@ %% is itself blocked - thus the only processes that need to check %% blocked/0 are ones that read from network sockets. --define(DEFAULT_CREDIT, {200, 50}). +-define(DEFAULT_INITIAL_CREDIT, 200). +-define(DEFAULT_MORE_CREDIT_AFTER, 50). + +-define(DEFAULT_CREDIT, + case get(credit_flow_default_credit) of + undefined -> + Val = {rabbit_misc:get_env(rabbit, credit_flow_initial_credit, + ?DEFAULT_INITIAL_CREDIT), + rabbit_misc:get_env(rabbit, credit_flow_more_credit_after, + ?DEFAULT_MORE_CREDIT_AFTER)}, + put(credit_flow_default_credit, Val), + Val; + Val -> Val + end). -export([send/1, send/2, ack/1, ack/2, handle_bump_msg/1, blocked/0, state/0]). -export([peer_down/1]). |