diff options
| author | Karl Nilsson <kjnilsson@gmail.com> | 2021-08-26 14:21:54 +0100 |
|---|---|---|
| committer | Gerhard Lazu <gerhard@lazu.co.uk> | 2021-08-31 15:29:16 +0100 |
| commit | c240ec2985ecd78b674c242ebf5deaf485caf8ba (patch) | |
| tree | f7e31a38658b7e220f7e143fa0f6a26d6aa4d0ce | |
| parent | c016567359d43500cb5b2cc07a6597522c945903 (diff) | |
| download | rabbitmq-server-git-improve-stream-reader-metrics-cleanup.tar.gz | |
Fix function_clause error in stream readerimprove-stream-reader-metrics-cleanup
When the server initiate connection close.
| -rw-r--r-- | deps/rabbitmq_stream/src/rabbit_stream_reader.erl | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/deps/rabbitmq_stream/src/rabbit_stream_reader.erl b/deps/rabbitmq_stream/src/rabbit_stream_reader.erl index 137d13d9ba..6939fbd4ca 100644 --- a/deps/rabbitmq_stream/src/rabbit_stream_reader.erl +++ b/deps/rabbitmq_stream/src/rabbit_stream_reader.erl @@ -746,7 +746,7 @@ open(info, open(info, heartbeat_send, #statem_data{ transport = Transport, connection = #stream_connection{socket = S} = Connection, - connection_state = State }) -> + connection_state = State}) -> Frame = rabbit_stream_core:frame(heartbeat), case catch send(Transport, S, Frame) of ok -> @@ -754,17 +754,17 @@ open(info, heartbeat_send, #statem_data{ Unexpected -> rabbit_log_connection:info("Heartbeat send error ~p, closing connection", [Unexpected]), - C1 = demonitor_all_streams(Connection), - close(Transport, C1, State), + _C1 = demonitor_all_streams(Connection), + close(Transport, S, State), stop end; open(info, heartbeat_timeout, #statem_data{ transport = Transport, - connection = Connection, + connection = #stream_connection{socket = S} = Connection, connection_state = State }) -> rabbit_log_connection:debug("Heartbeat timeout, closing connection"), - C1 = demonitor_all_streams(Connection), - close(Transport, C1, State), + _C1 = demonitor_all_streams(Connection), + close(Transport, S, State), stop; open(info, {infos, From}, #statem_data{ connection = #stream_connection{ |