mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-24 10:41:04 +00:00
Code Issues 1 Projects Releases Wiki Activity

Forward events.

Browse source 
Original commit message from CVS:
Forward events.
This commit is contained in:
Wim Taymans 2003-02-25 21:34:10 +00:00
parent 2980087e6a
commit 7912d9becd
1 changed files with 19 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
gst/smpte/gstsmpte.c
View file

@ -318,20 +318,30 @@ gst_smpte_loop (GstElement *element)
ts = smpte->position * GST_SECOND / smpte->fps; ts = smpte->position * GST_SECOND / smpte->fps;
if (GST_PAD_IS_USABLE (smpte->sinkpad1)) { while (GST_PAD_IS_USABLE (smpte->sinkpad1) && in1 == NULL) {
in1 = gst_pad_pull (smpte->sinkpad1); in1 = gst_pad_pull (smpte->sinkpad1);
if (GST_IS_EVENT (in1)) {
gst_pad_push (smpte->srcpad, in1);
in1 = NULL;
}
else
ts = GST_BUFFER_TIMESTAMP (in1); ts = GST_BUFFER_TIMESTAMP (in1);
} }
else { if (GST_PAD_IS_USABLE (smpte->sinkpad2) && in2 == NULL) {
in2 = gst_pad_pull (smpte->sinkpad2);
if (GST_IS_EVENT (in2)) {
gst_pad_push (smpte->srcpad, in2);
in2 = NULL;
}
else
ts = GST_BUFFER_TIMESTAMP (in2);
}
if (in1 == NULL) {
in1 = gst_buffer_new_and_alloc (smpte->width * smpte->height * 3); in1 = gst_buffer_new_and_alloc (smpte->width * smpte->height * 3);
fill_i420 (GST_BUFFER_DATA (in1), smpte->width, smpte->height, 7); fill_i420 (GST_BUFFER_DATA (in1), smpte->width, smpte->height, 7);
} }
if (in2 == NULL) {
if (GST_PAD_IS_USABLE (smpte->sinkpad2)) {
in2 = gst_pad_pull (smpte->sinkpad2);
ts = GST_BUFFER_TIMESTAMP (in2);
}
else {
in2 = gst_buffer_new_and_alloc (smpte->width * smpte->height * 3); in2 = gst_buffer_new_and_alloc (smpte->width * smpte->height * 3);
fill_i420 (GST_BUFFER_DATA (in2), smpte->width, smpte->height, 0); fill_i420 (GST_BUFFER_DATA (in2), smpte->width, smpte->height, 0);
} }