| /third_party/gstreamer/gstplugins_base/gst-libs/gst/app/ |
| D | gstappsrc.c | 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()
[all …]
|
| D | gstappsrc.h | 124 void (*need_data) (GstAppSrc *appsrc, guint length);
125 void (*enough_data) (GstAppSrc *appsrc);
126 gboolean (*seek_data) (GstAppSrc *appsrc, guint64 offset);
129 GstFlowReturn (*push_buffer) (GstAppSrc *appsrc, GstBuffer *buffer);
130 GstFlowReturn (*end_of_stream) (GstAppSrc *appsrc);
131 GstFlowReturn (*push_sample) (GstAppSrc *appsrc, GstSample *sample);
132 GstFlowReturn (*push_buffer_list) (GstAppSrc *appsrc, GstBufferList *buffer_list);
142 void gst_app_src_set_caps (GstAppSrc *appsrc, const GstCaps *caps);
145 GstCaps* gst_app_src_get_caps (GstAppSrc *appsrc);
148 void gst_app_src_set_size (GstAppSrc *appsrc, gint64 size);
[all …]
|
| /third_party/gstreamer/gstplugins_base/tests/examples/app/ |
| D | appsrc-ra.c | 53 GstElement *appsrc; member
69 feed_data (GstElement * appsrc, guint size, App * app) in feed_data() argument
76 g_signal_emit_by_name (app->appsrc, "end-of-stream", &ret); in feed_data()
96 g_signal_emit_by_name (app->appsrc, "push-buffer", buffer, &ret); in feed_data()
107 seek_data (GstElement * appsrc, guint64 position, App * app) in seek_data() argument
123 g_object_get (orig, pspec->name, &app->appsrc, NULL); in found_source()
125 GST_DEBUG ("got appsrc %p", app->appsrc); in found_source()
130 g_object_set (app->appsrc, "size", (gint64) app->length, NULL); in found_source()
131 gst_util_set_object_arg (G_OBJECT (app->appsrc), "stream-type", in found_source()
136 g_signal_connect (app->appsrc, "need-data", G_CALLBACK (feed_data), app); in found_source()
[all …]
|
| D | appsrc-seekable.c | 55 GstElement *appsrc; member
73 feed_data (GstElement * appsrc, guint size, App * app) in feed_data() argument
81 g_signal_emit_by_name (app->appsrc, "end-of-stream", &ret); in feed_data()
98 g_signal_emit_by_name (app->appsrc, "push-buffer", buffer, &ret); in feed_data()
109 seek_data (GstElement * appsrc, guint64 position, App * app) in seek_data() argument
125 g_object_get (orig, pspec->name, &app->appsrc, NULL); in found_source()
127 GST_DEBUG ("got appsrc %p", app->appsrc); in found_source()
132 g_object_set (app->appsrc, "size", (gint64) app->length, NULL); in found_source()
136 gst_util_set_object_arg (G_OBJECT (app->appsrc), "stream-type", "seekable"); in found_source()
140 g_signal_connect (app->appsrc, "need-data", G_CALLBACK (feed_data), app); in found_source()
[all …]
|
| D | appsrc-stream2.c | 62 GstElement *appsrc; member
80 feed_data (GstElement * appsrc, guint size, App * app) in feed_data() argument
88 g_signal_emit_by_name (app->appsrc, "end-of-stream", &ret); in feed_data()
105 g_signal_emit_by_name (app->appsrc, "push-buffer", buffer, &ret); in feed_data()
120 g_object_get (orig, pspec->name, &app->appsrc, NULL); in found_source()
122 GST_DEBUG ("got appsrc %p", app->appsrc); in found_source()
127 g_object_set (app->appsrc, "size", (gint64) app->length, NULL); in found_source()
131 g_signal_connect (app->appsrc, "need-data", G_CALLBACK (feed_data), app); in found_source()
|
| D | appsrc-stream.c | 58 GstElement *appsrc; member
88 g_signal_emit_by_name (app->appsrc, "end-of-stream", &ret); in read_data()
105 g_signal_emit_by_name (app->appsrc, "push-buffer", buffer, &ret); in read_data()
148 g_object_get (orig, pspec->name, &app->appsrc, NULL); in found_source()
150 GST_DEBUG ("got appsrc %p", app->appsrc); in found_source()
155 g_object_set (app->appsrc, "size", (gint64) app->length, NULL); in found_source()
159 g_signal_connect (app->appsrc, "need-data", G_CALLBACK (start_feed), app); in found_source()
160 g_signal_connect (app->appsrc, "enough-data", G_CALLBACK (stop_feed), app); in found_source()
|
| D | meson.build | 3 'appsrc-stream',
4 'appsrc-stream2',
5 'appsrc-ra',
6 'appsrc-seekable',
|
| /third_party/gstreamer/gstplugins_bad/gst-libs/gst/basecamerabinsrc/ |
| D | gstcamerabinpreview.c | 144 data->appsrc = gst_element_factory_make ("appsrc", "preview-appsrc"); in gst_camerabin_create_preview_pipeline()
149 if (!data->appsrc || !data->appsink || !csp || !vscale) { in gst_camerabin_create_preview_pipeline()
153 g_object_set (data->appsrc, "emit-signals", FALSE, NULL); in gst_camerabin_create_preview_pipeline()
157 gst_bin_add_many (GST_BIN (data->pipeline), data->appsrc, in gst_camerabin_create_preview_pipeline()
165 GST_PAD_LINK_FAILED (gst_element_link_pads_full (data->appsrc, "src", in gst_camerabin_create_preview_pipeline()
172 GST_PAD_LINK_FAILED (gst_element_link_pads_full (data->appsrc, "src", in gst_camerabin_create_preview_pipeline()
214 if (data->appsrc) in gst_camerabin_create_preview_pipeline()
215 gst_object_unref (data->appsrc); in gst_camerabin_create_preview_pipeline()
283 g_object_set (preview->appsrc, "caps", gst_sample_get_caps (sample), NULL); in gst_camerabin_preview_pipeline_post()
284 gst_app_src_push_buffer ((GstAppSrc *) preview->appsrc, in gst_camerabin_preview_pipeline_post()
[all …]
|
| D | gstcamerabinpreview.h | 40 GstElement *appsrc; member
|
| /third_party/gstreamer/gstplugins_bad/tests/check/elements/ |
| D | assrender.c | 181 GstElement *appsrc, *videotestsrc, *capsfilter, *assrender, *fakesink; \
207 appsrc = gst_element_factory_make ("appsrc", NULL); \
208 fail_unless (appsrc != NULL); \
217 gst_app_src_set_caps (GST_APP_SRC (appsrc), text_caps); \
218 g_object_set (appsrc, "format", GST_FORMAT_TIME, NULL); \
219 pad = gst_element_get_static_pad (appsrc, "src"); \
238 gst_bin_add_many (GST_BIN (pipeline), appsrc, videotestsrc, capsfilter, \
241 fail_unless (gst_element_link_pads (appsrc, "src", assrender, "text_sink")); \
262 gst_app_src_push_buffer (GST_APP_SRC (appsrc), buf); \
264 gst_app_src_end_of_stream (GST_APP_SRC (appsrc)); \
|
| /third_party/pulseaudio/src/modules/rtp/ |
| D | rtp-gstreamer.c | 53 GstElement *appsrc; member
77 GstElement *appsrc = NULL, *pay = NULL, *capsf = NULL, *rtpbin = NULL, *sink = NULL; in init_send_pipeline() local
85 MAKE_ELEMENT(appsrc, "appsrc"); in init_send_pipeline()
93 gst_bin_add_many(GST_BIN(c->pipeline), appsrc, pay, capsf, rtpbin, sink, NULL); in init_send_pipeline()
112 …g_object_set(appsrc, "caps", caps, "is-live", TRUE, "blocksize", mtu, "format", 3 /* time */, NULL… in init_send_pipeline()
132 if (!gst_element_link(appsrc, pay) || in init_send_pipeline()
146 c->appsrc = gst_object_ref(appsrc); in init_send_pipeline()
155 if (appsrc) in init_send_pipeline()
156 gst_object_unref(appsrc); in init_send_pipeline()
300 if (gst_app_src_push_buffer(GST_APP_SRC(c->appsrc), buf) != GST_FLOW_OK) { in pa_rtp_send()
[all …]
|
| /third_party/gstreamer/gstplugins_bad/ext/webrtc/ |
| D | webrtcdatachannel.c | 314 pad = gst_element_get_static_pad (channel->appsrc, "src"); in _close_sctp_stream()
480 ret = gst_app_src_push_buffer (GST_APP_SRC (channel->appsrc), buffer); in _parse_control_packet()
709 if (gst_app_src_push_buffer (GST_APP_SRC (channel->appsrc), in webrtc_data_channel_start_negotiation()
793 ret = gst_app_src_push_buffer (GST_APP_SRC (channel->appsrc), buffer); in webrtc_data_channel_send_data()
856 ret = gst_app_src_push_buffer (GST_APP_SRC (channel->appsrc), buffer); in webrtc_data_channel_send_string()
948 channel->appsrc = gst_element_factory_make ("appsrc", NULL); in gst_webrtc_data_channel_constructed()
949 gst_object_ref_sink (channel->appsrc); in gst_webrtc_data_channel_constructed()
950 pad = gst_element_get_static_pad (channel->appsrc, "src"); in gst_webrtc_data_channel_constructed()
972 GstPad *pad = gst_element_get_static_pad (channel->appsrc, "src"); in gst_webrtc_data_channel_finalize()
982 g_clear_object (&channel->appsrc); in gst_webrtc_data_channel_finalize()
[all …]
|
| D | webrtcdatachannel.h | 49 GstElement *appsrc; member
|
| /third_party/gstreamer/gstplugins_good/tests/check/elements/ |
| D | splitmuxsrc.c | 420 GstElement *appsrc; in GST_START_TEST() local
448 appsrc = gst_bin_get_by_name (GST_BIN (pipeline), "appsrc"); in GST_START_TEST()
449 fail_if (appsrc == NULL); in GST_START_TEST()
452 appsrc_src = gst_element_get_static_pad (appsrc, "src"); in GST_START_TEST()
474 fail_if (gst_app_src_push_buffer (GST_APP_SRC (appsrc), buffer) in GST_START_TEST()
477 fail_if (gst_app_src_end_of_stream (GST_APP_SRC (appsrc)) != GST_FLOW_OK); in GST_START_TEST()
484 g_clear_object (&appsrc); in GST_START_TEST()
|
| D | rtp-payloading.c | 41 GstElement *appsrc; member
187 p->appsrc = gst_element_factory_make ("appsrc", NULL); in rtp_pipeline_create()
197 if (!p->pipeline || !p->appsrc || !p->rtppay || !p->rtpdepay || !p->fakesink) { in rtp_pipeline_create()
200 RELEASE_ELEMENT (p->appsrc); in rtp_pipeline_create()
213 g_object_set (p->appsrc, "do-timestamp", TRUE, "caps", caps, in rtp_pipeline_create()
218 gst_bin_add (GST_BIN (p->pipeline), p->appsrc); in rtp_pipeline_create()
224 gst_element_link (p->appsrc, p->rtppay); in rtp_pipeline_create()
332 gst_element_send_event (p->appsrc, gst_event_ref (p->custom_event)); in rtp_pipeline_run()
347 g_signal_emit_by_name (p->appsrc, "push-buffer", buf, &flow_ret); in rtp_pipeline_run()
355 g_signal_emit_by_name (p->appsrc, "end-of-stream", &flow_ret); in rtp_pipeline_run()
|
| /third_party/gstreamer/gstplugins_base/gst/app/ |
| D | gstappsrc.c | 35 GST_ELEMENT_REGISTER_DEFINE (appsrc, "appsrc", GST_RANK_NONE, GST_TYPE_APP_SRC);
|
| D | gstappelements.h | 33 GST_ELEMENT_REGISTER_DECLARE (appsrc);
|
| D | gstapp.c | 27 ret |= GST_ELEMENT_REGISTER (appsrc, plugin); in plugin_init()
|
| /third_party/gstreamer/gstplugins_base/docs/libs/app/ |
| D | index.md | 7 To use it the functionality, insert an `appsrc` or `appsink` element
|
| /third_party/weston/remoting/ |
| D | remoting-plugin.c | 117 GstAppSrc *appsrc; member
221 output->appsrc = (GstAppSrc*) in remoting_gst_pipeline_init()
223 if (!output->appsrc) { in remoting_gst_pipeline_init()
246 g_object_set(G_OBJECT(output->appsrc), in remoting_gst_pipeline_init()
544 gst_app_src_push_buffer(output->appsrc, buffer); in remoting_output_gst_push_buffer()
|
| /third_party/gstreamer/gstplugins_base/tests/check/elements/ |
| D | appsrc.c | 47 GstElement *appsrc; in setup_appsrc() local
50 appsrc = gst_check_setup_element ("appsrc"); in setup_appsrc()
51 mysinkpad = gst_check_setup_sink_pad (appsrc, &sinktemplate); in setup_appsrc()
55 return appsrc; in setup_appsrc()
59 cleanup_appsrc (GstElement * appsrc) in cleanup_appsrc() argument
64 gst_check_teardown_sink_pad (appsrc); in cleanup_appsrc()
65 gst_check_teardown_element (appsrc); in cleanup_appsrc()
1469 GST_CHECK_MAIN (appsrc);
|
| /third_party/gstreamer/gstplugins_base/tests/icles/ |
| D | meson.build | 3 [ 'benchmark-appsrc.c', false, [gst_base_dep, app_dep], true ],
|
| /third_party/gstreamer/gstplugins_base/tests/check/ |
| D | meson.build | 35 [ 'elements/appsrc.c' ],
|
| /third_party/gstreamer/gstplugins_base/ |
| D | NEWS | 257 - appsrc: allow configuration of internal queue limits in time and
260 There is internal queuing inside appsrc so the application thread
1748 useful for elements such as appsrc or giostreamsrc.
2131 - appsrc: Clarify buffer ref semantics in signals documentation
2132 - appsrc: fix annotations for bindings
2270 - appsrc: fix annotations for bindings
|
| /third_party/gstreamer/gstplugins_good/ |
| D | NEWS | 257 - appsrc: allow configuration of internal queue limits in time and
260 There is internal queuing inside appsrc so the application thread
1748 useful for elements such as appsrc or giostreamsrc.
2131 - appsrc: Clarify buffer ref semantics in signals documentation
2132 - appsrc: fix annotations for bindings
2270 - appsrc: fix annotations for bindings
|