tests: work on porting the unit tests

This commit is contained in:
Wim Taymans 2011-03-28 14:12:24 +02:00 committed by Tim-Philipp Müller
parent 0e90a45365
commit 4674648248
2 changed files with 40 additions and 34 deletions

View file

@ -94,14 +94,15 @@ cleanup_gdpdepay (GstElement * gdpdepay)
} }
static void static void
gdpdepay_push_per_byte (const gchar * reason, guint8 * bytes, guint length) gdpdepay_push_per_byte (const gchar * reason, const guint8 * bytes,
guint length)
{ {
int i; int i;
GstBuffer *inbuffer; GstBuffer *inbuffer;
for (i = 0; i < length; ++i) { for (i = 0; i < length; ++i) {
inbuffer = gst_buffer_new_and_alloc (1); inbuffer = gst_buffer_new_and_alloc (1);
GST_BUFFER_DATA (inbuffer)[0] = bytes[i]; gst_buffer_fill (inbuffer, 0, &bytes[i], 1);
fail_unless (gst_pad_push (mysrcpad, inbuffer) == GST_FLOW_OK, fail_unless (gst_pad_push (mysrcpad, inbuffer) == GST_FLOW_OK,
"%s: failed pushing byte buffer", reason); "%s: failed pushing byte buffer", reason);
} }
@ -148,13 +149,13 @@ GST_START_TEST (test_audio_per_byte)
g_free (payload); g_free (payload);
buffer = gst_buffer_new_and_alloc (4); buffer = gst_buffer_new_and_alloc (4);
memcpy (GST_BUFFER_DATA (buffer), "f00d", 4); gst_buffer_fill (buffer, 0, "f00d", 4);
GST_BUFFER_TIMESTAMP (buffer) = GST_SECOND; GST_BUFFER_TIMESTAMP (buffer) = GST_SECOND;
GST_BUFFER_DURATION (buffer) = GST_SECOND / 10; GST_BUFFER_DURATION (buffer) = GST_SECOND / 10;
fail_unless (pk->header_from_buffer (buffer, 0, &len, &header)); fail_unless (pk->header_from_buffer (buffer, 0, &len, &header));
gdpdepay_push_per_byte ("buffer header", header, len); gdpdepay_push_per_byte ("buffer header", header, len);
fail_unless_equals_int (g_list_length (buffers), 0); fail_unless_equals_int (g_list_length (buffers), 0);
gdpdepay_push_per_byte ("buffer payload", GST_BUFFER_DATA (buffer), gdpdepay_push_per_byte ("buffer payload", (const guint8 *) "f00d",
gst_dp_header_payload_length (header)); gst_dp_header_payload_length (header));
g_free (header); g_free (header);
gst_buffer_unref (buffer); gst_buffer_unref (buffer);
@ -214,21 +215,20 @@ GST_START_TEST (test_audio_in_one_buffer)
&caps_payload)); &caps_payload));
buffer = gst_buffer_new_and_alloc (4); buffer = gst_buffer_new_and_alloc (4);
memcpy (GST_BUFFER_DATA (buffer), "f00d", 4); gst_buffer_fill (buffer, 0, "f00d", 4);
fail_unless (pk->header_from_buffer (buffer, 0, &header_len, &buf_header)); fail_unless (pk->header_from_buffer (buffer, 0, &header_len, &buf_header));
payload_len = gst_dp_header_payload_length (caps_header); payload_len = gst_dp_header_payload_length (caps_header);
inbuffer = gst_buffer_new_and_alloc (2 * GST_DP_HEADER_LENGTH + inbuffer = gst_buffer_new_and_alloc (2 * GST_DP_HEADER_LENGTH +
payload_len + GST_BUFFER_SIZE (buffer)); payload_len + gst_buffer_get_size (buffer));
memcpy (GST_BUFFER_DATA (inbuffer), caps_header, GST_DP_HEADER_LENGTH); gst_buffer_fill (inbuffer, 0, caps_header, GST_DP_HEADER_LENGTH);
i = GST_DP_HEADER_LENGTH; i = GST_DP_HEADER_LENGTH;
memcpy (GST_BUFFER_DATA (inbuffer) + i, caps_payload, payload_len); gst_buffer_fill (inbuffer, i, caps_payload, payload_len);
i += payload_len; i += payload_len;
memcpy (GST_BUFFER_DATA (inbuffer) + i, buf_header, GST_DP_HEADER_LENGTH); gst_buffer_fill (inbuffer, i, buf_header, GST_DP_HEADER_LENGTH);
i += GST_DP_HEADER_LENGTH; i += GST_DP_HEADER_LENGTH;
memcpy (GST_BUFFER_DATA (inbuffer) + i, GST_BUFFER_DATA (buffer), gst_buffer_fill (inbuffer, i, "f00d", 4);
GST_BUFFER_SIZE (buffer));
gst_caps_unref (caps); gst_caps_unref (caps);
gst_buffer_unref (buffer); gst_buffer_unref (buffer);
@ -287,7 +287,8 @@ GST_START_TEST (test_streamheader)
GstPad *srcpad; GstPad *srcpad;
GstElement *gdpdepay; GstElement *gdpdepay;
GstBuffer *buffer, *inbuffer, *outbuffer, *shbuffer; GstBuffer *buffer, *inbuffer, *outbuffer, *shbuffer;
guint8 *caps_header, *caps_payload, *buf_header; guint8 *caps_header, *caps_payload, *buf_header, *data;
gsize size;
guint header_len, payload_len; guint header_len, payload_len;
guint i; guint i;
GstStructure *structure; GstStructure *structure;
@ -315,7 +316,7 @@ GST_START_TEST (test_streamheader)
caps = gst_caps_from_string ("application/x-gst-test-streamheader"); caps = gst_caps_from_string ("application/x-gst-test-streamheader");
structure = gst_caps_get_structure (caps, 0); structure = gst_caps_get_structure (caps, 0);
buffer = gst_buffer_new_and_alloc (4); buffer = gst_buffer_new_and_alloc (4);
memcpy (GST_BUFFER_DATA (buffer), "f00d", 4); gst_buffer_fill (buffer, 0, "f00d", 4);
GST_BUFFER_FLAG_SET (buffer, GST_BUFFER_FLAG_IN_CAPS); GST_BUFFER_FLAG_SET (buffer, GST_BUFFER_FLAG_IN_CAPS);
g_value_init (&array, GST_TYPE_ARRAY); g_value_init (&array, GST_TYPE_ARRAY);
g_value_init (&value, GST_TYPE_BUFFER); g_value_init (&value, GST_TYPE_BUFFER);
@ -338,16 +339,17 @@ GST_START_TEST (test_streamheader)
payload_len = gst_dp_header_payload_length (caps_header); payload_len = gst_dp_header_payload_length (caps_header);
data = gst_buffer_map (buffer, &size, NULL, GST_MAP_READ);
inbuffer = gst_buffer_new_and_alloc (2 * GST_DP_HEADER_LENGTH + inbuffer = gst_buffer_new_and_alloc (2 * GST_DP_HEADER_LENGTH +
payload_len + GST_BUFFER_SIZE (buffer)); payload_len + size);
memcpy (GST_BUFFER_DATA (inbuffer), caps_header, GST_DP_HEADER_LENGTH); gst_buffer_fill (inbuffer, 0, caps_header, GST_DP_HEADER_LENGTH);
i = GST_DP_HEADER_LENGTH; i = GST_DP_HEADER_LENGTH;
memcpy (GST_BUFFER_DATA (inbuffer) + i, caps_payload, payload_len); gst_buffer_fill (inbuffer, i, caps_payload, payload_len);
i += payload_len; i += payload_len;
memcpy (GST_BUFFER_DATA (inbuffer) + i, buf_header, GST_DP_HEADER_LENGTH); gst_buffer_fill (inbuffer, i, buf_header, GST_DP_HEADER_LENGTH);
i += GST_DP_HEADER_LENGTH; i += GST_DP_HEADER_LENGTH;
memcpy (GST_BUFFER_DATA (inbuffer) + i, GST_BUFFER_DATA (buffer), gst_buffer_fill (inbuffer, i, data, size);
GST_BUFFER_SIZE (buffer)); gst_buffer_unmap (buffer, data, size);
gst_caps_unref (caps); gst_caps_unref (caps);
gst_buffer_unref (buffer); gst_buffer_unref (buffer);

