summaryrefslogtreecommitdiffstats
path: root/gst/smpte/gstsmpte.c
diff options
context:
space:
mode:
Diffstat (limited to 'gst/smpte/gstsmpte.c')
-rw-r--r--gst/smpte/gstsmpte.c28
1 files changed, 19 insertions, 9 deletions
diff --git a/gst/smpte/gstsmpte.c b/gst/smpte/gstsmpte.c
index c28f16a6..3a7d2f4e 100644
--- a/gst/smpte/gstsmpte.c
+++ b/gst/smpte/gstsmpte.c
@@ -318,20 +318,30 @@ gst_smpte_loop (GstElement *element)
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);
- ts = GST_BUFFER_TIMESTAMP (in1);
+ if (GST_IS_EVENT (in1)) {
+ gst_pad_push (smpte->srcpad, in1);
+ in1 = NULL;
+ }
+ else
+ 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);
fill_i420 (GST_BUFFER_DATA (in1), smpte->width, smpte->height, 7);
}
-
- if (GST_PAD_IS_USABLE (smpte->sinkpad2)) {
- in2 = gst_pad_pull (smpte->sinkpad2);
- ts = GST_BUFFER_TIMESTAMP (in2);
- }
- else {
+ if (in2 == NULL) {
in2 = gst_buffer_new_and_alloc (smpte->width * smpte->height * 3);
fill_i420 (GST_BUFFER_DATA (in2), smpte->width, smpte->height, 0);
}