Implement CR

CHANGELOG.md

@@ -1,7 +1,7 @@
 # Changelog
 
 ## 1.1.0-rc1
- * Add new callbacks `handle_spec_setup_completed/3` and `handle_spec_playing/3` in Bins and Pipelines. [#801](https://github.com/membraneframework/membrane_core/pull/801)
+ * Add new callbacks `handle_child_setup_completed/3` and `handle_child_playing/3` in Bins and Pipelines. [#801](https://github.com/membraneframework/membrane_core/pull/801)
 
 ## 1.1.0-rc0
  * Deprecate `handle_spec_started/3` callback in Bins and Pipelines. [#708](https://github.com/membraneframework/membrane_core/pull/708)

lib/membrane/bin.ex

@@ -180,23 +180,23 @@ defmodule Membrane.Bin do
             ) :: callback_return
 
   @doc """
-  Callback invoked when all children of `Membrane.ChildrenSpec` complete their setup.
+  Callback invoked when a child complete its setup.
 
   By default, it does nothing.
   """
-  @callback handle_spec_setup_completed(
-              children :: [Child.name()],
+  @callback handle_child_setup_completed(
+              child :: Child.name(),
               context :: CallbackContext.t(),
               state
             ) :: callback_return
 
   @doc """
-  Callback invoked when children of `Membrane.ChildrenSpec` enter `playing` playback.
+  Callback invoked when a child enters `playing` playback.
 
   By default, it does nothing.
   """
-  @callback handle_spec_playing(
-              children :: [Child.name()],
+  @callback handle_child_playing(
+              child :: Child.name(),
               context :: CallbackContext.t(),
               state
             ) :: callback_return
@@ -239,8 +239,8 @@ defmodule Membrane.Bin do
                       handle_playing: 2,
                       handle_info: 3,
                       handle_spec_started: 3,
-                      handle_spec_setup_completed: 3,
-                      handle_spec_playing: 3,
+                      handle_child_setup_completed: 3,
+                      handle_child_playing: 3,
                       handle_element_start_of_stream: 4,
                       handle_element_end_of_stream: 4,
                       handle_child_notification: 4,
@@ -382,10 +382,10 @@ defmodule Membrane.Bin do
       end
 
       @impl true
-      def handle_spec_setup_completed(_children_names, _ctx, state), do: {[], state}
+      def handle_child_setup_completed(_child, _ctx, state), do: {[], state}
 
       @impl true
-      def handle_spec_playing(_children_names, _ctx, state), do: {[], state}
+      def handle_child_playing(_child, _ctx, state), do: {[], state}
 
       @impl true
       def handle_element_start_of_stream(_element, _pad, _ctx, state), do: {[], state}
@@ -411,8 +411,8 @@ defmodule Membrane.Bin do
                      handle_setup: 2,
                      handle_playing: 2,
                      handle_info: 3,
-                     handle_spec_setup_completed: 3,
-                     handle_spec_playing: 3,
+                     handle_child_setup_completed: 3,
+                     handle_child_playing: 3,
                      handle_element_start_of_stream: 4,
                      handle_element_end_of_stream: 4,
                      handle_child_notification: 4,

lib/membrane/core/parent/child_life_controller.ex

@@ -320,10 +320,7 @@ defmodule Membrane.Core.Parent.ChildLifeController do
          Enum.empty?(spec_data.dependent_specs) do
       Membrane.Logger.debug("Spec #{inspect(spec_ref)} status changed to initialized")
 
-      state =
-        MapSet.to_list(spec_data.children_names)
-        |> StartupUtils.exec_handle_spec_setup_completed(state)
-
+      state = handle_children_setup_completed(spec_data.children_names, state)
       do_proceed_spec_startup(spec_ref, %{spec_data | status: :initialized}, state)
     else
       {spec_data, state}
@@ -428,8 +425,7 @@ defmodule Membrane.Core.Parent.ChildLifeController do
 
     state =
       with %{playback: :playing} <- state do
-        MapSet.to_list(spec_data.children_names)
-        |> StartupUtils.exec_handle_spec_playing(state)
+        handle_children_playing(spec_data.children_names, state)
       end
 
     {spec_data, state}
@@ -630,6 +626,32 @@ defmodule Membrane.Core.Parent.ChildLifeController do
     }
   end
 
+  @spec handle_children_setup_completed(MapSet.t(Child.name()) | [Child.name()], Parent.state()) ::
+          Parent.state()
+  def handle_children_setup_completed(children_names, state) do
+    exec_child_playback_related_callbacks(:handle_child_setup_completed, children_names, state)
+  end
+
+  @spec handle_children_playing(MapSet.t(Child.name()) | [Child.name()], Parent.state()) ::
+          Parent.state()
+  def handle_children_playing(children_names, state) do
+    exec_child_playback_related_callbacks(:handle_child_playing, children_names, state)
+  end
+
+  defp exec_child_playback_related_callbacks(callback, children_names, state) do
+    action_handler = Component.action_handler(state)
+
+    Enum.reduce(children_names, state, fn child, state ->
+      CallbackHandler.exec_and_handle_callback(
+        callback,
+        action_handler,
+        %{context: &Component.context_from_state/1},
+        [child],
+        state
+      )
+    end)
+  end
+
   @spec handle_child_pad_removed(Child.name(), Pad.ref(), Parent.state()) :: Parent.state()
   def handle_child_pad_removed(child, child_pad_ref, state) do
     Membrane.Logger.debug_verbose("Child #{inspect(child)} removed pad #{inspect(child_pad_ref)}")

lib/membrane/core/parent/child_life_controller/startup_utils.ex

@@ -108,35 +108,20 @@ defmodule Membrane.Core.Parent.ChildLifeController.StartupUtils do
 
     # handle_spec_started/3 callback is deprecated, so we don't require its implementation
     if function_exported?(state.module, callback_name, 3) do
-      exec_spec_related_callback(callback_name, children_names, state)
+      action_handler = Component.action_handler(state)
+
+      CallbackHandler.exec_and_handle_callback(
+        callback_name,
+        action_handler,
+        %{context: &Component.context_from_state/1},
+        [children_names],
+        state
+      )
     else
       state
     end
   end
 
-  @spec exec_handle_spec_setup_completed([Membrane.Child.name()], Parent.state()) ::
-          Parent.state()
-  def exec_handle_spec_setup_completed(children_names, state) do
-    exec_spec_related_callback(:handle_spec_setup_completed, children_names, state)
-  end
-
-  @spec exec_handle_spec_playing([Membrane.Child.name()], Parent.state()) :: Parent.state()
-  def exec_handle_spec_playing(children_names, state) do
-    exec_spec_related_callback(:handle_spec_playing, children_names, state)
-  end
-
-  defp exec_spec_related_callback(callback, children_names, state) do
-    action_handler = Component.action_handler(state)
-
-    CallbackHandler.exec_and_handle_callback(
-      callback,
-      action_handler,
-      %{context: &Component.context_from_state/1},
-      [children_names],
-      state
-    )
-  end
-
   @spec check_if_children_names_and_children_groups_ids_are_unique(
           ChildLifeController.children_spec_canonical_form(),
           Parent.state()

lib/membrane/core/parent/lifecycle_controller.ex

@@ -2,7 +2,6 @@ defmodule Membrane.Core.Parent.LifecycleController do
   @moduledoc false
   use Bunch
 
-  alias Membrane.Core.Parent.ChildLifeController.StartupUtils
   alias Membrane.{Child, ChildNotification, Core, Pad, Sync}
 
   alias Membrane.Core.{
@@ -14,7 +13,7 @@ defmodule Membrane.Core.Parent.LifecycleController do
   }
 
   alias Membrane.Core.Events
-  alias Membrane.Core.Parent.{ChildLifeController}
+  alias Membrane.Core.Parent.ChildLifeController
 
   require Membrane.Core.Component
   require Membrane.Core.Message
@@ -66,11 +65,7 @@ defmodule Membrane.Core.Parent.LifecycleController do
         state
       )
 
-    pinged_children
-    |> Enum.group_by(&state.children[&1].spec_ref)
-    |> Enum.reduce(state, fn {_spec_ref, children}, state ->
-      StartupUtils.exec_handle_spec_playing(children, state)
-    end)
+    ChildLifeController.handle_children_playing(pinged_children, state)
   end
 
   @spec handle_terminate_request(Parent.state()) :: Parent.state()

lib/membrane/pipeline.ex

@@ -225,8 +225,8 @@ defmodule Membrane.Pipeline do
 
   By default, it does nothing.
   """
-  @callback handle_spec_setup_completed(
-              children :: [Child.name()],
+  @callback handle_child_setup_completed(
+              child :: Child.name(),
               context :: CallbackContext.t(),
               state
             ) :: {[Action.common_actions()], state()}
@@ -236,8 +236,8 @@ defmodule Membrane.Pipeline do
 
   By default, it does nothing.
   """
-  @callback handle_spec_playing(
-              children :: [Child.name()],
+  @callback handle_child_playing(
+              child :: Child.name(),
               context :: CallbackContext.t(),
               state
             ) :: {[Action.common_actions()], state()}
@@ -282,8 +282,8 @@ defmodule Membrane.Pipeline do
                       handle_playing: 2,
                       handle_info: 3,
                       handle_spec_started: 3,
-                      handle_spec_setup_completed: 3,
-                      handle_spec_playing: 3,
+                      handle_child_setup_completed: 3,
+                      handle_child_playing: 3,
                       handle_element_start_of_stream: 4,
                       handle_element_end_of_stream: 4,
                       handle_child_notification: 4,
@@ -540,10 +540,10 @@ defmodule Membrane.Pipeline do
       end
 
       @impl true
-      def handle_spec_setup_completed(_children_names, _ctx, state), do: {[], state}
+      def handle_child_setup_completed(_child, _ctx, state), do: {[], state}
 
       @impl true
-      def handle_spec_playing(_children_names, _ctx, state), do: {[], state}
+      def handle_child_playing(_child, _ctx, state), do: {[], state}
 
       @impl true
       def handle_element_start_of_stream(_element, _pad, _ctx, state), do: {[], state}
@@ -568,8 +568,8 @@ defmodule Membrane.Pipeline do
                      handle_setup: 2,
                      handle_playing: 2,
                      handle_info: 3,
-                     handle_spec_setup_completed: 3,
-                     handle_spec_playing: 3,
+                     handle_child_setup_completed: 3,
+                     handle_child_playing: 3,
                      handle_element_start_of_stream: 4,
                      handle_element_end_of_stream: 4,
                      handle_child_notification: 4,

lib/membrane/testing/pipeline.ex

@@ -396,18 +396,26 @@ defmodule Membrane.Testing.Pipeline do
     {custom_actions, Map.put(state, :custom_pipeline_state, custom_state)}
   end
 
-  [
-    :handle_spec_started,
-    :handle_spec_setup_completed,
-    :handle_spec_playing
-  ]
+  @impl true
+  def handle_spec_started(children, ctx, %State{} = state) do
+    {custom_actions, custom_state} =
+      eval_injected_module_callback(
+        :handle_spec_started,
+        [children, ctx],
+        state
+      )
+
+    {custom_actions, Map.put(state, :custom_pipeline_state, custom_state)}
+  end
+
+  [:handle_child_setup_completed, :handle_child_playing]
   |> Enum.map(fn callback ->
     @impl true
-    def unquote(callback)(children, ctx, %State{} = state) do
+    def unquote(callback)(child, ctx, %State{} = state) do
       {custom_actions, custom_state} =
         eval_injected_module_callback(
           unquote(callback),
-          [children, ctx],
+          [child, ctx],
           state
         )