diff options
| author | David Ansari <david.ansari@gmx.de> | 2021-07-15 20:56:56 +0200 |
|---|---|---|
| committer | David Ansari <david.ansari@gmx.de> | 2021-07-15 20:56:56 +0200 |
| commit | 4053f729ddb8b8299816df01bd7a30fd32d1dda3 (patch) | |
| tree | 8f90ba56789b98325f25d9a83a03ea67835c97d8 | |
| parent | 694804d0d2e7c6620cce879a2dab03c891786f6d (diff) | |
| download | rabbitmq-server-git-4053f729ddb8b8299816df01bd7a30fd32d1dda3.tar.gz | |
Rename STATE_TIMEOUT to CONNECTION_NEGOTIATION_STEP_TIMEOUT
| -rw-r--r-- | deps/rabbitmq_stream/src/rabbit_stream_reader.erl | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/deps/rabbitmq_stream/src/rabbit_stream_reader.erl b/deps/rabbitmq_stream/src/rabbit_stream_reader.erl index 3527643867..d989c0f4ae 100644 --- a/deps/rabbitmq_stream/src/rabbit_stream_reader.erl +++ b/deps/rabbitmq_stream/src/rabbit_stream_reader.erl @@ -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, |