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

pad-monitor: verify that pushed segment matches what was received

Browse source 
Check that src pads push segments that are compatible with what
was received on the sink pads
This commit is contained in:
Thiago Santos 2013-07-17 14:36:44 -03:00
parent bd22bb8d1c
commit 425e608456
2 changed files with 70 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

68
validate/gst/qa/gst-qa-pad-monitor.c
View file

@ -168,6 +168,9 @@ gst_qa_pad_monitor_dispose (GObject * object)
gst_pad_remove_data_probe (pad, monitor->buffer_probe_id); gst_pad_remove_data_probe (pad, monitor->buffer_probe_id);
if (monitor->event_probe_id) if (monitor->event_probe_id)
gst_pad_remove_data_probe (pad, monitor->event_probe_id); gst_pad_remove_data_probe (pad, monitor->event_probe_id);
if (monitor->expected_segment)
gst_event_unref (monitor->expected_segment);
G_OBJECT_CLASS (parent_class)->dispose (object); G_OBJECT_CLASS (parent_class)->dispose (object);
} }
@ -363,6 +366,43 @@ gst_qa_pad_monitor_update_buffer_data (GstQaPadMonitor * pad_monitor,
pad_monitor->buffer_pushed = FALSE; pad_monitor->buffer_pushed = FALSE;
} }
static void
gst_qa_pad_monitor_add_expected_newsegment (GstQaPadMonitor * monitor,
GstEvent * event)
{
GstIterator *iter;
gboolean done;
GstPad *otherpad;
GstQaPadMonitor *othermonitor;
iter = gst_pad_iterate_internal_links (GST_QA_PAD_MONITOR_GET_PAD (monitor));
done = FALSE;
while (!done) {
switch (gst_iterator_next (iter, (gpointer *) & otherpad)) {
case GST_ITERATOR_OK:
othermonitor = g_object_get_data ((GObject *) otherpad, "qa-monitor");
if (othermonitor->expected_segment) {
GST_QA_MONITOR_REPORT_WARNING (othermonitor, EVENT, EXPECTED,
"expected newsegment event never pushed");
gst_event_unref (othermonitor->expected_segment);
}
othermonitor->expected_segment = gst_event_ref (event);
gst_object_unref (otherpad);
break;
case GST_ITERATOR_RESYNC:
gst_iterator_resync (iter);
break;
case GST_ITERATOR_ERROR:
GST_WARNING_OBJECT (monitor, "Internal links pad iteration error");
done = TRUE;
break;
case GST_ITERATOR_DONE:
done = TRUE;
break;
}
}
gst_iterator_free (iter);
}
static gboolean static gboolean
gst_qa_pad_monitor_sink_event_check (GstQaPadMonitor * pad_monitor, gst_qa_pad_monitor_sink_event_check (GstQaPadMonitor * pad_monitor,
@ -391,6 +431,34 @@ gst_qa_pad_monitor_sink_event_check (GstQaPadMonitor * pad_monitor,
* received just before the seek segment */ * received just before the seek segment */
} }
} }
if (GST_PAD_DIRECTION (pad) == GST_PAD_SINK) {
gst_qa_pad_monitor_add_expected_newsegment (pad_monitor, event);
} else {
/* check if this segment is the expected one */
if (pad_monitor->expected_segment) {
gint64 exp_start, exp_stop, exp_position;
gdouble exp_rate, exp_applied_rate;
gboolean exp_update;
GstFormat exp_format;
if (pad_monitor->expected_segment != event) {
gst_event_parse_new_segment_full (event, &exp_update, &exp_rate,
&exp_applied_rate, &exp_format, &exp_start, &exp_stop,
&exp_position);
if (format == exp_format) {
if (update != exp_update
|| (exp_rate * exp_applied_rate != rate * applied_rate)
|| exp_start != start || exp_stop != stop
|| exp_position != position) {
GST_QA_MONITOR_REPORT_WARNING (pad_monitor, EVENT, EXPECTED,
"Expected segment didn't match received segment event");
}
}
}
gst_event_replace (&pad_monitor->expected_segment, NULL);
}
}
break; break;
case GST_EVENT_FLUSH_START: case GST_EVENT_FLUSH_START:
{ {

2
validate/gst/qa/gst-qa-pad-monitor.h
View file

@ -79,6 +79,8 @@ struct _GstQaPadMonitor {
guint32 pending_flush_start_seqnum; guint32 pending_flush_start_seqnum;
guint32 pending_newsegment_seqnum; guint32 pending_newsegment_seqnum;
GstEvent *expected_segment;
/* tracked data */ /* tracked data */
GstSegment segment; GstSegment segment;
GstClockTime current_timestamp; GstClockTime current_timestamp;