@@ -209,40 +209,31 @@ defmodule Membrane.Core.Stalker do
209209 if :links in @ unsafely_name_processes_for_observer do
210210 IO . warn ( """
211211 Deprecated `:links` value for `:unsafely_name_processes_for_observer` configuration.
212- Use the following configuration:
212+ Instead please use the following configuration:
213213 ```
214214 config :membrane_core, report_links_to_observer: true
215215 ```
216- instead
217216 """ )
218-
219- generate_run_link_dbg_process ( )
220217 end
221218
222219 if @ report_links_to_observer do
223- generate_run_link_dbg_process ( )
224- end
220+ defp run_link_dbg_process ( pad_ref , observability_data ) do
221+ { :ok , observer_dbg_process } =
222+ Task . start_link ( fn ->
223+ Process . flag ( :trap_exit , true )
224+ Process . label ( self ( ) , :"pad #{ inspect ( pad_ref ) } #{ :erlang . pid_to_list ( self ( ) ) } " )
225+ process_to_link = Map . get ( observability_data , :observer_dbg_process )
226+ if process_to_link , do: Process . link ( process_to_link )
227+
228+ receive do
229+ { :EXIT , _pid , _reason } -> :ok
230+ end
231+ end )
225232
226- defmacrop generate_run_link_dbg_process ( ) do
227- quote do
228- defp run_link_dbg_process ( pad_ref , observability_data ) do
229- { :ok , observer_dbg_process } =
230- Task . start_link ( fn ->
231- Process . flag ( :trap_exit , true )
232- Process . label ( self ( ) , :"pad #{ inspect ( pad_ref ) } #{ :erlang . pid_to_list ( self ( ) ) } " )
233- process_to_link = Map . get ( observability_data , :observer_dbg_process )
234- if process_to_link , do: Process . link ( process_to_link )
235-
236- receive do
237- { :EXIT , _pid , _reason } -> :ok
238- end
239- end )
240-
241- observer_dbg_process
242- end
243- else
244- defp run_link_dbg_process ( _pad_ref , _observability_data ) , do: nil
233+ observer_dbg_process
245234 end
235+ else
236+ defp run_link_dbg_process ( _pad_ref , _observability_data ) , do: nil
246237 end
247238
248239 @ doc """
0 commit comments