Skip to content

Commit

Permalink
Remove unnecessary comments
Browse files Browse the repository at this point in the history
  • Loading branch information
FelonEkonom committed Mar 27, 2024
1 parent 95b045f commit 93de2fc
Show file tree
Hide file tree
Showing 4 changed files with 0 additions and 8 deletions.
2 changes: 0 additions & 2 deletions lib/membrane/core/bin.ex
Original file line number Diff line number Diff line change
Expand Up @@ -70,8 +70,6 @@ defmodule Membrane.Core.Bin do

if node do
result = :rpc.call(node, GenServer, :start, [__MODULE__, options])

# TODO: use an atomic way of linking once https://github.com/erlang/otp/issues/6375 is solved
with {:start_link, {:ok, pid}} <- {method, result}, do: Process.link(pid)
result
else
Expand Down
2 changes: 0 additions & 2 deletions lib/membrane/core/element.ex
Original file line number Diff line number Diff line change
Expand Up @@ -86,8 +86,6 @@ defmodule Membrane.Core.Element do
# rpc if necessary
if node do
result = :rpc.call(node, GenServer, :start, [__MODULE__, options])

# TODO: use an atomic way of linking once https://github.com/erlang/otp/issues/6375 is solved
with {:start_link, {:ok, pid}} <- {method, result}, do: Process.link(pid)
result
else
Expand Down
3 changes: 0 additions & 3 deletions lib/membrane/core/element/action_handler.ex
Original file line number Diff line number Diff line change
Expand Up @@ -348,7 +348,6 @@ defmodule Membrane.Core.Element.ActionHandler do
stalker_metrics: stalker_metrics
}
when stream_format != nil <- pad_data do
# todo: move this function to one of the controllers, to avoid redundant PadModet.get_data in the function below
state = DemandController.decrease_demand_by_outgoing_buffers(pad_ref, buffers, state)
:atomics.add(stalker_metrics.total_buffers, 1, length(buffers))
Message.send(pid, :buffer, buffers, for_pad: other_ref)
Expand Down Expand Up @@ -422,7 +421,6 @@ defmodule Membrane.Core.Element.ActionHandler do
defp delay_supplying_demand(pad_ref, size, state) do
with %{direction: :input, flow_control: :manual} <-
PadModel.get_data!(state, pad_ref) do
# todo: get_data! above could be eradicated
state = ManualFlowController.update_demand(pad_ref, size, state)
ManualFlowController.delay_supplying_demand(pad_ref, state)
else
Expand All @@ -444,7 +442,6 @@ defmodule Membrane.Core.Element.ActionHandler do
when type in [:source, :filter, :endpoint] do
with %{direction: :output, flow_control: :manual} <-
PadModel.get_data!(state, pad_ref) do
# todo: get_data! above could be eradicated
ManualFlowController.delay_redemand(pad_ref, state)
else
%{direction: :input} ->
Expand Down
1 change: 0 additions & 1 deletion lib/membrane/core/element/buffer_controller.ex
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,6 @@ defmodule Membrane.Core.Element.BufferController do
end
end

# todo: move it to the flow controllers?
@spec do_handle_ingoing_buffers(
Pad.ref(),
PadModel.pad_data(),
Expand Down

0 comments on commit 93de2fc

Please sign in to comment.