Skip to content

Commit

Permalink
Polish authentication in stream reader
Browse files Browse the repository at this point in the history
(cherry picked from commit 6c14d73)
  • Loading branch information
acogoluegnes authored and mergify[bot] committed Jun 6, 2023
1 parent 540c761 commit a24b443
Showing 1 changed file with 1 addition and 4 deletions.
5 changes: 1 addition & 4 deletions deps/rabbitmq_stream/src/rabbit_stream_reader.erl
Original file line number Diff line number Diff line change
Expand Up @@ -64,6 +64,7 @@
%% client port
peer_port,
auth_mechanism,
authentication_state :: any(),
connected_at :: integer(),
helper_sup :: pid(),
socket :: rabbit_net:socket(),
Expand All @@ -75,7 +76,6 @@
stream_leaders :: #{stream() => pid()},
stream_subscriptions :: #{stream() => [subscription_id()]},
credits :: atomics:atomics_ref(),
authentication_state :: any(),
user :: undefined | #user{},
virtual_host :: undefined | binary(),
connection_step ::
Expand Down Expand Up @@ -1426,9 +1426,6 @@ handle_frame_pre_auth(Transport,
{C1#stream_connection{connection_step = failure},
{sasl_authenticate, ?RESPONSE_SASL_ERROR, <<>>}};
{challenge, Challenge, AuthState1} ->
rabbit_core_metrics:auth_attempt_succeeded(Host,
<<>>,
stream),
{C1#stream_connection{authentication_state = AuthState1,
connection_step = authenticating},
{sasl_authenticate, ?RESPONSE_SASL_CHALLENGE,
Expand Down

0 comments on commit a24b443

Please sign in to comment.