mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-04-26 06:54:49 +00:00
Code Issues 1 Projects Releases Wiki Activity

mimic: Push out newsegment from current timestamp if the incoming ts is valid

Browse source 
Push out newsegment event with the timestamp from the incoming buffer if
the incoming buffers have a valid timestamp but no valid newsegment event
has been through.
This commit is contained in:
Olivier Crête 2010-05-06 13:51:22 -04:00
parent 491a202d5c
commit 8f8d9f6c63
1 changed files with 21 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

35
ext/mimic/gstmimdec.c
View file

@ -126,6 +126,7 @@ gst_mimdec_init (GstMimDec * mimdec, GstMimDecClass * klass)
mimdec->have_header = FALSE; mimdec->have_header = FALSE;
mimdec->payload_size = -1; mimdec->payload_size = -1;
mimdec->current_ts = -1; mimdec->current_ts = -1;
mimdec->need_newsegment = TRUE;
} }
static void static void
@ -151,6 +152,8 @@ gst_mimdec_chain (GstPad * pad, GstBuffer * in)
GstCaps *caps; GstCaps *caps;
GstFlowReturn res = GST_FLOW_OK; GstFlowReturn res = GST_FLOW_OK;
GstClockTime in_time = GST_BUFFER_TIMESTAMP (in); GstClockTime in_time = GST_BUFFER_TIMESTAMP (in);
GstEvent *event = NULL;
gboolean result = TRUE;
GST_DEBUG ("in gst_mimdec_chain"); GST_DEBUG ("in gst_mimdec_chain");
@ -212,9 +215,6 @@ gst_mimdec_chain (GstPad * pad, GstBuffer * in)
(guchar *) gst_adapter_peek (mimdec->adapter, mimdec->payload_size); (guchar *) gst_adapter_peek (mimdec->adapter, mimdec->payload_size);
if (mimdec->dec == NULL) { if (mimdec->dec == NULL) {
GstEvent *event = NULL;
gboolean result = TRUE;
/* Check if its a keyframe, otherwise skip it */ /* Check if its a keyframe, otherwise skip it */
if (GUINT32_FROM_LE (*((guint32 *) (frame_body + 12))) != 0) { if (GUINT32_FROM_LE (*((guint32 *) (frame_body + 12))) != 0) {
gst_adapter_flush (mimdec->adapter, mimdec->payload_size); gst_adapter_flush (mimdec->adapter, mimdec->payload_size);
@ -256,21 +256,28 @@ gst_mimdec_chain (GstPad * pad, GstBuffer * in)
res = GST_FLOW_ERROR; res = GST_FLOW_ERROR;
goto out; goto out;
} }
}
if (mimdec->need_newsegment)
if (mimdec->need_newsegment) {
if (GST_CLOCK_TIME_IS_VALID (in_time))
event = gst_event_new_new_segment (FALSE, 1.0, GST_FORMAT_TIME,
in_time, -1, 0);
else
event = gst_event_new_new_segment (FALSE, 1.0, GST_FORMAT_TIME, event = gst_event_new_new_segment (FALSE, 1.0, GST_FORMAT_TIME,
mimdec->current_ts * GST_MSECOND, -1, 0); mimdec->current_ts * GST_MSECOND, -1, 0);
mimdec->need_newsegment = FALSE;
GST_OBJECT_UNLOCK (mimdec);
if (event)
result = gst_pad_push_event (mimdec->srcpad, event);
GST_OBJECT_LOCK (mimdec);
if (!result) {
GST_WARNING_OBJECT (mimdec, "gst_pad_push_event failed");
res = GST_FLOW_ERROR;
goto out;
}
} }
mimdec->need_newsegment = FALSE;
GST_OBJECT_UNLOCK (mimdec);
if (event)
result = gst_pad_push_event (mimdec->srcpad, event);
GST_OBJECT_LOCK (mimdec);
if (!result) {
GST_WARNING_OBJECT (mimdec, "gst_pad_push_event failed");
res = GST_FLOW_ERROR;
goto out;
}
out_buf = gst_buffer_new_and_alloc (mimdec->buffer_size); out_buf = gst_buffer_new_and_alloc (mimdec->buffer_size);