root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

Rename STATE_TIMEOUT to CONNECTION_NEGOTIATION_STEP_TIMEOUT

This commit is contained in:
David Ansari 2021-07-15 20:56:56 +02:00
parent 694804d0d2
commit 4053f729dd
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
deps/rabbitmq_stream/src/rabbit_stream_reader.erl vendored
View File

@ -147,9 +147,9 @@
peer_cert_validity]).
-ifdef(TEST).
-define(STATE_TIMEOUT, 500).
-define(CONNECTION_NEGOTIATION_STEP_TIMEOUT, 500).
-else.
-define(STATE_TIMEOUT, 10_000).
-define(CONNECTION_NEGOTIATION_STEP_TIMEOUT, 10_000).
-endif.
%% client API
@ -259,7 +259,7 @@ init([KeepaliveSup,
end.
tcp_connected(enter, _OldState, StateData) ->
{next_state, ?FUNCTION_NAME, StateData, {state_timeout, ?STATE_TIMEOUT, close}};
{next_state, ?FUNCTION_NAME, StateData, {state_timeout, ?CONNECTION_NEGOTIATION_STEP_TIMEOUT, close}};
tcp_connected(state_timeout, close, #statem_data{
transport = Transport,
connection = #stream_connection{socket = Socket}
@ -285,7 +285,7 @@ tcp_connected(info, Msg, StateData) ->
end).
peer_properties_exchanged(enter, _OldState, StateData) ->
{next_state, ?FUNCTION_NAME, StateData, {state_timeout, ?STATE_TIMEOUT, close}};
{next_state, ?FUNCTION_NAME, StateData, {state_timeout, ?CONNECTION_NEGOTIATION_STEP_TIMEOUT, close}};
peer_properties_exchanged(state_timeout, close, #statem_data{
transport = Transport,
connection = #stream_connection{socket = Socket}
@ -311,7 +311,7 @@ peer_properties_exchanged(info, Msg, StateData) ->
end).
authenticating(enter, _OldState, StateData) ->
{next_state, ?FUNCTION_NAME, StateData, {state_timeout, ?STATE_TIMEOUT, close}};
{next_state, ?FUNCTION_NAME, StateData, {state_timeout, ?CONNECTION_NEGOTIATION_STEP_TIMEOUT, close}};
authenticating(state_timeout, close, #statem_data{
transport = Transport,
connection = #stream_connection{socket = Socket}
@ -344,7 +344,7 @@ authenticating(info, Msg, StateData) ->
end).
tuning(enter, _OldState, StateData) ->
{next_state, ?FUNCTION_NAME, StateData, {state_timeout, ?STATE_TIMEOUT, close}};
{next_state, ?FUNCTION_NAME, StateData, {state_timeout, ?CONNECTION_NEGOTIATION_STEP_TIMEOUT, close}};
tuning(state_timeout, close, #statem_data{
transport = Transport,
connection = #stream_connection{socket = Socket}
@ -374,7 +374,7 @@ tuning(info, Msg, StateData) ->
end).
tuned(enter, _OldState, StateData) ->
{next_state, ?FUNCTION_NAME, StateData, {state_timeout, ?STATE_TIMEOUT, close}};
{next_state, ?FUNCTION_NAME, StateData, {state_timeout, ?CONNECTION_NEGOTIATION_STEP_TIMEOUT, close}};
tuned(state_timeout, close, #statem_data{
transport = Transport,
connection = #stream_connection{socket = Socket}
@ -1000,7 +1000,7 @@ open(cast, {force_event_refresh, Ref}, #statem_data{
{keep_state, StatemData#statem_data{connection = Connection2}}.
close_sent(enter, _OldState, StateData) ->
{next_state, ?FUNCTION_NAME, StateData, {state_timeout, ?STATE_TIMEOUT, close}};
{next_state, ?FUNCTION_NAME, StateData, {state_timeout, ?CONNECTION_NEGOTIATION_STEP_TIMEOUT, close}};
close_sent(state_timeout, close, #statem_data{
transport = Transport,
connection = #stream_connection{socket = Socket} = Connection,