94 static void split_now (GstSplitMuxSink * splitmux);
95 static void split_after (GstSplitMuxSink * splitmux);
96 static void split_at_running_time (GstSplitMuxSink * splitmux,
214 G_DEFINE_TYPE_EXTENDED (GstSplitMuxSink, gst_splitmux_sink, GST_TYPE_BIN, 0,
219 static gboolean create_muxer (GstSplitMuxSink * splitmux);
220 static gboolean create_sink (GstSplitMuxSink * splitmux);
236 static void set_next_filename (GstSplitMuxSink * splitmux, MqStreamCtx * ctx);
237 static GstFlowReturn start_next_fragment (GstSplitMuxSink * splitmux,
240 static void grow_blocked_queues (GstSplitMuxSink * splitmux);
242 static void gst_splitmux_sink_ensure_max_files (GstSplitMuxSink * splitmux);
243 static GstElement *create_element (GstSplitMuxSink * splitmux,
246 static void do_async_done (GstSplitMuxSink * splitmux);
248 static GstClockTime calculate_next_max_timecode (GstSplitMuxSink * splitmux,
595 gst_splitmux_sink_init (GstSplitMuxSink * splitmux)  in gst_splitmux_sink_init()
630 gst_splitmux_reset_elements (GstSplitMuxSink * splitmux)  in gst_splitmux_reset_elements()
649   GstSplitMuxSink *splitmux = GST_SPLITMUX_SINK (object);  in gst_splitmux_sink_dispose()
660   GstSplitMuxSink *splitmux = GST_SPLITMUX_SINK (object);  in gst_splitmux_sink_finalize()
718 update_muxer_properties (GstSplitMuxSink * sink)  in update_muxer_properties()
751   GstSplitMuxSink *splitmux = GST_SPLITMUX_SINK (object);  in gst_splitmux_sink_set_property()
932   GstSplitMuxSink *splitmux = GST_SPLITMUX_SINK (object);  in gst_splitmux_sink_get_property()
1074 mq_stream_ctx_new (GstSplitMuxSink * splitmux)  in mq_stream_ctx_new()
1110 send_fragment_opened_closed_msg (GstSplitMuxSink * splitmux, gboolean opened,  in send_fragment_opened_closed_msg()
1148 send_eos_async (GstSplitMuxSink * splitmux, AsyncEosHelper * helper)  in send_eos_async()
1174 send_eos (GstSplitMuxSink * splitmux, MqStreamCtx * ctx)  in send_eos()
1195 eos_context_async (MqStreamCtx * ctx, GstSplitMuxSink * splitmux)  in eos_context_async()
1227 all_contexts_are_async_eos (GstSplitMuxSink * splitmux)  in all_contexts_are_async_eos()
1244 complete_or_wait_on_out (GstSplitMuxSink * splitmux, MqStreamCtx * ctx)  in complete_or_wait_on_out()
1401 calculate_next_max_timecode (GstSplitMuxSink * splitmux,  in calculate_next_max_timecode()
1478 request_next_keyframe (GstSplitMuxSink * splitmux, GstBuffer * buffer,  in request_next_keyframe()
1640   GstSplitMuxSink *splitmux = ctx->splitmux;  in handle_mq_output()
1892 unlock_context (MqStreamCtx * ctx, GstSplitMuxSink * splitmux)  in unlock_context()
1901 restart_context (MqStreamCtx * ctx, GstSplitMuxSink * splitmux)  in restart_context()
1916 relink_context (MqStreamCtx * ctx, GstSplitMuxSink * splitmux)  in relink_context()
1958 block_context (MqStreamCtx * ctx, GstSplitMuxSink * splitmux)  in block_context()
1978 _lock_and_set_to_null (GstElement * element, GstSplitMuxSink * splitmux)  in _lock_and_set_to_null()
2001 start_next_fragment (GstSplitMuxSink * splitmux, MqStreamCtx * ctx)  in start_next_fragment()
2206   GstSplitMuxSink *splitmux = GST_SPLITMUX_SINK (bin);  in bus_handler()
2332 need_new_fragment (GstSplitMuxSink * splitmux,  in need_new_fragment()
2474 static void continue_execution (GstSplitMuxSink * splitmux, GstClockTimeDiff max_out_running_time)  in continue_execution()
2501 handle_gathered_gop (GstSplitMuxSink * splitmux, const InputGop * gop,  in handle_gathered_gop()
2643 check_completed_gop (GstSplitMuxSink * splitmux, MqStreamCtx * ctx)  in check_completed_gop()
2819   GstSplitMuxSink *splitmux = ctx->splitmux;  in handle_mq_input()
3302 grow_blocked_queues (GstSplitMuxSink * splitmux)  in grow_blocked_queues()
3330   GstSplitMuxSink *splitmux = ctx->splitmux;  in handle_q_underrun()
3344   GstSplitMuxSink *splitmux = ctx->splitmux;  in handle_q_overrun()
3386 lookup_muxer_pad (GstSplitMuxSink * splitmux, const gchar * sinkpad_name)  in lookup_muxer_pad()
3413   GstSplitMuxSink *splitmux = (GstSplitMuxSink *) element;  in gst_splitmux_sink_request_new_pad()
3629   GstSplitMuxSink *splitmux = (GstSplitMuxSink *) element;  in gst_splitmux_sink_release_pad()
3692 create_element (GstSplitMuxSink * splitmux,  in create_element()
3718 create_muxer (GstSplitMuxSink * splitmux)  in create_muxer()
3816 create_sink (GstSplitMuxSink * splitmux)  in create_sink()
3894 set_next_filename (GstSplitMuxSink * splitmux, MqStreamCtx * ctx)  in set_next_filename()
3937 do_async_start (GstSplitMuxSink * splitmux)  in do_async_start()
3959 do_async_done (GstSplitMuxSink * splitmux)  in do_async_done()
3980 gst_splitmux_sink_reset (GstSplitMuxSink * splitmux)  in gst_splitmux_sink_reset()
4015   GstSplitMuxSink *splitmux = (GstSplitMuxSink *) element;  in gst_splitmux_sink_change_state()
4127 gst_splitmux_sink_ensure_max_files (GstSplitMuxSink * splitmux)  in gst_splitmux_sink_ensure_max_files()
4135 split_now (GstSplitMuxSink * splitmux)  in split_now()
4141 split_after (GstSplitMuxSink * splitmux)  in split_after()
4147 split_at_running_time (GstSplitMuxSink * splitmux, GstClockTime split_time)  in split_at_running_time()