Fix function_clause error in stream reader

When the server initiate connection close.
rabbitmq · Aug 26, 2021 · b288ffc · b288ffc
1 parent df8d976
commit b288ffc
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/deps/rabbitmq_stream/src/rabbit_stream_reader.erl b/deps/rabbitmq_stream/src/rabbit_stream_reader.erl
@@ -746,25 +746,25 @@ 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 ->
             keep_state_and_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{