mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-12-18 14:26:43 +00:00
Code Issues 1 Projects Releases Wiki Activity

tests: rtpbasepayload: fix indentation

Browse source
This commit is contained in:
Tim-Philipp Müller 2014-12-12 14:59:49 +00:00
parent 091e124950
commit 2f7af2d41b
1 changed files with 134 additions and 289 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

423
tests/check/libs/rtpbasedepayload.c
View file

@ -59,8 +59,8 @@ G_DEFINE_TYPE (GstRtpDummyDepay, gst_rtp_dummy_depay,
static GstBuffer *gst_rtp_dummy_depay_process (GstRTPBaseDepayload * depayload, static GstBuffer *gst_rtp_dummy_depay_process (GstRTPBaseDepayload * depayload,
GstBuffer * buf); GstBuffer * buf);
static gboolean gst_rtp_dummy_depay_set_caps (GstRTPBaseDepayload *filter, static gboolean gst_rtp_dummy_depay_set_caps (GstRTPBaseDepayload * filter,
GstCaps *caps); GstCaps * caps);
static GstStaticPadTemplate gst_rtp_dummy_depay_sink_template = static GstStaticPadTemplate gst_rtp_dummy_depay_sink_template =
GST_STATIC_PAD_TEMPLATE ("sink", GST_STATIC_PAD_TEMPLATE ("sink",
@ -113,8 +113,8 @@ gst_rtp_dummy_depay_process (GstRTPBaseDepayload * depayload, GstBuffer * buf)
guint i; guint i;
GST_LOG ("depayloading buffer pts=%" GST_TIME_FORMAT " offset=%" GST_LOG ("depayloading buffer pts=%" GST_TIME_FORMAT " offset=%"
G_GUINT64_FORMAT " memories=%d", GST_TIME_ARGS (GST_BUFFER_PTS(buf)), G_GUINT64_FORMAT " memories=%d", GST_TIME_ARGS (GST_BUFFER_PTS (buf)),
GST_BUFFER_OFFSET(buf), gst_buffer_n_memory (buf)); GST_BUFFER_OFFSET (buf), gst_buffer_n_memory (buf));
for (i = 0; i < gst_buffer_n_memory (buf); i++) { for (i = 0; i < gst_buffer_n_memory (buf); i++) {
GstMemory *mem = gst_buffer_get_memory (buf, 0); GstMemory *mem = gst_buffer_get_memory (buf, 0);
@ -134,8 +134,8 @@ gst_rtp_dummy_depay_process (GstRTPBaseDepayload * depayload, GstBuffer * buf)
GST_LOG ("depayloaded buffer pts=%" GST_TIME_FORMAT " offset=%" GST_LOG ("depayloaded buffer pts=%" GST_TIME_FORMAT " offset=%"
G_GUINT64_FORMAT " rtptime=%" G_GUINT32_FORMAT " memories=%d", G_GUINT64_FORMAT " rtptime=%" G_GUINT32_FORMAT " memories=%d",
GST_TIME_ARGS (GST_BUFFER_PTS(outbuf)), GST_TIME_ARGS (GST_BUFFER_PTS (outbuf)),
GST_BUFFER_OFFSET(outbuf), rtptime, gst_buffer_n_memory (buf)); GST_BUFFER_OFFSET (outbuf), rtptime, gst_buffer_n_memory (buf));
for (i = 0; i < gst_buffer_n_memory (buf); i++) { for (i = 0; i < gst_buffer_n_memory (buf); i++) {
GstMemory *mem = gst_buffer_get_memory (buf, 0); GstMemory *mem = gst_buffer_get_memory (buf, 0);
@ -149,7 +149,7 @@ gst_rtp_dummy_depay_process (GstRTPBaseDepayload * depayload, GstBuffer * buf)
} }
static gboolean static gboolean
gst_rtp_dummy_depay_set_caps (GstRTPBaseDepayload *filter, GstCaps *caps) gst_rtp_dummy_depay_set_caps (GstRTPBaseDepayload * filter, GstCaps * caps)
{ {
GstEvent *event; GstEvent *event;
event = gst_event_new_caps (caps); event = gst_event_new_caps (caps);
@ -171,7 +171,8 @@ static GstStaticPadTemplate sinktemplate = GST_STATIC_PAD_TEMPLATE ("sink",
typedef struct State State; typedef struct State State;
struct State { struct State
{
GstElement *element; GstElement *element;
GstPad *sinkpad; GstPad *sinkpad;
GstPad *srcpad; GstPad *srcpad;
@ -186,7 +187,8 @@ event_func (GstPad * pad, GstObject * noparent, GstEvent * event)
return gst_pad_event_default (pad, noparent, event); return gst_pad_event_default (pad, noparent, event);
} }
static void drop_events (void) static void
drop_events (void)
{ {
while (events != NULL) { while (events != NULL) {
gst_event_unref (GST_EVENT (events->data)); gst_event_unref (GST_EVENT (events->data));
@ -194,13 +196,14 @@ static void drop_events (void)
} }
} }
static void validate_events_received (guint received) static void
validate_events_received (guint received)
{ {
fail_unless_equals_int (g_list_length (events), received); fail_unless_equals_int (g_list_length (events), received);
} }
static void validate_event (guint index, const gchar *name, static void
const gchar *field, ...) validate_event (guint index, const gchar * name, const gchar * field, ...)
{ {
GstEvent *event; GstEvent *event;
va_list var_args; va_list var_args;
@ -262,32 +265,32 @@ static void validate_event (guint index, const gchar *name,
GstCaps *caps; GstCaps *caps;
GstClockTime start; GstClockTime start;
gst_event_parse_caps (event, &caps); gst_event_parse_caps (event, &caps);
fail_unless (gst_structure_get_clock_time ( fail_unless (gst_structure_get_clock_time (gst_caps_get_structure (caps,
gst_caps_get_structure (caps, 0), "npt-start", &start)); 0), "npt-start", &start));
fail_unless_equals_uint64 (start, expected); fail_unless_equals_uint64 (start, expected);
} else if (!g_strcmp0 (field, "npt-stop")) { } else if (!g_strcmp0 (field, "npt-stop")) {
GstClockTime expected = va_arg (var_args, GstClockTime); GstClockTime expected = va_arg (var_args, GstClockTime);
GstCaps *caps; GstCaps *caps;
GstClockTime stop; GstClockTime stop;
gst_event_parse_caps (event, &caps); gst_event_parse_caps (event, &caps);
fail_unless (gst_structure_get_clock_time ( fail_unless (gst_structure_get_clock_time (gst_caps_get_structure (caps,
gst_caps_get_structure (caps, 0), "npt-stop", &stop)); 0), "npt-stop", &stop));
fail_unless_equals_uint64 (stop, expected); fail_unless_equals_uint64 (stop, expected);
} else if (!g_strcmp0 (field, "play-speed")) { } else if (!g_strcmp0 (field, "play-speed")) {
gdouble expected = va_arg (var_args, gdouble); gdouble expected = va_arg (var_args, gdouble);
GstCaps *caps; GstCaps *caps;
gdouble speed; gdouble speed;
gst_event_parse_caps (event, &caps); gst_event_parse_caps (event, &caps);
fail_unless (gst_structure_get_double ( fail_unless (gst_structure_get_double (gst_caps_get_structure (caps, 0),
gst_caps_get_structure (caps, 0), "play-speed", &speed)); "play-speed", &speed));
fail_unless (speed == expected); fail_unless (speed == expected);
} else if (!g_strcmp0 (field, "play-scale")) { } else if (!g_strcmp0 (field, "play-scale")) {
gdouble expected = va_arg (var_args, gdouble); gdouble expected = va_arg (var_args, gdouble);
GstCaps *caps; GstCaps *caps;
gdouble scale; gdouble scale;
gst_event_parse_caps (event, &caps); gst_event_parse_caps (event, &caps);
fail_unless (gst_structure_get_double ( fail_unless (gst_structure_get_double (gst_caps_get_structure (caps, 0),
gst_caps_get_structure (caps, 0), "play-scale", &scale)); "play-scale", &scale));
fail_unless (scale == expected); fail_unless (scale == expected);
} else { } else {
fail ("test cannot validate unknown event field '%s'", field); fail ("test cannot validate unknown event field '%s'", field);
@ -302,8 +305,9 @@ static void validate_event (guint index, const gchar *name,
#define push_rtp_buffer_fails(state, error, field, ...) \ #define push_rtp_buffer_fails(state, error, field, ...) \
push_rtp_buffer_full ((state), (error), (field), __VA_ARGS__) push_rtp_buffer_full ((state), (error), (field), __VA_ARGS__)
static void push_rtp_buffer_full (State *state, GstFlowReturn expected, static void
const gchar *field, ...) push_rtp_buffer_full (State * state, GstFlowReturn expected,
const gchar * field, ...)
{ {
GstBuffer *buf = gst_rtp_buffer_new_allocate (0, 0, 0); GstBuffer *buf = gst_rtp_buffer_new_allocate (0, 0, 0);
GstRTPBuffer rtp = { NULL }; GstRTPBuffer rtp = { NULL };
@ -360,8 +364,9 @@ static void push_rtp_buffer_full (State *state, GstFlowReturn expected,
#define push_buffer(state, field, ...) \ #define push_buffer(state, field, ...) \
push_buffer_full ((state), GST_FLOW_OK, (field), __VA_ARGS__) push_buffer_full ((state), GST_FLOW_OK, (field), __VA_ARGS__)
static void push_buffer_full (State *state, GstFlowReturn expected, static void
const gchar *field, ...) push_buffer_full (State * state, GstFlowReturn expected,
const gchar * field, ...)
{ {
GstBuffer *buf = gst_buffer_new_allocate (0, 0, 0); GstBuffer *buf = gst_buffer_new_allocate (0, 0, 0);
va_list var_args; va_list var_args;
@ -391,12 +396,14 @@ static void push_buffer_full (State *state, GstFlowReturn expected,
fail_unless_equals_int (gst_pad_push (state->srcpad, buf), expected); fail_unless_equals_int (gst_pad_push (state->srcpad, buf), expected);
} }
static void validate_buffers_received (guint received) static void
validate_buffers_received (guint received)
{ {
fail_unless_equals_int (g_list_length (buffers), received); fail_unless_equals_int (g_list_length (buffers), received);
} }
static void validate_buffer (guint index, const gchar *field, ...) static void
validate_buffer (guint index, const gchar * field, ...)
{ {
GstBuffer *buf; GstBuffer *buf;
va_list var_args; va_list var_args;
@ -414,7 +421,7 @@ static void validate_buffer (guint index, const gchar *field, ...)
fail_unless_equals_uint64 (GST_BUFFER_PTS (buf), pts); fail_unless_equals_uint64 (GST_BUFFER_PTS (buf), pts);
} else if (!g_strcmp0 (field, "offset")) { } else if (!g_strcmp0 (field, "offset")) {
guint64 offset = va_arg (var_args, guint64); guint64 offset = va_arg (var_args, guint64);
fail_unless_equals_uint64 (GST_BUFFER_OFFSET(buf), offset); fail_unless_equals_uint64 (GST_BUFFER_OFFSET (buf), offset);
} else if (!g_strcmp0 (field, "discont")) { } else if (!g_strcmp0 (field, "discont")) {
gboolean discont = va_arg (var_args, gboolean); gboolean discont = va_arg (var_args, gboolean);
if (discont) { if (discont) {
@ -430,8 +437,8 @@ static void validate_buffer (guint index, const gchar *field, ...)
va_end (var_args); va_end (var_args);
} }
static State *create_depayloader (const gchar *caps_str, static State *
const gchar *property, ...) create_depayloader (const gchar * caps_str, const gchar * property, ...)
{ {
va_list var_args; va_list var_args;
GstCaps *caps; GstCaps *caps;
@ -468,14 +475,15 @@ static State *create_depayloader (const gchar *caps_str,
return state; return state;
} }
static void set_state (State *state, GstState new_state) static void
set_state (State * state, GstState new_state)
{ {
fail_unless_equals_int (gst_element_set_state (state->element, new_state), fail_unless_equals_int (gst_element_set_state (state->element, new_state),
GST_STATE_CHANGE_SUCCESS); GST_STATE_CHANGE_SUCCESS);
} }
static void packet_lost (State *state, GstClockTime timestamp, static void
GstClockTime duration) packet_lost (State * state, GstClockTime timestamp, GstClockTime duration)
{ {
GstEvent *event; GstEvent *event;
guint seqnum = 0x4243; guint seqnum = 0x4243;
@ -483,18 +491,17 @@ static void packet_lost (State *state, GstClockTime timestamp,
guint retries = 42; guint retries = 42;
event = gst_event_new_custom (GST_EVENT_CUSTOM_DOWNSTREAM, event = gst_event_new_custom (GST_EVENT_CUSTOM_DOWNSTREAM,
gst_structure_new ("GstRTPPacketLost", gst_structure_new ("GstRTPPacketLost",
"seqnum", G_TYPE_UINT, seqnum, "seqnum", G_TYPE_UINT, seqnum,
"timestamp", G_TYPE_UINT64, timestamp, "timestamp", G_TYPE_UINT64, timestamp,
"duration", G_TYPE_UINT64, duration, "duration", G_TYPE_UINT64, duration,
"late", G_TYPE_BOOLEAN, late, "late", G_TYPE_BOOLEAN, late, "retry", G_TYPE_UINT, retries, NULL));;
"retry", G_TYPE_UINT, retries,
NULL));;
fail_unless (gst_pad_push_event (state->srcpad, event)); fail_unless (gst_pad_push_event (state->srcpad, event));
} }
static void reconfigure_caps (State *state, const gchar *caps_str) static void
reconfigure_caps (State * state, const gchar * caps_str)
{ {
GstCaps *newcaps; GstCaps *newcaps;
GstEvent *event; GstEvent *event;
@ -504,7 +511,8 @@ static void reconfigure_caps (State *state, const gchar *caps_str)
fail_unless (gst_pad_push_event (state->srcpad, event)); fail_unless (gst_pad_push_event (state->srcpad, event));
} }
static void flush_pipeline (State *state) static void
flush_pipeline (State * state)
{ {
GstEvent *event; GstEvent *event;
GstSegment segment; GstSegment segment;
@ -517,7 +525,8 @@ static void flush_pipeline (State *state)
fail_unless (gst_pad_push_event (state->srcpad, event)); fail_unless (gst_pad_push_event (state->srcpad, event));
} }
static void destroy_depayloader (State *state) static void
destroy_depayloader (State * state)
{ {
gst_check_teardown_sink_pad (state->element); gst_check_teardown_sink_pad (state->element);
gst_check_teardown_src_pad (state->element); gst_check_teardown_src_pad (state->element);
@ -549,50 +558,35 @@ GST_START_TEST (rtp_base_depayload_buffer_test)
push_rtp_buffer (state, push_rtp_buffer (state,
"pts", 0 * GST_SECOND, "pts", 0 * GST_SECOND,
"rtptime", G_GUINT64_CONSTANT (0x1234), "rtptime", G_GUINT64_CONSTANT (0x1234), "seq", 0x4242, NULL);
"seq", 0x4242,
NULL);
push_rtp_buffer (state, push_rtp_buffer (state,
"pts", 1 * GST_SECOND, "pts", 1 * GST_SECOND,
"rtptime", G_GUINT64_CONSTANT (0x1234) + 1 * DEFAULT_CLOCK_RATE, "rtptime", G_GUINT64_CONSTANT (0x1234) + 1 * DEFAULT_CLOCK_RATE,
"seq", 0x4242 + 1, "seq", 0x4242 + 1, NULL);
NULL);
set_state (state, GST_STATE_NULL); set_state (state, GST_STATE_NULL);
validate_buffers_received (2); validate_buffers_received (2);
validate_buffer (0, validate_buffer (0, "pts", 0 * GST_SECOND, "discont", FALSE, NULL);
"pts", 0 * GST_SECOND,
"discont", FALSE,
NULL);
validate_buffer (1, validate_buffer (1, "pts", 1 * GST_SECOND, "discont", FALSE, NULL);
"pts", 1 * GST_SECOND,
"discont", FALSE,
NULL);
validate_events_received (3); validate_events_received (3);
validate_event (0, "stream-start", validate_event (0, "stream-start", NULL);
NULL);
validate_event (1, "caps", validate_event (1, "caps", "media-type", "application/x-rtp", NULL);
"media-type", "application/x-rtp",
NULL);
validate_event (2, "segment", validate_event (2, "segment",
"time", G_GUINT64_CONSTANT (0), "time", G_GUINT64_CONSTANT (0),
"start", G_GUINT64_CONSTANT (0), "start", G_GUINT64_CONSTANT (0), "stop", G_MAXUINT64, NULL);
"stop", G_MAXUINT64,
NULL);
destroy_depayloader (state); destroy_depayloader (state);
} }
GST_END_TEST GST_END_TEST
/* the intent with this test is to provide the depayloader with a buffer that /* the intent with this test is to provide the depayloader with a buffer that
* does not contain an RTP header. this makes it impossible for the depayloader * does not contain an RTP header. this makes it impossible for the depayloader
* to depayload the incoming RTP packet, yet the stream-start and caps events * to depayload the incoming RTP packet, yet the stream-start and caps events
@ -607,9 +601,7 @@ GST_START_TEST (rtp_base_depayload_invalid_rtp_packet_test)
set_state (state, GST_STATE_PLAYING); set_state (state, GST_STATE_PLAYING);
push_buffer (state, push_buffer (state,
"pts", 0 * GST_SECOND, "pts", 0 * GST_SECOND, "offset", GST_BUFFER_OFFSET_NONE, NULL);
"offset", GST_BUFFER_OFFSET_NONE,
NULL);
set_state (state, GST_STATE_NULL); set_state (state, GST_STATE_NULL);
@ -617,18 +609,14 @@ GST_START_TEST (rtp_base_depayload_invalid_rtp_packet_test)
validate_events_received (2); validate_events_received (2);
validate_event (0, "stream-start", validate_event (0, "stream-start", NULL);
NULL);
validate_event (1, "caps", validate_event (1, "caps", "media-type", "application/x-rtp", NULL);
"media-type", "application/x-rtp",
NULL);
destroy_depayloader (state); destroy_depayloader (state);
} }
GST_END_TEST GST_END_TEST
/* validate what happens when a depayloader is provided with two RTP packets /* validate what happens when a depayloader is provided with two RTP packets
* sent after each other that do not have sequential sequence numbers. in this * sent after each other that do not have sequential sequence numbers. in this
* case the depayloader should be able to depayload both first and the second * case the depayloader should be able to depayload both first and the second
@ -647,50 +635,35 @@ GST_START_TEST (rtp_base_depayload_with_gap_test)
push_rtp_buffer (state, push_rtp_buffer (state,
"pts", 0 * GST_SECOND, "pts", 0 * GST_SECOND,
"rtptime", G_GUINT64_CONSTANT (0x43214321), "rtptime", G_GUINT64_CONSTANT (0x43214321), "seq", 0x4242, NULL);
"seq", 0x4242,
NULL);
push_rtp_buffer (state, push_rtp_buffer (state,
"pts", 1 * GST_SECOND, "pts", 1 * GST_SECOND,
"rtptime", G_GUINT64_CONSTANT (0x43214321) + 1 * DEFAULT_CLOCK_RATE, "rtptime", G_GUINT64_CONSTANT (0x43214321) + 1 * DEFAULT_CLOCK_RATE,
"seq", 0x4242 + 2, "seq", 0x4242 + 2, NULL);
NULL);
set_state (state, GST_STATE_NULL); set_state (state, GST_STATE_NULL);
validate_buffers_received (2); validate_buffers_received (2);
validate_buffer (0, validate_buffer (0, "pts", 0 * GST_SECOND, "discont", FALSE, NULL);
"pts", 0 * GST_SECOND,
"discont", FALSE,
NULL);
validate_buffer (1, validate_buffer (1, "pts", 1 * GST_SECOND, "discont", TRUE, NULL);
"pts", 1 * GST_SECOND,
"discont", TRUE,
NULL);
validate_events_received (3); validate_events_received (3);
validate_event (0, "stream-start", validate_event (0, "stream-start", NULL);
NULL);
validate_event (1, "caps", validate_event (1, "caps", "media-type", "application/x-rtp", NULL);
"media-type", "application/x-rtp",
NULL);
validate_event (2, "segment", validate_event (2, "segment",
"time", G_GUINT64_CONSTANT (0), "time", G_GUINT64_CONSTANT (0),
"start", G_GUINT64_CONSTANT (0), "start", G_GUINT64_CONSTANT (0), "stop", G_MAXUINT64, NULL);
"stop", G_MAXUINT64,
NULL);
destroy_depayloader (state); destroy_depayloader (state);
} }
GST_END_TEST GST_END_TEST
/* two RTP packets are pushed in this test, and while the sequence numbers are /* two RTP packets are pushed in this test, and while the sequence numbers are
* sequential they are reversed. the expectation is that the depayloader will be * sequential they are reversed. the expectation is that the depayloader will be
* able to depayload the first RTP packet, but once the second RTP packet * able to depayload the first RTP packet, but once the second RTP packet
@ -707,45 +680,33 @@ GST_START_TEST (rtp_base_depayload_reversed_test)
push_rtp_buffer (state, push_rtp_buffer (state,
"pts", 0 * GST_SECOND, "pts", 0 * GST_SECOND,
"rtptime", G_GUINT64_CONSTANT (0x43214321), "rtptime", G_GUINT64_CONSTANT (0x43214321), "seq", 0x4242, NULL);
"seq", 0x4242,
NULL);
push_rtp_buffer (state, push_rtp_buffer (state,
"pts", 1 * GST_SECOND, "pts", 1 * GST_SECOND,
"rtptime", G_GUINT64_CONSTANT (0x43214321) + 1 * DEFAULT_CLOCK_RATE, "rtptime", G_GUINT64_CONSTANT (0x43214321) + 1 * DEFAULT_CLOCK_RATE,
"seq", 0x4242 - 1, "seq", 0x4242 - 1, NULL);
NULL);
set_state (state, GST_STATE_NULL); set_state (state, GST_STATE_NULL);
validate_buffers_received (1); validate_buffers_received (1);
validate_buffer (0, validate_buffer (0, "pts", 0 * GST_SECOND, "discont", FALSE, NULL);
"pts", 0 * GST_SECOND,
"discont", FALSE,
NULL);
validate_events_received (3); validate_events_received (3);
validate_event (0, "stream-start", validate_event (0, "stream-start", NULL);
NULL);
validate_event (1, "caps", validate_event (1, "caps", "media-type", "application/x-rtp", NULL);
"media-type", "application/x-rtp",
NULL);
validate_event (2, "segment", validate_event (2, "segment",
"time", G_GUINT64_CONSTANT (0), "time", G_GUINT64_CONSTANT (0),
"start", G_GUINT64_CONSTANT (0), "start", G_GUINT64_CONSTANT (0), "stop", G_MAXUINT64, NULL);
"stop", G_MAXUINT64,
NULL);
destroy_depayloader (state); destroy_depayloader (state);
} }
GST_END_TEST GST_END_TEST
/* the intent of this test is to push two RTP packets that have reverse sequence /* the intent of this test is to push two RTP packets that have reverse sequence
* numbers that differ significantly. the depayloader will consider RTP packets * numbers that differ significantly. the depayloader will consider RTP packets
* where the sequence numbers differ by more than 1000 to indicate that the * where the sequence numbers differ by more than 1000 to indicate that the
@ -764,50 +725,35 @@ GST_START_TEST (rtp_base_depayload_old_reversed_test)
push_rtp_buffer (state, push_rtp_buffer (state,
"pts", 0 * GST_SECOND, "pts", 0 * GST_SECOND,
"rtptime", G_GUINT64_CONSTANT (0x43214321), "rtptime", G_GUINT64_CONSTANT (0x43214321), "seq", 0x4242, NULL);
"seq", 0x4242,
NULL);
push_rtp_buffer (state, push_rtp_buffer (state,
"pts", 1 * GST_SECOND, "pts", 1 * GST_SECOND,
"rtptime", G_GUINT64_CONSTANT (0x43214321) + 1 * DEFAULT_CLOCK_RATE, "rtptime", G_GUINT64_CONSTANT (0x43214321) + 1 * DEFAULT_CLOCK_RATE,
"seq", 0x4242 - 1000, "seq", 0x4242 - 1000, NULL);
NULL);
set_state (state, GST_STATE_NULL); set_state (state, GST_STATE_NULL);
validate_buffers_received (2); validate_buffers_received (2);
validate_buffer (0, validate_buffer (0, "pts", 0 * GST_SECOND, "discont", FALSE, NULL);
"pts", 0 * GST_SECOND,
"discont", FALSE,
NULL);
validate_buffer (1, validate_buffer (1, "pts", 1 * GST_SECOND, "discont", TRUE, NULL);
"pts", 1 * GST_SECOND,
"discont", TRUE,
NULL);
validate_events_received (3); validate_events_received (3);
validate_event (0, "stream-start", validate_event (0, "stream-start", NULL);
NULL);
validate_event (1, "caps", validate_event (1, "caps", "media-type", "application/x-rtp", NULL);
"media-type", "application/x-rtp",
NULL);
validate_event (2, "segment", validate_event (2, "segment",
"time", G_GUINT64_CONSTANT (0), "time", G_GUINT64_CONSTANT (0),
"start", G_GUINT64_CONSTANT (0), "start", G_GUINT64_CONSTANT (0), "stop", G_MAXUINT64, NULL);
"stop", G_MAXUINT64,
NULL);
destroy_depayloader (state); destroy_depayloader (state);
} }
GST_END_TEST GST_END_TEST
/* a depayloader that has not received any caps event will not be able to /* a depayloader that has not received any caps event will not be able to
* process any incoming RTP packet. instead pushing an RTP packet should result * process any incoming RTP packet. instead pushing an RTP packet should result
* in the expected error. * in the expected error.
@ -822,9 +768,7 @@ GST_START_TEST (rtp_base_depayload_without_negotiation_test)
push_rtp_buffer_fails (state, GST_FLOW_NOT_NEGOTIATED, push_rtp_buffer_fails (state, GST_FLOW_NOT_NEGOTIATED,
"pts", 0 * GST_SECOND, "pts", 0 * GST_SECOND,
"rtptime", G_GUINT64_CONSTANT (0x1234), "rtptime", G_GUINT64_CONSTANT (0x1234), "seq", 0x4242, NULL);
"seq", 0x4242,
NULL);
set_state (state, GST_STATE_NULL); set_state (state, GST_STATE_NULL);
@ -832,14 +776,12 @@ GST_START_TEST (rtp_base_depayload_without_negotiation_test)
validate_events_received (1); validate_events_received (1);
validate_event (0, "stream-start", validate_event (0, "stream-start", NULL);
NULL);
destroy_depayloader (state); destroy_depayloader (state);
} }
GST_END_TEST GST_END_TEST
/* a depayloader that receives the downstream event GstRTPPacketLost should /* a depayloader that receives the downstream event GstRTPPacketLost should
* respond by emitting a gap event with the corresponding timestamp and * respond by emitting a gap event with the corresponding timestamp and
* duration. the initial events are unaffected, but are succeeded by the added * duration. the initial events are unaffected, but are succeeded by the added
@ -855,57 +797,40 @@ GST_START_TEST (rtp_base_depayload_packet_lost_test)
push_rtp_buffer (state, push_rtp_buffer (state,
"pts", 0 * GST_SECOND, "pts", 0 * GST_SECOND,
"rtptime", G_GUINT64_CONSTANT (0x1234), "rtptime", G_GUINT64_CONSTANT (0x1234), "seq", 0x4242, NULL);
"seq", 0x4242,
NULL);
packet_lost (state, 1 * GST_SECOND, GST_SECOND); packet_lost (state, 1 * GST_SECOND, GST_SECOND);
push_rtp_buffer (state, push_rtp_buffer (state,
"pts", 2 * GST_SECOND, "pts", 2 * GST_SECOND,
"rtptime", G_GUINT64_CONSTANT (0x1234) + 2 * DEFAULT_CLOCK_RATE, "rtptime", G_GUINT64_CONSTANT (0x1234) + 2 * DEFAULT_CLOCK_RATE,
"seq", 0x4242 + 2, "seq", 0x4242 + 2, NULL);
NULL);
set_state (state, GST_STATE_NULL); set_state (state, GST_STATE_NULL);
validate_buffers_received (2); validate_buffers_received (2);
validate_buffer (0, validate_buffer (0, "pts", 0 * GST_SECOND, "discont", FALSE, NULL);
"pts", 0 * GST_SECOND,
"discont", FALSE,
NULL);
validate_buffer (1, validate_buffer (1, "pts", 2 * GST_SECOND, "discont", TRUE, NULL);
"pts", 2 * GST_SECOND,
"discont", TRUE,
NULL);
validate_events_received (4); validate_events_received (4);
validate_event (0, "stream-start", validate_event (0, "stream-start", NULL);
NULL);
validate_event (1, "caps", validate_event (1, "caps", "media-type", "application/x-rtp", NULL);
"media-type", "application/x-rtp",
NULL);
validate_event (2, "segment", validate_event (2, "segment",
"time", G_GUINT64_CONSTANT (0), "time", G_GUINT64_CONSTANT (0),
"start", G_GUINT64_CONSTANT (0), "start", G_GUINT64_CONSTANT (0), "stop", G_MAXUINT64, NULL);
"stop", G_MAXUINT64,
NULL);
validate_event (3, "gap", validate_event (3, "gap",
"timestamp", 1 * GST_SECOND, "timestamp", 1 * GST_SECOND, "duration", GST_SECOND, NULL);
"duration", GST_SECOND,
NULL);
destroy_depayloader (state); destroy_depayloader (state);
} }
GST_END_TEST GST_END_TEST
/* a depayloader that receives identical caps events simply ignores the latter /* a depayloader that receives identical caps events simply ignores the latter
* events without propagating them downstream. * events without propagating them downstream.
*/ */
@ -919,46 +844,32 @@ GST_START_TEST (rtp_base_depayload_repeated_caps_test)
push_rtp_buffer (state, push_rtp_buffer (state,
"pts", 0 * GST_SECOND, "pts", 0 * GST_SECOND,
"rtptime", G_GUINT64_CONSTANT (0x1234), "rtptime", G_GUINT64_CONSTANT (0x1234), "seq", 0x4242, NULL);
"seq", 0x4242,
NULL);
reconfigure_caps (state, "application/x-rtp"); reconfigure_caps (state, "application/x-rtp");
push_rtp_buffer (state, push_rtp_buffer (state,
"pts", 1 * GST_SECOND, "pts", 1 * GST_SECOND,
"rtptime", G_GUINT64_CONSTANT (0x1234) + 1 * DEFAULT_CLOCK_RATE, "rtptime", G_GUINT64_CONSTANT (0x1234) + 1 * DEFAULT_CLOCK_RATE,
"seq", 0x4242 + 1, "seq", 0x4242 + 1, NULL);
NULL);
set_state (state, GST_STATE_NULL); set_state (state, GST_STATE_NULL);
validate_buffers_received (2); validate_buffers_received (2);
validate_buffer (0, validate_buffer (0, "pts", 0 * GST_SECOND, "discont", FALSE, NULL);
"pts", 0 * GST_SECOND,
"discont", FALSE,
NULL);
validate_buffer (1, validate_buffer (1, "pts", 1 * GST_SECOND, "discont", FALSE, NULL);
"pts", 1 * GST_SECOND,
"discont", FALSE,
NULL);
validate_events_received (3); validate_events_received (3);
validate_event (0, "stream-start", validate_event (0, "stream-start", NULL);
NULL);
validate_event (1, "caps", validate_event (1, "caps", "media-type", "application/x-rtp", NULL);
"media-type", "application/x-rtp",
NULL);
validate_event (2, "segment", validate_event (2, "segment",
"time", G_GUINT64_CONSTANT (0), "time", G_GUINT64_CONSTANT (0),
"start", G_GUINT64_CONSTANT (0), "start", G_GUINT64_CONSTANT (0), "stop", G_MAXUINT64, NULL);
"stop", G_MAXUINT64,
NULL);
destroy_depayloader (state); destroy_depayloader (state);
} }
@ -981,9 +892,7 @@ GST_START_TEST (rtp_base_depayload_npt_test)
push_rtp_buffer (state, push_rtp_buffer (state,
"pts", 0 * GST_SECOND, "pts", 0 * GST_SECOND,
"rtptime", G_GUINT64_CONSTANT (0x1234), "rtptime", G_GUINT64_CONSTANT (0x1234), "seq", 0x4242, NULL);
"seq", 0x4242,
NULL);
reconfigure_caps (state, reconfigure_caps (state,
"application/x-rtp, npt-start=(guint64)1234, npt-stop=(guint64)4321"); "application/x-rtp, npt-start=(guint64)1234, npt-stop=(guint64)4321");
@ -993,61 +902,44 @@ GST_START_TEST (rtp_base_depayload_npt_test)
push_rtp_buffer (state, push_rtp_buffer (state,
"pts", 1 * GST_SECOND, "pts", 1 * GST_SECOND,
"rtptime", G_GUINT64_CONSTANT (0x1234) + 1 * DEFAULT_CLOCK_RATE, "rtptime", G_GUINT64_CONSTANT (0x1234) + 1 * DEFAULT_CLOCK_RATE,
"seq", 0x4242 + 1, "seq", 0x4242 + 1, NULL);
NULL);
set_state (state, GST_STATE_NULL); set_state (state, GST_STATE_NULL);
validate_buffers_received (2); validate_buffers_received (2);
validate_buffer (0, validate_buffer (0, "pts", 0 * GST_SECOND, "discont", FALSE, NULL);
"pts", 0 * GST_SECOND,
"discont", FALSE,
NULL);
validate_buffer (1, validate_buffer (1, "pts", 1 * GST_SECOND, "discont", FALSE, NULL);
"pts", 1 * GST_SECOND,
"discont", FALSE,
NULL);
validate_events_received (7); validate_events_received (7);
validate_event (0, "stream-start", validate_event (0, "stream-start", NULL);
NULL);
validate_event (1, "caps", validate_event (1, "caps", "media-type", "application/x-rtp", NULL);
"media-type", "application/x-rtp",
NULL);
validate_event (2, "segment", validate_event (2, "segment",
"time", G_GUINT64_CONSTANT (0), "time", G_GUINT64_CONSTANT (0),
"start", G_GUINT64_CONSTANT (0), "start", G_GUINT64_CONSTANT (0), "stop", G_MAXUINT64, NULL);
"stop", G_MAXUINT64,
NULL);
validate_event (3, "caps", validate_event (3, "caps",
"media-type", "application/x-rtp", "media-type", "application/x-rtp",
"npt-start", G_GUINT64_CONSTANT (1234), "npt-start", G_GUINT64_CONSTANT (1234),
"npt-stop", G_GUINT64_CONSTANT (4321), "npt-stop", G_GUINT64_CONSTANT (4321), NULL);
NULL);
validate_event (4, "flush-start", validate_event (4, "flush-start", NULL);
NULL);
validate_event (5, "flush-stop", validate_event (5, "flush-stop", NULL);
NULL);
validate_event (6, "segment", validate_event (6, "segment",
"time", G_GUINT64_CONSTANT (1234), "time", G_GUINT64_CONSTANT (1234),
"start", G_GUINT64_CONSTANT (0), "start", G_GUINT64_CONSTANT (0),
"stop", G_GUINT64_CONSTANT (4321 - 1234), "stop", G_GUINT64_CONSTANT (4321 - 1234), NULL);
NULL);
destroy_depayloader (state); destroy_depayloader (state);
} }
GST_END_TEST GST_END_TEST
/* when a depayloader receives a new caps event with play-scale it should save /* when a depayloader receives a new caps event with play-scale it should save
* this rate as it should affect the next segment event being pushed by the * this rate as it should affect the next segment event being pushed by the
* depayloader. a new segment event is not pushed by the depayloader until a * depayloader. a new segment event is not pushed by the depayloader until a
@ -1064,74 +956,51 @@ GST_START_TEST (rtp_base_depayload_play_scale_test)
push_rtp_buffer (state, push_rtp_buffer (state,
"pts", 0 * GST_SECOND, "pts", 0 * GST_SECOND,
"rtptime", G_GUINT64_CONSTANT (0x1234), "rtptime", G_GUINT64_CONSTANT (0x1234), "seq", 0x4242, NULL);
"seq", 0x4242,
NULL);
reconfigure_caps (state, reconfigure_caps (state, "application/x-rtp, play-scale=(double)2.0");
"application/x-rtp, play-scale=(double)2.0");
flush_pipeline (state); flush_pipeline (state);
push_rtp_buffer (state, push_rtp_buffer (state,
"pts", 1 * GST_SECOND, "pts", 1 * GST_SECOND,
"rtptime", G_GUINT64_CONSTANT (0x1234) + 1 * DEFAULT_CLOCK_RATE, "rtptime", G_GUINT64_CONSTANT (0x1234) + 1 * DEFAULT_CLOCK_RATE,
"seq", 0x4242 + 1, "seq", 0x4242 + 1, NULL);
NULL);
set_state (state, GST_STATE_NULL); set_state (state, GST_STATE_NULL);
validate_buffers_received (2); validate_buffers_received (2);
validate_buffer (0, validate_buffer (0, "pts", 0 * GST_SECOND, "discont", FALSE, NULL);
"pts", 0 * GST_SECOND,
"discont", FALSE,
NULL);
validate_buffer (1, validate_buffer (1, "pts", 1 * GST_SECOND, "discont", FALSE, NULL);
"pts", 1 * GST_SECOND,
"discont", FALSE,
NULL);
validate_events_received (7); validate_events_received (7);
validate_event (0, "stream-start", validate_event (0, "stream-start", NULL);
NULL);
validate_event (1, "caps", validate_event (1, "caps", "media-type", "application/x-rtp", NULL);
"media-type", "application/x-rtp",
NULL);
validate_event (2, "segment", validate_event (2, "segment",
"time", G_GUINT64_CONSTANT (0), "time", G_GUINT64_CONSTANT (0),
"start", G_GUINT64_CONSTANT (0), "start", G_GUINT64_CONSTANT (0), "stop", G_MAXUINT64, NULL);
"stop", G_MAXUINT64,
NULL);
validate_event (3, "caps", validate_event (3, "caps",
"media-type", "application/x-rtp", "media-type", "application/x-rtp", "play-scale", 2.0, NULL);
"play-scale", 2.0,
NULL);
validate_event (4, "flush-start", validate_event (4, "flush-start", NULL);
NULL);
validate_event (5, "flush-stop", validate_event (5, "flush-stop", NULL);
NULL);
validate_event (6, "segment", validate_event (6, "segment",
"time", G_GUINT64_CONSTANT (0), "time", G_GUINT64_CONSTANT (0),
"start", G_GUINT64_CONSTANT (0), "start", G_GUINT64_CONSTANT (0),
"stop", G_MAXUINT64, "stop", G_MAXUINT64, "rate", 1.0, "applied-rate", 2.0, NULL);
"rate", 1.0,
"applied-rate", 2.0,
NULL);
destroy_depayloader (state); destroy_depayloader (state);
} }
GST_END_TEST GST_END_TEST
/* when a depayloader receives a new caps event with play-speed it should save /* when a depayloader receives a new caps event with play-speed it should save
* this rate as it should affect the next segment event being pushed by the * this rate as it should affect the next segment event being pushed by the
* depayloader. a new segment event is not pushed by the depayloader until a * depayloader. a new segment event is not pushed by the depayloader until a
@ -1148,75 +1017,51 @@ GST_START_TEST (rtp_base_depayload_play_speed_test)
push_rtp_buffer (state, push_rtp_buffer (state,
"pts", 0 * GST_SECOND, "pts", 0 * GST_SECOND,
"rtptime", G_GUINT64_CONSTANT (0x1234), "rtptime", G_GUINT64_CONSTANT (0x1234), "seq", 0x4242, NULL);
"seq", 0x4242,
NULL);
reconfigure_caps (state, reconfigure_caps (state, "application/x-rtp, play-speed=(double)2.0");
"application/x-rtp, play-speed=(double)2.0");
flush_pipeline (state); flush_pipeline (state);
push_rtp_buffer (state, push_rtp_buffer (state,
"pts", 1 * GST_SECOND, "pts", 1 * GST_SECOND,
"rtptime", G_GUINT64_CONSTANT (0x1234) + 1 * DEFAULT_CLOCK_RATE, "rtptime", G_GUINT64_CONSTANT (0x1234) + 1 * DEFAULT_CLOCK_RATE,
"seq", 0x4242 + 1, "seq", 0x4242 + 1, NULL);
NULL);
set_state (state, GST_STATE_NULL); set_state (state, GST_STATE_NULL);
validate_buffers_received (2); validate_buffers_received (2);
validate_buffer (0, validate_buffer (0, "pts", 0 * GST_SECOND, "discont", FALSE, NULL);
"pts", 0 * GST_SECOND,
"discont", FALSE,
NULL);
validate_buffer (1, validate_buffer (1, "pts", 1 * GST_SECOND, "discont", FALSE, NULL);
"pts", 1 * GST_SECOND,
"discont", FALSE,
NULL);
validate_events_received (7); validate_events_received (7);
validate_event (0, "stream-start", validate_event (0, "stream-start", NULL);
NULL);
validate_event (1, "caps", validate_event (1, "caps", "media-type", "application/x-rtp", NULL);
"media-type", "application/x-rtp",
NULL);
validate_event (2, "segment", validate_event (2, "segment",
"time", G_GUINT64_CONSTANT (0), "time", G_GUINT64_CONSTANT (0),
"start", G_GUINT64_CONSTANT (0), "start", G_GUINT64_CONSTANT (0), "stop", G_MAXUINT64, NULL);
"stop", G_MAXUINT64,
NULL);
validate_event (3, "caps", validate_event (3, "caps",
"media-type", "application/x-rtp", "media-type", "application/x-rtp", "play-speed", 2.0, NULL);
"play-speed", 2.0,
NULL);
validate_event (4, "flush-start", validate_event (4, "flush-start", NULL);
NULL);
validate_event (5, "flush-stop", validate_event (5, "flush-stop", NULL);
NULL);
validate_event (6, "segment", validate_event (6, "segment",
"time", G_GUINT64_CONSTANT (0), "time", G_GUINT64_CONSTANT (0),
"start", G_GUINT64_CONSTANT (0), "start", G_GUINT64_CONSTANT (0),
"stop", G_MAXUINT64, "stop", G_MAXUINT64, "rate", 2.0, "applied-rate", 1.0, NULL);
"rate", 2.0,
"applied-rate", 1.0,
NULL);
destroy_depayloader (state); destroy_depayloader (state);
} }
GST_END_TEST GST_END_TEST static Suite *
static Suite *
rtp_basepayloading_suite (void) rtp_basepayloading_suite (void)
{ {
Suite *s = suite_create ("rtp_base_depayloading_test"); Suite *s = suite_create ("rtp_base_depayloading_test");