Skip to content

Commit

Permalink
Finish off #13046
Browse files Browse the repository at this point in the history
  • Loading branch information
michaelklishin committed Jan 12, 2025
1 parent 27e4d4b commit 3dd3433
Showing 1 changed file with 9 additions and 7 deletions.
16 changes: 9 additions & 7 deletions deps/rabbit/src/rabbit.erl
Original file line number Diff line number Diff line change
Expand Up @@ -1755,17 +1755,19 @@ persist_static_configuration() ->
]),

%% Disallow the following two cases:
%% 1. Negative value
%% 2. MoreCreditAfter larger than InitialCredit.
%% 1. Negative values
%% 2. MoreCreditAfter greater than InitialCredit
CreditFlowDefaultCredit = case application:get_env(?MODULE, credit_flow_default_credit) of
{ok, {InitialCredit, MoreCreditAfter}}
when is_integer(InitialCredit) andalso
is_integer(MoreCreditAfter) andalso
MoreCreditAfter < InitialCredit ->
is_integer(MoreCreditAfter) andalso
InitialCredit > 0 andalso
MoreCreditAfter > 0 andalso
MoreCreditAfter < InitialCredit ->
{InitialCredit, MoreCreditAfter};
_ ->
rabbit_log:error("Failed to start due to invalid value of credit_flow_default_credit."),
throw({error, invalid_credit_flow_default_credit_value})
Other ->
rabbit_log:error("Refusing to boot due to an invalid value of 'rabbit.credit_flow_default_credit'"),
throw({error, {invalid_credit_flow_default_credit_value, Other}})
end,
ok = persistent_term:put(credit_flow_default_credit, CreditFlowDefaultCredit),

Expand Down

0 comments on commit 3dd3433

Please sign in to comment.