diff options
| author | Karl Nilsson <kjnilsson@gmail.com> | 2021-09-21 13:09:46 +0100 |
|---|---|---|
| committer | Karl Nilsson <kjnilsson@gmail.com> | 2021-09-21 13:09:46 +0100 |
| commit | be380930ec6a87a4b720bab973663c088388262c (patch) | |
| tree | a985508207bc9e7d0eff622785b4c71d961017a9 | |
| parent | 6e6279eb2b659cc39b6c016deaec7cada9a76424 (diff) | |
| download | rabbitmq-server-git-be380930ec6a87a4b720bab973663c088388262c.tar.gz | |
Stream coordinator: monitor task processes
So that they are cleaned up from the stream coordinator aux state
when they finish instead of growing indefinitely.
| -rw-r--r-- | deps/rabbit/src/rabbit_stream_coordinator.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/deps/rabbit/src/rabbit_stream_coordinator.erl b/deps/rabbit/src/rabbit_stream_coordinator.erl index 70989e383b..f32d6de61d 100644 --- a/deps/rabbit/src/rabbit_stream_coordinator.erl +++ b/deps/rabbit/src/rabbit_stream_coordinator.erl @@ -634,7 +634,7 @@ run_action(Action, StreamId, #{node := _Node, ActionFun(), unlink(Coordinator) end), - Effects = [], + Effects = [{monitor, process, aux, Pid}], Actions = Actions0#{Pid => {StreamId, Action, Args}}, {no_reply, Aux#aux{actions = Actions}, Log, Effects}. |