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

adaptivedemux: tests: create a GstDashDemuxTestCase class

Browse source 
Create a GstDashDemuxTestCase class that extends from GstAdaptiveDemuxTestCase.
This new class will contain all the DASH specific fields.

https://bugzilla.gnome.org/show_bug.cgi?id=762144
This commit is contained in:
Florin Apostol 2016-02-16 14:24:26 +00:00 committed by Thiago Santos
parent 9c0489e73e
commit f27d585078
3 changed files with 110 additions and 31 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
tests/check/elements/adaptive_demux_common.c
View file

@ -25,11 +25,6 @@
#define GST_TEST_HTTP_SRC_NAME "testhttpsrc"
struct _GstAdaptiveDemuxTestCaseClass
{
GObjectClass parent_class;
};
#define gst_adaptive_demux_test_case_parent_class parent_class
static void gst_adaptive_demux_test_case_dispose (GObject * object);

6
tests/check/elements/adaptive_demux_common.h
View file

@ -77,7 +77,11 @@ typedef struct _GstAdaptiveDemuxTestExpectedOutput
gboolean segment_verification_needed;
} GstAdaptiveDemuxTestExpectedOutput;
typedef struct _GstAdaptiveDemuxTestCaseClass GstAdaptiveDemuxTestCaseClass;
typedef struct _GstAdaptiveDemuxTestCaseClass
{
GObjectClass parent_class;
} GstAdaptiveDemuxTestCaseClass;
typedef struct _GstAdaptiveDemuxTestCase
{
GObject parent;

130
tests/check/elements/dash_demux.c
View file

@ -26,7 +26,7 @@
#define COPY_OUTPUT_TEST_DATA(outputTestData,testData) do { \
guint otdPos, otdLen = sizeof((outputTestData)) / sizeof((outputTestData)[0]); \
for(otdPos=0; otdPos<otdLen; ++otdPos){ \
(testData)->output_streams = g_list_append ((testData)->output_streams, &(outputTestData)[otdPos]); \
GST_ADAPTIVE_DEMUX_TEST_CASE (testData)->output_streams = g_list_append (GST_ADAPTIVE_DEMUX_TEST_CASE (testData)->output_streams, &(outputTestData)[otdPos]); \
} \
} while(0)
@ -43,6 +43,86 @@ typedef struct _GstTestHTTPSrcTestData
GstStructure *data;
} GstTestHTTPSrcTestData;
typedef struct _GstDashDemuxTestCase
{
GstAdaptiveDemuxTestCase parent;
} GstDashDemuxTestCase;
GType gst_dash_demux_test_case_get_type (void);
static void gst_dash_demux_test_case_dispose (GObject * object);
static void gst_dash_demux_test_case_finalize (GObject * object);
static void gst_dash_demux_test_case_clear (GstDashDemuxTestCase * test_case);
static GstDashDemuxTestCase *
gst_dash_demux_test_case_new (void)
G_GNUC_MALLOC;
#define GST_TYPE_DASH_DEMUX_TEST_CASE \
(gst_dash_demux_test_case_get_type())
#define GST_DASH_DEMUX_TEST_CASE(obj) \
(G_TYPE_CHECK_INSTANCE_CAST((obj), GST_TYPE_DASH_DEMUX_TEST_CASE, GstDashDemuxTestCase))
#define GST_DASH_DEMUX_TEST_CASE_CLASS(klass) \
(G_TYPE_CHECK_CLASS_CAST((klass), GST_TYPE_DASH_DEMUX_TEST_CASE, GstDashDemuxTestCaseClass))
#define GST_DASH_DEMUX_TEST_CASE_GET_CLASS(obj) \
(G_TYPE_INSTANCE_GET_CLASS ((obj), GST_TYPE_DASH_DEMUX_TEST_CASE, GstDashDemuxTestCaseClass))
#define GST_IS_DASH_DEMUX_TEST_CASE(obj) \
(G_TYPE_CHECK_INSTANCE_TYPE((obj), GST_TYPE_DASH_DEMUX_TEST_CASE))
#define GST_IS_DASH_DEMUX_TEST_CASE_CLASS(klass) \
(G_TYPE_CHECK_CLASS_TYPE((klass), GST_TYPE_DASH_DEMUX_TEST_CASE))
static GstDashDemuxTestCase *gst_dash_demux_test_case_new (void)
{
return g_object_newv (GST_TYPE_DASH_DEMUX_TEST_CASE, 0, NULL);
}
typedef struct _GstDashDemuxTestCaseClass
{
GstAdaptiveDemuxTestCaseClass parent_class;
} GstDashDemuxTestCaseClass;
#define gst_dash_demux_test_case_parent_class parent_class
G_DEFINE_TYPE (GstDashDemuxTestCase, gst_dash_demux_test_case,
GST_TYPE_ADAPTIVE_DEMUX_TEST_CASE);
static void
gst_dash_demux_test_case_class_init (GstDashDemuxTestCaseClass * klass)
{
GObjectClass *object = G_OBJECT_CLASS (klass);
object->dispose = gst_dash_demux_test_case_dispose;
object->finalize = gst_dash_demux_test_case_finalize;
}
static void
gst_dash_demux_test_case_init (GstDashDemuxTestCase * test_case)
{
gst_dash_demux_test_case_clear (test_case);
}
static void
gst_dash_demux_test_case_clear (GstDashDemuxTestCase * test_case)
{
}
static void
gst_dash_demux_test_case_dispose (GObject * object)
{
GstDashDemuxTestCase *testData = GST_DASH_DEMUX_TEST_CASE (object);
gst_dash_demux_test_case_clear (testData);
G_OBJECT_CLASS (parent_class)->dispose (object);
}
static void
gst_dash_demux_test_case_finalize (GObject * object)
{
/*GstDashDemuxTestCase *testData = GST_DASH_DEMUX_TEST_CASE (object); */
G_OBJECT_CLASS (parent_class)->finalize (object);
}
static gboolean
gst_dashdemux_http_src_start (GstTestHTTPSrc * src,
const gchar * uri, GstTestHTTPSrcInput * input_data, gpointer user_data)
@ -158,7 +238,7 @@ GST_START_TEST (simpleTest)
GstTestHTTPSrcCallbacks http_src_callbacks = { 0 };
GstTestHTTPSrcTestData http_src_test_data = { 0 };
GstAdaptiveDemuxTestCallbacks test_callbacks = { 0 };
GstAdaptiveDemuxTestCase *testData;
GstDashDemuxTestCase *testData;
http_src_callbacks.src_start = gst_dashdemux_http_src_start;
http_src_callbacks.src_create = gst_dashdemux_http_src_create;
@ -171,7 +251,7 @@ GST_START_TEST (simpleTest)
test_callbacks.appsink_eos =
gst_adaptive_demux_test_check_size_of_received_data;
testData = gst_adaptive_demux_test_case_new ();
testData = gst_dash_demux_test_case_new ();
COPY_OUTPUT_TEST_DATA (outputTestData, testData);
gst_adaptive_demux_test_run (DEMUX_ELEMENT_NAME, "http://unit.test/test.mpd",
@ -283,7 +363,7 @@ GST_START_TEST (testTwoPeriods)
GstTestHTTPSrcCallbacks http_src_callbacks = { 0 };
GstTestHTTPSrcTestData http_src_test_data = { 0 };
GstAdaptiveDemuxTestCallbacks test_callbacks = { 0 };
GstAdaptiveDemuxTestCase *testData;
GstDashDemuxTestCase *testData;
http_src_callbacks.src_start = gst_dashdemux_http_src_start;
http_src_callbacks.src_create = gst_dashdemux_http_src_create;
@ -296,7 +376,7 @@ GST_START_TEST (testTwoPeriods)
test_callbacks.appsink_eos =
gst_adaptive_demux_test_check_size_of_received_data;
testData = gst_adaptive_demux_test_case_new ();
testData = gst_dash_demux_test_case_new ();
COPY_OUTPUT_TEST_DATA (outputTestData, testData);
gst_adaptive_demux_test_run (DEMUX_ELEMENT_NAME,
@ -364,7 +444,7 @@ do \
static void
setAndTestDashParams (GstAdaptiveDemuxTestEngine * engine, gpointer user_data)
{
/* GstAdaptiveDemuxTestCase * testData = (GstAdaptiveDemuxTestCase*)user_data; */
/* GstDashDemuxTestCase * testData = (GstDashDemuxTestCase*)user_data; */
GObject *dashdemux = G_OBJECT (engine->demux);
test_int_prop (dashdemux, "connection-speed", 1000);
@ -427,7 +507,7 @@ GST_START_TEST (testParameters)
GstTestHTTPSrcCallbacks http_src_callbacks = { 0 };
GstTestHTTPSrcTestData http_src_test_data = { 0 };
GstAdaptiveDemuxTestCallbacks test_callbacks = { 0 };
GstAdaptiveDemuxTestCase *testData;
GstDashDemuxTestCase *testData;
http_src_callbacks.src_start = gst_dashdemux_http_src_start;
http_src_callbacks.src_create = gst_dashdemux_http_src_create;
@ -441,7 +521,7 @@ GST_START_TEST (testParameters)
test_callbacks.appsink_eos =
gst_adaptive_demux_test_check_size_of_received_data;
testData = gst_adaptive_demux_test_case_new ();
testData = gst_dash_demux_test_case_new ();
COPY_OUTPUT_TEST_DATA (outputTestData, testData);
gst_adaptive_demux_test_run (DEMUX_ELEMENT_NAME, "http://unit.test/test.mpd",
@ -497,7 +577,7 @@ GST_START_TEST (testSeek)
};
GstTestHTTPSrcCallbacks http_src_callbacks = { 0 };
GstTestHTTPSrcTestData http_src_test_data = { 0 };
GstAdaptiveDemuxTestCase *testData;
GstDashDemuxTestCase *testData;
http_src_callbacks.src_start = gst_dashdemux_http_src_start;
http_src_callbacks.src_create = gst_dashdemux_http_src_create;
@ -505,7 +585,7 @@ GST_START_TEST (testSeek)
gst_test_http_src_install_callbacks (&http_src_callbacks,
&http_src_test_data);
testData = gst_adaptive_demux_test_case_new ();
testData = gst_dash_demux_test_case_new ();
COPY_OUTPUT_TEST_DATA (outputTestData, testData);
/* media segment starts at 4687
@ -513,19 +593,19 @@ GST_START_TEST (testSeek)
* on the first pad listed in GstAdaptiveDemuxTestOutputStreamData and the
* first chunk of at least one byte has already arrived in AppSink
*/
testData->threshold_for_seek = 4687 + 1;
GST_ADAPTIVE_DEMUX_TEST_CASE (testData)->threshold_for_seek = 4687 + 1;
/* seek to 5ms.
* Because there is only one fragment, we expect the whole file to be
* downloaded again
*/
testData->seek_event =
GST_ADAPTIVE_DEMUX_TEST_CASE (testData)->seek_event =
gst_event_new_seek (1.0, GST_FORMAT_TIME,
GST_SEEK_FLAG_FLUSH | GST_SEEK_FLAG_KEY_UNIT, GST_SEEK_TYPE_SET,
5 * GST_MSECOND, GST_SEEK_TYPE_NONE, 0);
gst_adaptive_demux_test_seek (DEMUX_ELEMENT_NAME,
"http://unit.test/test.mpd", testData);
"http://unit.test/test.mpd", GST_ADAPTIVE_DEMUX_TEST_CASE (testData));
g_object_unref (testData);
if (http_src_test_data.data)
@ -589,7 +669,7 @@ run_seek_position_test (gdouble rate, GstSeekType start_type,
/* 1 from the init segment */
{"audio_00", (segments ? 1 + segments : 0) * 10000, NULL},
};
GstAdaptiveDemuxTestCase *testData;
GstDashDemuxTestCase *testData;
http_src_callbacks.src_start = gst_dashdemux_http_src_start;
http_src_callbacks.src_create = gst_dashdemux_http_src_create;
@ -597,7 +677,7 @@ run_seek_position_test (gdouble rate, GstSeekType start_type,
gst_test_http_src_install_callbacks (&http_src_callbacks,
&http_src_test_data);
testData = gst_adaptive_demux_test_case_new ();
testData = gst_dash_demux_test_case_new ();
COPY_OUTPUT_TEST_DATA (outputTestData, testData);
/* media segment starts at 4687
@ -606,9 +686,9 @@ run_seek_position_test (gdouble rate, GstSeekType start_type,
* first chunk of at least one byte has already arrived in AppSink
*/
if (seek_threshold_bytes)
testData->threshold_for_seek = seek_threshold_bytes;
GST_ADAPTIVE_DEMUX_TEST_CASE (testData)->threshold_for_seek = seek_threshold_bytes;
else
testData->threshold_for_seek = 4687 + 1;
GST_ADAPTIVE_DEMUX_TEST_CASE (testData)->threshold_for_seek = 4687 + 1;
/* FIXME hack to avoid having a 0 seqnum */
gst_util_seqnum_next ();
@ -617,12 +697,12 @@ run_seek_position_test (gdouble rate, GstSeekType start_type,
* Because there is only one fragment, we expect the whole file to be
* downloaded again
*/
testData->seek_event =
GST_ADAPTIVE_DEMUX_TEST_CASE (testData)->seek_event =
gst_event_new_seek (rate, GST_FORMAT_TIME, flags, start_type,
seek_start, stop_type, seek_stop);
gst_adaptive_demux_test_seek (DEMUX_ELEMENT_NAME,
"http://unit.test/test.mpd", testData);
"http://unit.test/test.mpd", GST_ADAPTIVE_DEMUX_TEST_CASE (testData));
g_object_unref (testData);
if (http_src_test_data.data)
@ -786,7 +866,7 @@ GST_START_TEST (testDownloadError)
GstTestHTTPSrcCallbacks http_src_callbacks = { 0 };
GstTestHTTPSrcTestData http_src_test_data = { 0 };
GstAdaptiveDemuxTestCallbacks test_callbacks = { 0 };
GstAdaptiveDemuxTestCase *testData;
GstDashDemuxTestCase *testData;
http_src_callbacks.src_start = gst_dashdemux_http_src_start;
http_src_callbacks.src_create = gst_dashdemux_http_src_create;
@ -800,7 +880,7 @@ GST_START_TEST (testDownloadError)
test_callbacks.appsink_eos =
gst_adaptive_demux_test_check_size_of_received_data;
testData = gst_adaptive_demux_test_case_new ();
testData = gst_dash_demux_test_case_new ();
COPY_OUTPUT_TEST_DATA (outputTestData, testData);
gst_adaptive_demux_test_run (DEMUX_ELEMENT_NAME, "http://unit.test/test.mpd",
@ -917,7 +997,7 @@ GST_START_TEST (testQuery)
GstTestHTTPSrcCallbacks http_src_callbacks = { 0 };
GstTestHTTPSrcTestData http_src_test_data = { 0 };
GstAdaptiveDemuxTestCallbacks test_callbacks = { 0 };
GstAdaptiveDemuxTestCase *testData;
GstDashDemuxTestCase *testData;
http_src_callbacks.src_start = gst_dashdemux_http_src_start;
http_src_callbacks.src_create = gst_dashdemux_http_src_create;
@ -929,7 +1009,7 @@ GST_START_TEST (testQuery)
test_callbacks.appsink_eos =
gst_adaptive_demux_test_check_size_of_received_data;
testData = gst_adaptive_demux_test_case_new ();
testData = gst_dash_demux_test_case_new ();
COPY_OUTPUT_TEST_DATA (outputTestData, testData);
gst_adaptive_demux_test_run (DEMUX_ELEMENT_NAME,
@ -1041,7 +1121,7 @@ GST_START_TEST (testFragmentDownloadError)
GstTestHTTPSrcCallbacks http_src_callbacks = { 0 };
GstTestHTTPSrcTestData http_src_test_data = { 0 };
GstAdaptiveDemuxTestCallbacks test_callbacks = { 0 };
GstAdaptiveDemuxTestCase *testData;
GstDashDemuxTestCase *testData;
guint64 threshold_for_trigger = 2000;
http_src_callbacks.src_start = gst_dashdemux_http_src_start;
@ -1059,7 +1139,7 @@ GST_START_TEST (testFragmentDownloadError)
/* test_callbacks.demux_sent_eos = gst_adaptive_demux_test_check_size_of_received_data; */
test_callbacks.bus_error_message = testDownloadErrorMessageCallback;
testData = gst_adaptive_demux_test_case_new ();
testData = gst_dash_demux_test_case_new ();
COPY_OUTPUT_TEST_DATA (outputTestData, testData);
gst_adaptive_demux_test_run (DEMUX_ELEMENT_NAME,