Lines Matching refs:appsrc
277 static void gst_app_src_set_latencies (GstAppSrc * appsrc,
295 static GstFlowReturn gst_app_src_push_buffer_action (GstAppSrc * appsrc,
297 static GstFlowReturn gst_app_src_push_buffer_list_action (GstAppSrc * appsrc,
299 static GstFlowReturn gst_app_src_push_sample_action (GstAppSrc * appsrc,
734 gst_app_src_init (GstAppSrc * appsrc) in gst_app_src_init() argument
738 priv = appsrc->priv = gst_app_src_get_instance_private (appsrc); in gst_app_src_init()
760 gst_base_src_set_live (GST_BASE_SRC (appsrc), DEFAULT_PROP_IS_LIVE); in gst_app_src_init()
797 GstAppSrc *appsrc = GST_APP_SRC_CAST (obj); in gst_app_src_dispose() local
798 GstAppSrcPrivate *priv = appsrc->priv; in gst_app_src_dispose()
801 GST_OBJECT_LOCK (appsrc); in gst_app_src_dispose()
810 GST_OBJECT_UNLOCK (appsrc); in gst_app_src_dispose()
815 gst_app_src_flush_queued (appsrc, FALSE); in gst_app_src_dispose()
826 GstAppSrc *appsrc = GST_APP_SRC_CAST (obj); in gst_app_src_finalize() local
827 GstAppSrcPrivate *priv = appsrc->priv; in gst_app_src_finalize()
841 GstAppSrc *appsrc = GST_APP_SRC (bsrc); in gst_app_src_internal_get_caps() local
844 GST_OBJECT_LOCK (appsrc); in gst_app_src_internal_get_caps()
845 if ((caps = appsrc->priv->current_caps)) in gst_app_src_internal_get_caps()
847 GST_OBJECT_UNLOCK (appsrc); in gst_app_src_internal_get_caps()
860 GST_DEBUG_OBJECT (appsrc, "caps: %" GST_PTR_FORMAT, caps); in gst_app_src_internal_get_caps()
868 GstAppSrc *appsrc = GST_APP_SRC_CAST (object); in gst_app_src_set_property() local
869 GstAppSrcPrivate *priv = appsrc->priv; in gst_app_src_set_property()
873 gst_app_src_set_caps (appsrc, gst_value_get_caps (value)); in gst_app_src_set_property()
876 gst_app_src_set_size (appsrc, g_value_get_int64 (value)); in gst_app_src_set_property()
879 gst_app_src_set_stream_type (appsrc, g_value_get_enum (value)); in gst_app_src_set_property()
882 gst_app_src_set_max_bytes (appsrc, g_value_get_uint64 (value)); in gst_app_src_set_property()
885 gst_app_src_set_max_buffers (appsrc, g_value_get_uint64 (value)); in gst_app_src_set_property()
888 gst_app_src_set_max_time (appsrc, g_value_get_uint64 (value)); in gst_app_src_set_property()
897 gst_base_src_set_live (GST_BASE_SRC (appsrc), in gst_app_src_set_property()
901 gst_app_src_set_latencies (appsrc, TRUE, g_value_get_int64 (value), in gst_app_src_set_property()
905 gst_app_src_set_latencies (appsrc, FALSE, -1, TRUE, in gst_app_src_set_property()
909 gst_app_src_set_emit_signals (appsrc, g_value_get_boolean (value)); in gst_app_src_set_property()
915 gst_app_src_set_duration (appsrc, g_value_get_uint64 (value)); in gst_app_src_set_property()
933 GstAppSrc *appsrc = GST_APP_SRC_CAST (object); in gst_app_src_get_property() local
934 GstAppSrcPrivate *priv = appsrc->priv; in gst_app_src_get_property()
938 g_value_take_boxed (value, gst_app_src_get_caps (appsrc)); in gst_app_src_get_property()
941 g_value_set_int64 (value, gst_app_src_get_size (appsrc)); in gst_app_src_get_property()
944 g_value_set_enum (value, gst_app_src_get_stream_type (appsrc)); in gst_app_src_get_property()
947 g_value_set_uint64 (value, gst_app_src_get_max_bytes (appsrc)); in gst_app_src_get_property()
950 g_value_set_uint64 (value, gst_app_src_get_max_buffers (appsrc)); in gst_app_src_get_property()
953 g_value_set_uint64 (value, gst_app_src_get_max_time (appsrc)); in gst_app_src_get_property()
962 g_value_set_boolean (value, gst_base_src_is_live (GST_BASE_SRC (appsrc))); in gst_app_src_get_property()
968 gst_app_src_get_latency (appsrc, &min, NULL); in gst_app_src_get_property()
976 gst_app_src_get_latency (appsrc, NULL, &max); in gst_app_src_get_property()
981 g_value_set_boolean (value, gst_app_src_get_emit_signals (appsrc)); in gst_app_src_get_property()
987 g_value_set_uint64 (value, gst_app_src_get_current_level_bytes (appsrc)); in gst_app_src_get_property()
991 gst_app_src_get_current_level_buffers (appsrc)); in gst_app_src_get_property()
994 g_value_set_uint64 (value, gst_app_src_get_current_level_time (appsrc)); in gst_app_src_get_property()
997 g_value_set_uint64 (value, gst_app_src_get_duration (appsrc)); in gst_app_src_get_property()
1014 GstAppSrc *appsrc = GST_APP_SRC_CAST (element); in gst_app_src_send_event() local
1015 GstAppSrcPrivate *priv = appsrc->priv; in gst_app_src_send_event()
1020 gst_app_src_flush_queued (appsrc, TRUE); in gst_app_src_send_event()
1025 GST_DEBUG_OBJECT (appsrc, "queue event: %" GST_PTR_FORMAT, event); in gst_app_src_send_event()
1045 GstAppSrc *appsrc = GST_APP_SRC_CAST (bsrc); in gst_app_src_unlock() local
1046 GstAppSrcPrivate *priv = appsrc->priv; in gst_app_src_unlock()
1049 GST_DEBUG_OBJECT (appsrc, "unlock start"); in gst_app_src_unlock()
1060 GstAppSrc *appsrc = GST_APP_SRC_CAST (bsrc); in gst_app_src_unlock_stop() local
1061 GstAppSrcPrivate *priv = appsrc->priv; in gst_app_src_unlock_stop()
1064 GST_DEBUG_OBJECT (appsrc, "unlock stop"); in gst_app_src_unlock_stop()
1075 GstAppSrc *appsrc = GST_APP_SRC_CAST (bsrc); in gst_app_src_start() local
1076 GstAppSrcPrivate *priv = appsrc->priv; in gst_app_src_start()
1079 GST_DEBUG_OBJECT (appsrc, "starting"); in gst_app_src_start()
1098 GstAppSrc *appsrc = GST_APP_SRC_CAST (bsrc); in gst_app_src_stop() local
1099 GstAppSrcPrivate *priv = appsrc->priv; in gst_app_src_stop()
1102 GST_DEBUG_OBJECT (appsrc, "stopping"); in gst_app_src_stop()
1106 gst_app_src_flush_queued (appsrc, TRUE); in gst_app_src_stop()
1116 GstAppSrc *appsrc = GST_APP_SRC_CAST (src); in gst_app_src_is_seekable() local
1117 GstAppSrcPrivate *priv = appsrc->priv; in gst_app_src_is_seekable()
1134 GstAppSrc *appsrc = GST_APP_SRC_CAST (src); in gst_app_src_do_get_size() local
1136 *size = gst_app_src_get_size (appsrc); in gst_app_src_do_get_size()
1144 GstAppSrc *appsrc = GST_APP_SRC_CAST (src); in gst_app_src_query() local
1145 GstAppSrcPrivate *priv = appsrc->priv; in gst_app_src_query()
1215 GstAppSrc *appsrc = GST_APP_SRC_CAST (src); in gst_app_src_do_seek() local
1216 GstAppSrcPrivate *priv = appsrc->priv; in gst_app_src_do_seek()
1228 GST_DEBUG_OBJECT (appsrc, "seeking to %" G_GINT64_FORMAT ", format %s", in gst_app_src_do_seek()
1239 callbacks->callbacks.seek_data (appsrc, desired_position, in gst_app_src_do_seek()
1242 g_signal_emit (appsrc, gst_app_src_signals[SIGNAL_SEEK_DATA], 0, in gst_app_src_do_seek()
1249 GST_DEBUG_OBJECT (appsrc, "flushing queue"); in gst_app_src_do_seek()
1251 gst_app_src_flush_queued (appsrc, TRUE); in gst_app_src_do_seek()
1258 GST_WARNING_OBJECT (appsrc, "seek failed"); in gst_app_src_do_seek()
1266 gst_app_src_emit_seek (GstAppSrc * appsrc, guint64 offset) in gst_app_src_emit_seek() argument
1270 GstAppSrcPrivate *priv = appsrc->priv; in gst_app_src_emit_seek()
1278 GST_DEBUG_OBJECT (appsrc, in gst_app_src_emit_seek()
1283 res = callbacks->callbacks.seek_data (appsrc, offset, callbacks->user_data); in gst_app_src_emit_seek()
1285 g_signal_emit (appsrc, gst_app_src_signals[SIGNAL_SEEK_DATA], 0, in gst_app_src_emit_seek()
1298 gst_app_src_emit_need_data (GstAppSrc * appsrc, guint size) in gst_app_src_emit_need_data() argument
1301 GstAppSrcPrivate *priv = appsrc->priv; in gst_app_src_emit_need_data()
1311 callbacks->callbacks.need_data (appsrc, size, callbacks->user_data); in gst_app_src_emit_need_data()
1313 g_signal_emit (appsrc, gst_app_src_signals[SIGNAL_NEED_DATA], 0, size, in gst_app_src_emit_need_data()
1326 GstAppSrc *appsrc = GST_APP_SRC_CAST (basesrc); in gst_app_src_do_negotiate() local
1327 GstAppSrcPrivate *priv = appsrc->priv; in gst_app_src_do_negotiate()
1352 GstAppSrc *appsrc = GST_APP_SRC_CAST (basesrc); in gst_app_src_negotiate() local
1353 GstAppSrcPrivate *priv = appsrc->priv; in gst_app_src_negotiate()
1369 gst_app_src_update_queued_pop (GstAppSrc * appsrc, GstMiniObject * item, in gst_app_src_update_queued_pop() argument
1372 GstAppSrcPrivate *priv = appsrc->priv; in gst_app_src_update_queued_pop()
1387 GST_LOG_OBJECT (appsrc, "have buffer %p of size %u", buf, buf_size); in gst_app_src_update_queued_pop()
1429 GST_TRACE_OBJECT (appsrc, in gst_app_src_update_queued_pop()
1450 GST_DEBUG_OBJECT (appsrc, in gst_app_src_update_queued_pop()
1465 gst_app_src_update_queued_push (GstAppSrc * appsrc, GstMiniObject * item) in gst_app_src_update_queued_push() argument
1467 GstAppSrcPrivate *priv = appsrc->priv; in gst_app_src_update_queued_push()
1538 GST_TRACE_OBJECT (appsrc, in gst_app_src_update_queued_push()
1554 GST_DEBUG_OBJECT (appsrc, in gst_app_src_update_queued_push()
1564 GstAppSrc *appsrc = GST_APP_SRC_CAST (bsrc); in gst_app_src_create() local
1565 GstAppSrcPrivate *priv = appsrc->priv; in gst_app_src_create()
1568 GST_OBJECT_LOCK (appsrc); in gst_app_src_create()
1571 GST_DEBUG_OBJECT (appsrc, in gst_app_src_create()
1575 GST_OBJECT_UNLOCK (appsrc); in gst_app_src_create()
1577 gst_element_post_message (GST_ELEMENT (appsrc), in gst_app_src_create()
1578 gst_message_new_duration_changed (GST_OBJECT (appsrc))); in gst_app_src_create()
1581 GST_DEBUG_OBJECT (appsrc, in gst_app_src_create()
1585 GST_OBJECT_UNLOCK (appsrc); in gst_app_src_create()
1587 gst_element_post_message (GST_ELEMENT (appsrc), in gst_app_src_create()
1588 gst_message_new_duration_changed (GST_OBJECT (appsrc))); in gst_app_src_create()
1590 GST_OBJECT_UNLOCK (appsrc); in gst_app_src_create()
1605 res = gst_app_src_emit_seek (appsrc, offset); in gst_app_src_create()
1681 GST_DEBUG_OBJECT (appsrc, "pop event %" GST_PTR_FORMAT, event); in gst_app_src_create()
1690 GST_DEBUG_OBJECT (appsrc, in gst_app_src_create()
1693 GST_ERROR_OBJECT (appsrc, in gst_app_src_create()
1712 gst_pad_get_sticky_event (GST_BASE_SRC_PAD (appsrc), in gst_app_src_create()
1717 GST_DEBUG_OBJECT (appsrc, in gst_app_src_create()
1721 gst_pad_push_event (GST_BASE_SRC_PAD (appsrc), seg_event); in gst_app_src_create()
1726 gst_pad_push_event (GST_BASE_SRC_PAD (appsrc), event); in gst_app_src_create()
1735 gst_app_src_update_queued_pop (appsrc, obj, TRUE); in gst_app_src_create()
1752 gst_app_src_emit_need_data (appsrc, size); in gst_app_src_create()
1758 gst_app_src_emit_need_data (appsrc, size); in gst_app_src_create()
1790 GST_DEBUG_OBJECT (appsrc, "we are flushing"); in gst_app_src_create()
1796 GST_DEBUG_OBJECT (appsrc, "we are EOS"); in gst_app_src_create()
1803 GST_ELEMENT_ERROR (appsrc, RESOURCE, READ, ("failed to seek"), in gst_app_src_create()
1811 GST_ELEMENT_ERROR (appsrc, LIBRARY, SETTINGS, in gst_app_src_create()
1830 gst_app_src_set_caps (GstAppSrc * appsrc, const GstCaps * caps) in gst_app_src_set_caps() argument
1835 g_return_if_fail (GST_IS_APP_SRC (appsrc)); in gst_app_src_set_caps()
1837 priv = appsrc->priv; in gst_app_src_set_caps()
1841 GST_OBJECT_LOCK (appsrc); in gst_app_src_set_caps()
1852 GST_DEBUG_OBJECT (appsrc, "setting caps to %" GST_PTR_FORMAT, caps); in gst_app_src_set_caps()
1864 GST_OBJECT_UNLOCK (appsrc); in gst_app_src_set_caps()
1878 gst_app_src_get_caps (GstAppSrc * appsrc) in gst_app_src_get_caps() argument
1883 g_return_val_if_fail (GST_IS_APP_SRC (appsrc), NULL); in gst_app_src_get_caps()
1885 GST_OBJECT_LOCK (appsrc); in gst_app_src_get_caps()
1886 if ((caps = appsrc->priv->last_caps)) in gst_app_src_get_caps()
1888 GST_OBJECT_UNLOCK (appsrc); in gst_app_src_get_caps()
1903 gst_app_src_set_size (GstAppSrc * appsrc, gint64 size) in gst_app_src_set_size() argument
1907 g_return_if_fail (GST_IS_APP_SRC (appsrc)); in gst_app_src_set_size()
1909 priv = appsrc->priv; in gst_app_src_set_size()
1911 GST_OBJECT_LOCK (appsrc); in gst_app_src_set_size()
1912 GST_DEBUG_OBJECT (appsrc, "setting size of %" G_GINT64_FORMAT, size); in gst_app_src_set_size()
1914 GST_OBJECT_UNLOCK (appsrc); in gst_app_src_set_size()
1927 gst_app_src_get_size (GstAppSrc * appsrc) in gst_app_src_get_size() argument
1932 g_return_val_if_fail (GST_IS_APP_SRC (appsrc), -1); in gst_app_src_get_size()
1934 priv = appsrc->priv; in gst_app_src_get_size()
1936 GST_OBJECT_LOCK (appsrc); in gst_app_src_get_size()
1938 GST_DEBUG_OBJECT (appsrc, "getting size of %" G_GINT64_FORMAT, size); in gst_app_src_get_size()
1939 GST_OBJECT_UNLOCK (appsrc); in gst_app_src_get_size()
1955 gst_app_src_set_duration (GstAppSrc * appsrc, GstClockTime duration) in gst_app_src_set_duration() argument
1959 g_return_if_fail (GST_IS_APP_SRC (appsrc)); in gst_app_src_set_duration()
1961 priv = appsrc->priv; in gst_app_src_set_duration()
1963 GST_OBJECT_LOCK (appsrc); in gst_app_src_set_duration()
1964 GST_DEBUG_OBJECT (appsrc, "setting duration of %" GST_TIME_FORMAT, in gst_app_src_set_duration()
1967 GST_OBJECT_UNLOCK (appsrc); in gst_app_src_set_duration()
1982 gst_app_src_get_duration (GstAppSrc * appsrc) in gst_app_src_get_duration() argument
1987 g_return_val_if_fail (GST_IS_APP_SRC (appsrc), GST_CLOCK_TIME_NONE); in gst_app_src_get_duration()
1989 priv = appsrc->priv; in gst_app_src_get_duration()
1991 GST_OBJECT_LOCK (appsrc); in gst_app_src_get_duration()
1993 GST_DEBUG_OBJECT (appsrc, "getting duration of %" GST_TIME_FORMAT, in gst_app_src_get_duration()
1995 GST_OBJECT_UNLOCK (appsrc); in gst_app_src_get_duration()
2011 gst_app_src_set_stream_type (GstAppSrc * appsrc, GstAppStreamType type) in gst_app_src_set_stream_type() argument
2015 g_return_if_fail (GST_IS_APP_SRC (appsrc)); in gst_app_src_set_stream_type()
2017 priv = appsrc->priv; in gst_app_src_set_stream_type()
2019 GST_OBJECT_LOCK (appsrc); in gst_app_src_set_stream_type()
2020 GST_DEBUG_OBJECT (appsrc, "setting stream_type of %d", type); in gst_app_src_set_stream_type()
2022 GST_OBJECT_UNLOCK (appsrc); in gst_app_src_set_stream_type()
2035 gst_app_src_get_stream_type (GstAppSrc * appsrc) in gst_app_src_get_stream_type() argument
2040 g_return_val_if_fail (GST_IS_APP_SRC (appsrc), FALSE); in gst_app_src_get_stream_type()
2042 priv = appsrc->priv; in gst_app_src_get_stream_type()
2044 GST_OBJECT_LOCK (appsrc); in gst_app_src_get_stream_type()
2046 GST_DEBUG_OBJECT (appsrc, "getting stream_type of %d", stream_type); in gst_app_src_get_stream_type()
2047 GST_OBJECT_UNLOCK (appsrc); in gst_app_src_get_stream_type()
2062 gst_app_src_set_max_bytes (GstAppSrc * appsrc, guint64 max) in gst_app_src_set_max_bytes() argument
2066 g_return_if_fail (GST_IS_APP_SRC (appsrc)); in gst_app_src_set_max_bytes()
2068 priv = appsrc->priv; in gst_app_src_set_max_bytes()
2072 GST_DEBUG_OBJECT (appsrc, "setting max-bytes to %" G_GUINT64_FORMAT, max); in gst_app_src_set_max_bytes()
2089 gst_app_src_get_max_bytes (GstAppSrc * appsrc) in gst_app_src_get_max_bytes() argument
2094 g_return_val_if_fail (GST_IS_APP_SRC (appsrc), 0); in gst_app_src_get_max_bytes()
2096 priv = appsrc->priv; in gst_app_src_get_max_bytes()
2100 GST_DEBUG_OBJECT (appsrc, "getting max-bytes of %" G_GUINT64_FORMAT, result); in gst_app_src_get_max_bytes()
2117 gst_app_src_get_current_level_bytes (GstAppSrc * appsrc) in gst_app_src_get_current_level_bytes() argument
2122 g_return_val_if_fail (GST_IS_APP_SRC (appsrc), -1); in gst_app_src_get_current_level_bytes()
2124 priv = appsrc->priv; in gst_app_src_get_current_level_bytes()
2126 GST_OBJECT_LOCK (appsrc); in gst_app_src_get_current_level_bytes()
2128 GST_DEBUG_OBJECT (appsrc, "current level bytes is %" G_GUINT64_FORMAT, in gst_app_src_get_current_level_bytes()
2130 GST_OBJECT_UNLOCK (appsrc); in gst_app_src_get_current_level_bytes()
2147 gst_app_src_set_max_buffers (GstAppSrc * appsrc, guint64 max) in gst_app_src_set_max_buffers() argument
2151 g_return_if_fail (GST_IS_APP_SRC (appsrc)); in gst_app_src_set_max_buffers()
2153 priv = appsrc->priv; in gst_app_src_set_max_buffers()
2157 GST_DEBUG_OBJECT (appsrc, "setting max-buffers to %" G_GUINT64_FORMAT, max); in gst_app_src_set_max_buffers()
2176 gst_app_src_get_max_buffers (GstAppSrc * appsrc) in gst_app_src_get_max_buffers() argument
2181 g_return_val_if_fail (GST_IS_APP_SRC (appsrc), 0); in gst_app_src_get_max_buffers()
2183 priv = appsrc->priv; in gst_app_src_get_max_buffers()
2187 GST_DEBUG_OBJECT (appsrc, "getting max-buffers of %" G_GUINT64_FORMAT, in gst_app_src_get_max_buffers()
2205 gst_app_src_get_current_level_buffers (GstAppSrc * appsrc) in gst_app_src_get_current_level_buffers() argument
2210 g_return_val_if_fail (GST_IS_APP_SRC (appsrc), -1); in gst_app_src_get_current_level_buffers()
2212 priv = appsrc->priv; in gst_app_src_get_current_level_buffers()
2214 GST_OBJECT_LOCK (appsrc); in gst_app_src_get_current_level_buffers()
2216 GST_DEBUG_OBJECT (appsrc, "current level buffers is %" G_GUINT64_FORMAT, in gst_app_src_get_current_level_buffers()
2218 GST_OBJECT_UNLOCK (appsrc); in gst_app_src_get_current_level_buffers()
2235 gst_app_src_set_max_time (GstAppSrc * appsrc, GstClockTime max) in gst_app_src_set_max_time() argument
2239 g_return_if_fail (GST_IS_APP_SRC (appsrc)); in gst_app_src_set_max_time()
2241 priv = appsrc->priv; in gst_app_src_set_max_time()
2245 GST_DEBUG_OBJECT (appsrc, "setting max-time to %" GST_TIME_FORMAT, in gst_app_src_set_max_time()
2265 gst_app_src_get_max_time (GstAppSrc * appsrc) in gst_app_src_get_max_time() argument
2270 g_return_val_if_fail (GST_IS_APP_SRC (appsrc), 0); in gst_app_src_get_max_time()
2272 priv = appsrc->priv; in gst_app_src_get_max_time()
2276 GST_DEBUG_OBJECT (appsrc, "getting max-time of %" GST_TIME_FORMAT, in gst_app_src_get_max_time()
2294 gst_app_src_get_current_level_time (GstAppSrc * appsrc) in gst_app_src_get_current_level_time() argument
2299 g_return_val_if_fail (GST_IS_APP_SRC (appsrc), GST_CLOCK_TIME_NONE); in gst_app_src_get_current_level_time()
2301 priv = appsrc->priv; in gst_app_src_get_current_level_time()
2303 GST_OBJECT_LOCK (appsrc); in gst_app_src_get_current_level_time()
2305 GST_DEBUG_OBJECT (appsrc, "current level time is %" GST_TIME_FORMAT, in gst_app_src_get_current_level_time()
2307 GST_OBJECT_UNLOCK (appsrc); in gst_app_src_get_current_level_time()
2313 gst_app_src_set_latencies (GstAppSrc * appsrc, gboolean do_min, guint64 min, in gst_app_src_set_latencies() argument
2316 GstAppSrcPrivate *priv = appsrc->priv; in gst_app_src_set_latencies()
2331 GST_DEBUG_OBJECT (appsrc, "posting latency changed"); in gst_app_src_set_latencies()
2332 gst_element_post_message (GST_ELEMENT_CAST (appsrc), in gst_app_src_set_latencies()
2333 gst_message_new_latency (GST_OBJECT_CAST (appsrc))); in gst_app_src_set_latencies()
2350 gst_app_src_set_leaky_type (GstAppSrc * appsrc, GstAppLeakyType leaky) in gst_app_src_set_leaky_type() argument
2352 g_return_if_fail (GST_IS_APP_SRC (appsrc)); in gst_app_src_set_leaky_type()
2354 appsrc->priv->leaky_type = leaky; in gst_app_src_set_leaky_type()
2369 gst_app_src_get_leaky_type (GstAppSrc * appsrc) in gst_app_src_get_leaky_type() argument
2371 g_return_val_if_fail (GST_IS_APP_SRC (appsrc), GST_APP_LEAKY_TYPE_NONE); in gst_app_src_get_leaky_type()
2373 return appsrc->priv->leaky_type; in gst_app_src_get_leaky_type()
2386 gst_app_src_set_latency (GstAppSrc * appsrc, guint64 min, guint64 max) in gst_app_src_set_latency() argument
2388 gst_app_src_set_latencies (appsrc, TRUE, min, TRUE, max); in gst_app_src_set_latency()
2400 gst_app_src_get_latency (GstAppSrc * appsrc, guint64 * min, guint64 * max) in gst_app_src_get_latency() argument
2404 g_return_if_fail (GST_IS_APP_SRC (appsrc)); in gst_app_src_get_latency()
2406 priv = appsrc->priv; in gst_app_src_get_latency()
2426 gst_app_src_set_emit_signals (GstAppSrc * appsrc, gboolean emit) in gst_app_src_set_emit_signals() argument
2430 g_return_if_fail (GST_IS_APP_SRC (appsrc)); in gst_app_src_set_emit_signals()
2432 priv = appsrc->priv; in gst_app_src_set_emit_signals()
2449 gst_app_src_get_emit_signals (GstAppSrc * appsrc) in gst_app_src_get_emit_signals() argument
2454 g_return_val_if_fail (GST_IS_APP_SRC (appsrc), FALSE); in gst_app_src_get_emit_signals()
2456 priv = appsrc->priv; in gst_app_src_get_emit_signals()
2466 gst_app_src_push_internal (GstAppSrc * appsrc, GstBuffer * buffer, in gst_app_src_push_internal() argument
2472 g_return_val_if_fail (GST_IS_APP_SRC (appsrc), GST_FLOW_ERROR); in gst_app_src_push_internal()
2474 priv = appsrc->priv; in gst_app_src_push_internal()
2490 gst_base_src_get_do_timestamp (GST_BASE_SRC_CAST (appsrc))) { in gst_app_src_push_internal()
2493 clock = gst_element_get_clock (GST_ELEMENT_CAST (appsrc)); in gst_app_src_push_internal()
2497 gst_element_get_base_time (GST_ELEMENT_CAST (appsrc)); in gst_app_src_push_internal()
2526 GST_WARNING_OBJECT (appsrc, in gst_app_src_push_internal()
2546 GST_DEBUG_OBJECT (appsrc, in gst_app_src_push_internal()
2566 callbacks->callbacks.enough_data (appsrc, callbacks->user_data); in gst_app_src_push_internal()
2568 g_signal_emit (appsrc, gst_app_src_signals[SIGNAL_ENOUGH_DATA], 0, in gst_app_src_push_internal()
2597 GST_FIXME_OBJECT (appsrc, in gst_app_src_push_internal()
2604 GST_WARNING_OBJECT (appsrc, "Dropping old item %" GST_PTR_FORMAT, item); in gst_app_src_push_internal()
2606 gst_app_src_update_queued_pop (appsrc, item, FALSE); in gst_app_src_push_internal()
2619 GST_DEBUG_OBJECT (appsrc, "waiting for free space"); in gst_app_src_push_internal()
2639 GST_DEBUG_OBJECT (appsrc, "enqueue new segment %" GST_PTR_FORMAT, event); in gst_app_src_push_internal()
2659 GST_DEBUG_OBJECT (appsrc, "queueing buffer list %p", buflist); in gst_app_src_push_internal()
2678 GST_DEBUG_OBJECT (appsrc, "queueing buffer %p", buffer); in gst_app_src_push_internal()
2684 gst_app_src_update_queued_push (appsrc, in gst_app_src_push_internal()
2697 GST_DEBUG_OBJECT (appsrc, "refuse buffer %p, we are flushing", buffer); in gst_app_src_push_internal()
2709 GST_DEBUG_OBJECT (appsrc, "refuse buffer %p, we are EOS", buffer); in gst_app_src_push_internal()
2721 GST_DEBUG_OBJECT (appsrc, "dropped new buffer %p, we are full", buffer); in gst_app_src_push_internal()
2734 gst_app_src_push_buffer_full (GstAppSrc * appsrc, GstBuffer * buffer, in gst_app_src_push_buffer_full() argument
2737 return gst_app_src_push_internal (appsrc, buffer, NULL, steal_ref); in gst_app_src_push_buffer_full()
2741 gst_app_src_push_sample_internal (GstAppSrc * appsrc, GstSample * sample) in gst_app_src_push_sample_internal() argument
2743 GstAppSrcPrivate *priv = appsrc->priv; in gst_app_src_push_sample_internal()
2752 gst_app_src_set_caps (appsrc, caps); in gst_app_src_push_sample_internal()
2754 GST_WARNING_OBJECT (appsrc, "received sample without caps"); in gst_app_src_push_sample_internal()
2761 GST_LOG_OBJECT (appsrc, "format %s is not supported", in gst_app_src_push_sample_internal()
2768 GST_LOG_OBJECT (appsrc, "segment wasn't changed"); in gst_app_src_push_sample_internal()
2772 GST_LOG_OBJECT (appsrc, in gst_app_src_push_sample_internal()
2787 return gst_app_src_push_buffer_full (appsrc, buffer, FALSE); in gst_app_src_push_sample_internal()
2791 return gst_app_src_push_internal (appsrc, NULL, buffer_list, FALSE); in gst_app_src_push_sample_internal()
2793 GST_WARNING_OBJECT (appsrc, "received sample without buffer or buffer list"); in gst_app_src_push_sample_internal()
2813 gst_app_src_push_buffer (GstAppSrc * appsrc, GstBuffer * buffer) in gst_app_src_push_buffer() argument
2815 return gst_app_src_push_buffer_full (appsrc, buffer, TRUE); in gst_app_src_push_buffer()
2837 gst_app_src_push_buffer_list (GstAppSrc * appsrc, GstBufferList * buffer_list) in gst_app_src_push_buffer_list() argument
2839 return gst_app_src_push_internal (appsrc, NULL, buffer_list, TRUE); in gst_app_src_push_buffer_list()
2867 gst_app_src_push_sample (GstAppSrc * appsrc, GstSample * sample) in gst_app_src_push_sample() argument
2869 return gst_app_src_push_sample_internal (appsrc, sample); in gst_app_src_push_sample()
2875 gst_app_src_push_buffer_action (GstAppSrc * appsrc, GstBuffer * buffer) in gst_app_src_push_buffer_action() argument
2877 return gst_app_src_push_buffer_full (appsrc, buffer, FALSE); in gst_app_src_push_buffer_action()
2883 gst_app_src_push_buffer_list_action (GstAppSrc * appsrc, in gst_app_src_push_buffer_list_action() argument
2886 return gst_app_src_push_internal (appsrc, NULL, buffer_list, FALSE); in gst_app_src_push_buffer_list_action()
2892 gst_app_src_push_sample_action (GstAppSrc * appsrc, GstSample * sample) in gst_app_src_push_sample_action() argument
2894 return gst_app_src_push_sample_internal (appsrc, sample); in gst_app_src_push_sample_action()
2908 gst_app_src_end_of_stream (GstAppSrc * appsrc) in gst_app_src_end_of_stream() argument
2912 g_return_val_if_fail (GST_IS_APP_SRC (appsrc), GST_FLOW_ERROR); in gst_app_src_end_of_stream()
2914 priv = appsrc->priv; in gst_app_src_end_of_stream()
2922 GST_DEBUG_OBJECT (appsrc, "sending EOS"); in gst_app_src_end_of_stream()
2933 GST_DEBUG_OBJECT (appsrc, "refuse EOS, we are flushing"); in gst_app_src_end_of_stream()
2957 gst_app_src_set_callbacks (GstAppSrc * appsrc, in gst_app_src_set_callbacks() argument
2963 g_return_if_fail (GST_IS_APP_SRC (appsrc)); in gst_app_src_set_callbacks()
2966 priv = appsrc->priv; in gst_app_src_set_callbacks()
3003 GstAppSrc *appsrc = GST_APP_SRC (handler); in gst_app_src_uri_get_uri() local
3005 return appsrc->priv->uri ? g_strdup (appsrc->priv->uri) : NULL; in gst_app_src_uri_get_uri()
3012 GstAppSrc *appsrc = GST_APP_SRC (handler); in gst_app_src_uri_set_uri() local
3014 g_free (appsrc->priv->uri); in gst_app_src_uri_set_uri()
3015 appsrc->priv->uri = uri ? g_strdup (uri) : NULL; in gst_app_src_uri_set_uri()
3034 GstAppSrc *appsrc = GST_APP_SRC_CAST (src); in gst_app_src_event() local
3035 GstAppSrcPrivate *priv = appsrc->priv; in gst_app_src_event()