3 * unit testing helper lib
5 * Copyright (C) 2009 Edward Hervey <bilboed@bilboed.com>
7 * This library is free software; you can redistribute it and/or
8 * modify it under the terms of the GNU Library General Public
9 * License as published by the Free Software Foundation; either
10 * version 2 of the License, or (at your option) any later version.
12 * This library is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
15 * Library General Public License for more details.
17 * You should have received a copy of the GNU Library General Public
18 * License along with this library; if not, write to the
19 * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
20 * Boston, MA 02111-1307, USA.
24 * SECTION:gstcheckconsistencychecker
25 * @short_description: Data flow consistency checker for GStreamer unit tests.
27 * These macros and functions are for internal use of the unit tests found
28 * inside the 'check' directories of various GStreamer packages.
33 #include "gstconsistencychecker.h"
35 struct _GstStreamConsistency
45 source_pad_data_cb (GstPad * pad, GstPadProbeInfo * info,
46 GstStreamConsistency * consist)
48 GstMiniObject *data = GST_PAD_PROBE_INFO_DATA (info);
50 if (GST_IS_BUFFER (data)) {
51 GST_DEBUG_OBJECT (pad,
52 "Buffer pts %" GST_TIME_FORMAT ", dts %" GST_TIME_FORMAT,
53 GST_TIME_ARGS (GST_BUFFER_PTS (GST_BUFFER_CAST (data))),
54 GST_TIME_ARGS (GST_BUFFER_DTS (GST_BUFFER_CAST (data))));
55 /* If an EOS went through, a buffer would be invalid */
56 fail_if (consist->eos, "Buffer received after EOS");
57 /* Buffers need to be preceded by a segment event */
58 fail_unless (consist->segment, "Buffer received without segment");
59 } else if (GST_IS_EVENT (data)) {
60 GstEvent *event = (GstEvent *) data;
62 GST_DEBUG_OBJECT (pad, "%s", GST_EVENT_TYPE_NAME (event));
63 switch (GST_EVENT_TYPE (event)) {
64 case GST_EVENT_FLUSH_START:
65 consist->flushing = TRUE;
67 case GST_EVENT_FLUSH_STOP:
68 /* Receiving a flush-stop is only valid after receiving a flush-start */
69 fail_unless (consist->flushing,
70 "Received a FLUSH_STOP without a FLUSH_START");
71 fail_if (consist->eos, "Received a FLUSH_STOP after an EOS");
72 consist->flushing = FALSE;
74 case GST_EVENT_SEGMENT:
75 consist->segment = TRUE;
79 /* FIXME : not 100% sure about whether two eos in a row is valid */
80 fail_if (consist->eos, "Received EOS just after another EOS");
82 consist->segment = FALSE;
85 GST_DEBUG_OBJECT (pad, "tag %" GST_PTR_FORMAT,
86 gst_event_get_structure (event));
89 if (GST_EVENT_IS_SERIALIZED (event) && GST_EVENT_IS_DOWNSTREAM (event)) {
90 fail_if (consist->eos, "Event received after EOS");
91 fail_unless (consist->segment, "Event received before segment");
93 /* FIXME : Figure out what to do for other events */
102 * gst_consistency_checker_new:
103 * @pad: The #GstPad on which the dataflow will be checked.
105 * Sets up a data probe on the given pad which will raise assertions if the
106 * data flow is inconsistent.
108 * Currently only works for source pads.
110 * Returns: A #GstStreamConsistency structure used to track data flow.
115 GstStreamConsistency *
116 gst_consistency_checker_new (GstPad * pad)
118 GstStreamConsistency *consist;
120 g_return_val_if_fail (pad != NULL, NULL);
122 consist = g_new0 (GstStreamConsistency, 1);
123 consist->pad = g_object_ref (pad);
125 gst_pad_add_probe (pad, GST_PAD_PROBE_TYPE_DATA_DOWNSTREAM,
126 (GstPadProbeCallback) source_pad_data_cb, consist, NULL);
132 * gst_consistency_checker_reset:
133 * @consist: The #GstStreamConsistency to reset.
135 * Reset the stream checker's internal variables.
141 gst_consistency_checker_reset (GstStreamConsistency * consist)
143 consist->eos = FALSE;
144 consist->flushing = FALSE;
145 consist->segment = FALSE;
149 * gst_consistency_checker_free:
150 * @consist: The #GstStreamConsistency to free.
152 * Frees the allocated data and probe associated with @consist.
158 gst_consistency_checker_free (GstStreamConsistency * consist)
160 /* Remove the data probe */
161 gst_pad_remove_probe (consist->pad, consist->probeid);
162 g_object_unref (consist->pad);