diff --git a/lib/membrane/core/element/callback_context.ex b/lib/membrane/core/element/callback_context.ex index e0eadd694..71cee7c9b 100644 --- a/lib/membrane/core/element/callback_context.ex +++ b/lib/membrane/core/element/callback_context.ex @@ -18,8 +18,7 @@ defmodule Membrane.Core.Element.CallbackContext do name: state.name, playback: state.playback, resource_guard: state.resource_guard, - utility_supervisor: state.subprocess_supervisor, - big_state: state + utility_supervisor: state.subprocess_supervisor }) end end diff --git a/lib/membrane/core/element/demand_controller/auto_flow_utils.ex b/lib/membrane/core/element/demand_controller/auto_flow_utils.ex index 3040925c8..499ab22bc 100644 --- a/lib/membrane/core/element/demand_controller/auto_flow_utils.ex +++ b/lib/membrane/core/element/demand_controller/auto_flow_utils.ex @@ -74,11 +74,6 @@ defmodule Membrane.Core.Element.DemandController.AutoFlowUtils do pad_data.flow_control == :auto and pad_data.demand < 0 end - @spec auto_flow_queue_empty?(Pad.ref(), State.t()) :: boolean() - def auto_flow_queue_empty?(pad_ref, state) do - PadModel.get_data!(state, pad_ref, :auto_flow_queue) == Qex.new() - end - @spec store_buffers_in_queue(Pad.ref(), [Buffer.t()], State.t()) :: State.t() def store_buffers_in_queue(pad_ref, buffers, state) do store_in_queue(pad_ref, :buffers, buffers, state) @@ -186,7 +181,7 @@ defmodule Membrane.Core.Element.DemandController.AutoFlowUtils do exec_queue_item_callback(selected_pad, queue_item, state) |> PadModel.set_data!(selected_pad, :auto_flow_queue, popped_queue) - do_flush_auto_flow_queues(pads_to_flush, state) + do_flush_auto_flow_queues(pads_to_flush, state) {:empty, empty_queue} -> state = PadModel.set_data!(state, selected_pad, :auto_flow_queue, empty_queue) diff --git a/logs.txt b/logs.txt deleted file mode 100644 index 5c120e161..000000000 --- a/logs.txt +++ /dev/null @@ -1,3 +0,0 @@ - -BREAK: (a)bort (A)bort with dump (c)ontinue (p)roc info (i)nfo - (l)oaded (v)ersion (k)ill (D)b-tables (d)istribution