View file

@ -142,7 +142,7 @@ GST_START_TEST (test_audio)
buffers = g_list_remove (buffers, outbuffer); buffers = g_list_remove (buffers, outbuffer);
ASSERT_BUFFER_REFCOUNT (outbuffer, "outbuffer", 2); ASSERT_BUFFER_REFCOUNT (outbuffer, "outbuffer", 2);
length = GST_DP_HEADER_LENGTH + (strlen (caps_string) + 1); length = GST_DP_HEADER_LENGTH + (strlen (caps_string) + 1);
fail_unless_equals_int (GST_BUFFER_SIZE (outbuffer), length); fail_unless_equals_int (gst_buffer_get_size (outbuffer), length);
gst_buffer_unref (outbuffer); gst_buffer_unref (outbuffer);
/* the third buffer is the GDP buffer for our pushed buffer */ /* the third buffer is the GDP buffer for our pushed buffer */
@ -150,7 +150,7 @@ GST_START_TEST (test_audio)
buffers = g_list_remove (buffers, outbuffer); buffers = g_list_remove (buffers, outbuffer);
ASSERT_BUFFER_REFCOUNT (outbuffer, "outbuffer", 1); ASSERT_BUFFER_REFCOUNT (outbuffer, "outbuffer", 1);
length = GST_DP_HEADER_LENGTH + 4; length = GST_DP_HEADER_LENGTH + 4;
fail_unless_equals_int (GST_BUFFER_SIZE (outbuffer), length); fail_unless_equals_int (gst_buffer_get_size (outbuffer), length);
gst_buffer_unref (outbuffer); gst_buffer_unref (outbuffer);
/* second buffer */ /* second buffer */
@ -170,7 +170,7 @@ GST_START_TEST (test_audio)
/* the third output buffer is data */ /* the third output buffer is data */
length = GST_DP_HEADER_LENGTH + 4; length = GST_DP_HEADER_LENGTH + 4;
fail_unless_equals_int (GST_BUFFER_SIZE (outbuffer), length); fail_unless_equals_int (gst_buffer_get_size (outbuffer), length);
gst_buffer_unref (outbuffer); gst_buffer_unref (outbuffer);
/* a third buffer without caps set explicitly; should work */ /* a third buffer without caps set explicitly; should work */
@ -189,7 +189,7 @@ GST_START_TEST (test_audio)
/* the fourth output buffer is data */ /* the fourth output buffer is data */
length = GST_DP_HEADER_LENGTH + 4; length = GST_DP_HEADER_LENGTH + 4;
fail_unless_equals_int (GST_BUFFER_SIZE (outbuffer), length); fail_unless_equals_int (gst_buffer_get_size (outbuffer), length);
gst_buffer_unref (outbuffer); gst_buffer_unref (outbuffer);
@ -263,7 +263,7 @@ GST_START_TEST (test_streamheader)
GST_DEBUG ("first buffer"); GST_DEBUG ("first buffer");
inbuffer = gst_buffer_new_and_alloc (4); inbuffer = gst_buffer_new_and_alloc (4);
memcpy (GST_BUFFER_DATA (inbuffer), "head", 4); gst_buffer_fill (inbuffer, 0, "head", 4);
caps = gst_caps_from_string ("application/x-gst-test-streamheader"); caps = gst_caps_from_string ("application/x-gst-test-streamheader");
structure = gst_caps_get_structure (caps, 0); structure = gst_caps_get_structure (caps, 0);
GST_BUFFER_FLAG_SET (inbuffer, GST_BUFFER_FLAG_IN_CAPS); GST_BUFFER_FLAG_SET (inbuffer, GST_BUFFER_FLAG_IN_CAPS);
@ -316,7 +316,7 @@ GST_START_TEST (test_streamheader)
buffers = g_list_remove (buffers, outbuffer); buffers = g_list_remove (buffers, outbuffer);
ASSERT_BUFFER_REFCOUNT (outbuffer, "outbuffer", 2); ASSERT_BUFFER_REFCOUNT (outbuffer, "outbuffer", 2);
length = GST_DP_HEADER_LENGTH + (strlen (caps_string) + 1); length = GST_DP_HEADER_LENGTH + (strlen (caps_string) + 1);
fail_unless_equals_int (GST_BUFFER_SIZE (outbuffer), length); fail_unless_equals_int (gst_buffer_get_size (outbuffer), length);
gst_buffer_unref (outbuffer); gst_buffer_unref (outbuffer);
/* the third buffer is the GDP buffer for our pushed buffer */ /* the third buffer is the GDP buffer for our pushed buffer */
@ -324,7 +324,7 @@ GST_START_TEST (test_streamheader)
buffers = g_list_remove (buffers, outbuffer); buffers = g_list_remove (buffers, outbuffer);
ASSERT_BUFFER_REFCOUNT (outbuffer, "outbuffer", 1); ASSERT_BUFFER_REFCOUNT (outbuffer, "outbuffer", 1);
length = GST_DP_HEADER_LENGTH + 4; length = GST_DP_HEADER_LENGTH + 4;
fail_unless_equals_int (GST_BUFFER_SIZE (outbuffer), length); fail_unless_equals_int (gst_buffer_get_size (outbuffer), length);
gst_buffer_unref (outbuffer); gst_buffer_unref (outbuffer);
/* second buffer */ /* second buffer */
@ -344,7 +344,7 @@ GST_START_TEST (test_streamheader)
/* the third output buffer is data */ /* the third output buffer is data */
length = GST_DP_HEADER_LENGTH + 4; length = GST_DP_HEADER_LENGTH + 4;
fail_unless_equals_int (GST_BUFFER_SIZE (outbuffer), length); fail_unless_equals_int (gst_buffer_get_size (outbuffer), length);
gst_buffer_unref (outbuffer); gst_buffer_unref (outbuffer);
/* a third buffer without caps set explicitly; should work */ /* a third buffer without caps set explicitly; should work */
@ -363,7 +363,7 @@ GST_START_TEST (test_streamheader)
/* the fourth output buffer is data */ /* the fourth output buffer is data */
length = GST_DP_HEADER_LENGTH + 4; length = GST_DP_HEADER_LENGTH + 4;
fail_unless_equals_int (GST_BUFFER_SIZE (outbuffer), length); fail_unless_equals_int (gst_buffer_get_size (outbuffer), length);
gst_buffer_unref (outbuffer); gst_buffer_unref (outbuffer);
@ -464,6 +464,8 @@ GST_START_TEST (test_crc)
GstEvent *event; GstEvent *event;
gchar *caps_string; gchar *caps_string;
gint length; gint length;
guint8 *data;
gsize size;
guint16 crc_calculated, crc_read; guint16 crc_calculated, crc_read;
gdppay = setup_gdppay (); gdppay = setup_gdppay ();
@ -503,16 +505,18 @@ GST_START_TEST (test_crc)
/* verify the header checksum */ /* verify the header checksum */
/* CRC's start at 58 in the header */ /* CRC's start at 58 in the header */
crc_calculated = gst_dp_crc (GST_BUFFER_DATA (outbuffer), 58); data = gst_buffer_map (outbuffer, &size, NULL, GST_MAP_READWRITE);
crc_read = GST_READ_UINT16_BE (GST_BUFFER_DATA (outbuffer) + 58); crc_calculated = gst_dp_crc (data, 58);
crc_read = GST_READ_UINT16_BE (data + 58);
fail_unless_equals_int (crc_calculated, crc_read); fail_unless_equals_int (crc_calculated, crc_read);
/* change a byte in the header and verify that the checksum now fails */ /* change a byte in the header and verify that the checksum now fails */
GST_BUFFER_DATA (outbuffer)[0] = 0xff; data[0] = 0xff;
crc_calculated = gst_dp_crc (GST_BUFFER_DATA (outbuffer), 58); crc_calculated = gst_dp_crc (data, 58);
fail_if (crc_calculated == crc_read, fail_if (crc_calculated == crc_read,
"Introducing a byte error in the header should make the checksum fail"); "Introducing a byte error in the header should make the checksum fail");
gst_buffer_unmap (outbuffer, data, size);
gst_buffer_unref (outbuffer); gst_buffer_unref (outbuffer);
/* second buffer is the serialized caps; /* second buffer is the serialized caps;
@ -521,7 +525,7 @@ GST_START_TEST (test_crc)
buffers = g_list_remove (buffers, outbuffer); buffers = g_list_remove (buffers, outbuffer);
ASSERT_BUFFER_REFCOUNT (outbuffer, "outbuffer", 2); ASSERT_BUFFER_REFCOUNT (outbuffer, "outbuffer", 2);
length = GST_DP_HEADER_LENGTH + (strlen (caps_string) + 1); length = GST_DP_HEADER_LENGTH + (strlen (caps_string) + 1);
fail_unless_equals_int (GST_BUFFER_SIZE (outbuffer), length); fail_unless_equals_int (gst_buffer_get_size (outbuffer), length);
gst_buffer_unref (outbuffer); gst_buffer_unref (outbuffer);
/* the third buffer is the GDP buffer for our pushed buffer */ /* the third buffer is the GDP buffer for our pushed buffer */
@ -529,7 +533,7 @@ GST_START_TEST (test_crc)
buffers = g_list_remove (buffers, outbuffer); buffers = g_list_remove (buffers, outbuffer);
ASSERT_BUFFER_REFCOUNT (outbuffer, "outbuffer", 1); ASSERT_BUFFER_REFCOUNT (outbuffer, "outbuffer", 1);
length = GST_DP_HEADER_LENGTH + 4; length = GST_DP_HEADER_LENGTH + 4;
fail_unless_equals_int (GST_BUFFER_SIZE (outbuffer), length); fail_unless_equals_int (gst_buffer_get_size (outbuffer), length);
gst_buffer_unref (outbuffer); gst_buffer_unref (outbuffer);
fail_unless (gst_element_set_state (gdppay, fail_unless (gst_element_set_state (gdppay,