diff options
| author | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2020-10-22 14:27:06 +0200 |
|---|---|---|
| committer | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2020-10-22 14:27:06 +0200 |
| commit | dd8b3ea008a635c11e7e95d67138ebab11608538 (patch) | |
| tree | a4d5eee307056794965e90135bf3d27c7a10e227 | |
| parent | 20681aca6363df24ddf395768e31ba436d5f8a00 (diff) | |
| download | rabbitmq-server-git-dd8b3ea008a635c11e7e95d67138ebab11608538.tar.gz | |
Check stats timer in listen loop
| -rw-r--r-- | deps/rabbitmq_stream/src/rabbit_stream_reader.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/deps/rabbitmq_stream/src/rabbit_stream_reader.erl b/deps/rabbitmq_stream/src/rabbit_stream_reader.erl index 57b21454b5..dbc78ae2ae 100644 --- a/deps/rabbitmq_stream/src/rabbit_stream_reader.erl +++ b/deps/rabbitmq_stream/src/rabbit_stream_reader.erl @@ -237,9 +237,10 @@ close(Transport, S) -> listen_loop_post_auth(Transport, #stream_connection{socket = S, stream_subscriptions = StreamSubscriptions, credits = Credits, heartbeater = Heartbeater, monitors = Monitors, client_properties = ClientProperties, - send_file_oct = SendFileOct} = Connection, + send_file_oct = SendFileOct} = Connection0, #stream_connection_state{consumers = Consumers, blocked = Blocked} = State, #configuration{credits_required_for_unblocking = CreditsRequiredForUnblocking} = Configuration) -> + Connection = ensure_stats_timer(Connection0), {OK, Closed, Error} = Transport:messages(), receive {OK, S, Data} -> |