@@ -177,7 +177,8 @@ bytes(Words) -> try
177177 end .
178178
179179interesting_sups () ->
180- [queue_sups (), quorum_sups (), dlx_sups (), stream_server_sups (), stream_reader_sups (),
180+ [queue_sups (), quorum_sups (), dlx_sups (),
181+ stream_server_sups (), stream_reader_sups (), stream_coordinator (),
181182 conn_sups () | interesting_sups0 ()].
182183
183184queue_sups () ->
@@ -188,6 +189,7 @@ quorum_sups() -> [ra_server_sup_sup].
188189dlx_sups () -> [rabbit_fifo_dlx_sup ].
189190stream_server_sups () -> [osiris_server_sup ].
190191stream_reader_sups () -> [osiris_replica_reader_sup ].
192+ stream_coordinator () -> [rabbit_stream_coordinator ].
191193
192194msg_stores () ->
193195 all_vhosts_children (msg_store_transient )
@@ -234,18 +236,17 @@ ranch_server_sups() ->
234236with (Sups , With ) -> [{Sup , With } || Sup <- Sups ].
235237
236238distinguishers () -> with (queue_sups (), fun queue_type /1 ) ++
237- with (conn_sups (), fun conn_type /1 ) ++
238- with (quorum_sups (), fun ra_type /1 ).
239+ with (conn_sups (), fun conn_type /1 ).
239240
240241distinguished_interesting_sups () ->
241242 [
242243 with (queue_sups (), master ),
243244 with (queue_sups (), slave ),
244- with ( quorum_sups (), quorum ),
245+ quorum_sups (),
245246 dlx_sups (),
246247 stream_server_sups (),
247248 stream_reader_sups (),
248- with ( quorum_sups (), stream ),
249+ stream_coordinator ( ),
249250 with (conn_sups (), reader ),
250251 with (conn_sups (), writer ),
251252 with (conn_sups (), channel ),
@@ -302,12 +303,6 @@ conn_type(PDict) ->
302303 _ -> other
303304 end .
304305
305- ra_type (PDict ) ->
306- case keyfind ('$rabbit_vm_category' , PDict ) of
307- {value , rabbit_stream_coordinator } -> stream ;
308- _ -> quorum
309- end .
310-
311306% %----------------------------------------------------------------------------
312307
313308% % NB: this code is non-rabbit specific.
0 commit comments