GstBuffer *paybuffer;
GST_LOG ("payloading buffer pts=%" GST_TIME_FORMAT " offset=%"
- G_GUINT64_FORMAT, GST_TIME_ARGS (GST_BUFFER_PTS (buffer)),
- GST_BUFFER_OFFSET(buffer));
+ G_GUINT64_FORMAT, GST_TIME_ARGS (GST_BUFFER_PTS (buffer)),
+ GST_BUFFER_OFFSET (buffer));
if (!gst_pad_has_current_caps (GST_RTP_BASE_PAYLOAD_SRCPAD (pay))) {
if (!gst_rtp_base_payload_set_outcaps (GST_RTP_BASE_PAYLOAD (pay),
- "custom-caps", G_TYPE_UINT, DEFAULT_CLOCK_RATE, NULL)) {
+ "custom-caps", G_TYPE_UINT, DEFAULT_CLOCK_RATE, NULL)) {
gst_buffer_unref (buffer);
return GST_FLOW_NOT_NEGOTIATED;
}
gst_buffer_append (paybuffer, buffer);
GST_LOG ("payloaded buffer pts=%" GST_TIME_FORMAT " offset=%"
- G_GUINT64_FORMAT, GST_TIME_ARGS (GST_BUFFER_PTS (paybuffer)),
- GST_BUFFER_OFFSET(paybuffer));
+ G_GUINT64_FORMAT, GST_TIME_ARGS (GST_BUFFER_PTS (paybuffer)),
+ GST_BUFFER_OFFSET (paybuffer));
if (GST_BUFFER_PTS (paybuffer) < BUFFER_BEFORE_LIST) {
return gst_rtp_base_payload_push (pay, paybuffer);
- } else {
+ } else {
GstBufferList *list = gst_buffer_list_new ();
gst_buffer_list_add (list, paybuffer);
return gst_rtp_base_payload_push_list (pay, list);
GST_PAD_SINK,
GST_PAD_ALWAYS,
GST_STATIC_CAPS ("application/x-rtp, payload=(int)98, ssrc=(uint)24, "
- "timestamp-offset=(uint)212, seqnum-offset=(uint)2424"));
+ "timestamp-offset=(uint)212, seqnum-offset=(uint)2424"));
typedef struct State State;
-struct State {
+struct State
+{
GstElement *element;
GstPad *sinkpad;
GstPad *srcpad;
return gst_pad_event_default (pad, noparent, event);
}
-static void drop_events (void)
+static void
+drop_events (void)
{
while (events != NULL) {
gst_event_unref (GST_EVENT (events->data));
}
}
-static void validate_events_received (guint received)
+static void
+validate_events_received (guint received)
{
fail_unless_equals_int (g_list_length (events), received);
}
-static void validate_event (guint index, const gchar *name,
- const gchar *field, ...)
+static void
+validate_event (guint index, const gchar * name, const gchar * field, ...)
{
GstEvent *event;
va_list var_args;
GstCaps *caps;
GstClockTime start;
gst_event_parse_caps (event, &caps);
- fail_unless (gst_structure_get_clock_time (
- gst_caps_get_structure (caps, 0), "npt-start", &start));
+ fail_unless (gst_structure_get_clock_time (gst_caps_get_structure (caps,
+ 0), "npt-start", &start));
fail_unless_equals_uint64 (start, expected);
} else if (!g_strcmp0 (field, "npt-stop")) {
GstClockTime expected = va_arg (var_args, GstClockTime);
GstCaps *caps;
GstClockTime stop;
gst_event_parse_caps (event, &caps);
- fail_unless (gst_structure_get_clock_time (
- gst_caps_get_structure (caps, 0), "npt-stop", &stop));
+ fail_unless (gst_structure_get_clock_time (gst_caps_get_structure (caps,
+ 0), "npt-stop", &stop));
fail_unless_equals_uint64 (stop, expected);
} else if (!g_strcmp0 (field, "play-speed")) {
gdouble expected = va_arg (var_args, gdouble);
GstCaps *caps;
gdouble speed;
gst_event_parse_caps (event, &caps);
- fail_unless (gst_structure_get_double (
- gst_caps_get_structure (caps, 0), "play-speed", &speed));
+ fail_unless (gst_structure_get_double (gst_caps_get_structure (caps, 0),
+ "play-speed", &speed));
fail_unless (speed == expected);
} else if (!g_strcmp0 (field, "play-scale")) {
gdouble expected = va_arg (var_args, gdouble);
GstCaps *caps;
gdouble scale;
gst_event_parse_caps (event, &caps);
- fail_unless (gst_structure_get_double (
- gst_caps_get_structure (caps, 0), "play-scale", &scale));
+ fail_unless (gst_structure_get_double (gst_caps_get_structure (caps, 0),
+ "play-scale", &scale));
fail_unless (scale == expected);
} else if (!g_strcmp0 (field, "ssrc")) {
guint expected = va_arg (var_args, guint);
GstCaps *caps;
guint ssrc;
gst_event_parse_caps (event, &caps);
- fail_unless (gst_structure_get_uint (
- gst_caps_get_structure (caps, 0), "ssrc", &ssrc));
+ fail_unless (gst_structure_get_uint (gst_caps_get_structure (caps, 0),
+ "ssrc", &ssrc));
fail_unless_equals_int (ssrc, expected);
} else {
fail ("test cannot validate unknown event field '%s'", field);
va_end (var_args);
}
-static void validate_normal_start_events (uint index)
+static void
+validate_normal_start_events (uint index)
{
- validate_event (index, "stream-start",
- NULL);
+ validate_event (index, "stream-start", NULL);
- validate_event (index + 1, "caps",
- "media-type", "application/x-rtp",
- NULL);
+ validate_event (index + 1, "caps", "media-type", "application/x-rtp", NULL);
validate_event (index + 2, "segment",
"time", G_GUINT64_CONSTANT (0),
- "start", G_GUINT64_CONSTANT (0),
- "stop", G_MAXUINT64,
- NULL);
+ "start", G_GUINT64_CONSTANT (0), "stop", G_MAXUINT64, NULL);
}
#define push_buffer(state, field, ...) \
#define push_buffer_fails(state, field, ...) \
push_buffer_full ((state), GST_FLOW_FLUSHING, (field), __VA_ARGS__)
-static void push_buffer_full (State *state, GstFlowReturn expected,
- const gchar *field, ...)
+static void
+push_buffer_full (State * state, GstFlowReturn expected,
+ const gchar * field, ...)
{
GstBuffer *buf = gst_rtp_buffer_new_allocate (0, 0, 0);
GstRTPBuffer rtp = { NULL };
fail_unless_equals_int (gst_pad_push (state->srcpad, buf), expected);
}
-static void push_buffer_list (State *state, const gchar *field, ...)
+static void
+push_buffer_list (State * state, const gchar * field, ...)
{
GstBuffer *buf = gst_rtp_buffer_new_allocate (0, 0, 0);
GstRTPBuffer rtp = { NULL };
fail_unless_equals_int (gst_pad_push_list (state->srcpad, list), GST_FLOW_OK);
}
-static void validate_buffers_received (guint received_buffers)
+static void
+validate_buffers_received (guint received_buffers)
{
fail_unless_equals_int (g_list_length (buffers), received_buffers);
}
-static void validate_buffer (guint index, const gchar *field, ...)
+static void
+validate_buffer (guint index, const gchar * field, ...)
{
GstBuffer *buf;
GstRTPBuffer rtp = { NULL };
fail_unless_equals_uint64 (GST_BUFFER_PTS (buf), pts);
} else if (!g_strcmp0 (field, "offset")) {
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")) {
gboolean discont = va_arg (var_args, gboolean);
if (discont) {
}
}
-static void get_buffer_field (guint index, const gchar *field, ...)
+static void
+get_buffer_field (guint index, const gchar * field, ...)
{
GstBuffer *buf;
GstRTPBuffer rtp = { NULL };
guint64 *offset = va_arg (var_args, guint64 *);
*offset = GST_BUFFER_OFFSET (buf);
} else if (!g_strcmp0 (field, "discont")) {
- gboolean *discont = va_arg (var_args, gboolean*);
+ gboolean *discont = va_arg (var_args, gboolean *);
*discont = GST_BUFFER_FLAG_IS_SET (buf, GST_BUFFER_FLAG_DISCONT);
} else {
if (!mapped) {
gst_rtp_buffer_unmap (&rtp);
}
-static State *create_payloader (const gchar *caps_str,
- GstStaticPadTemplate *sinktmpl, const gchar *property, ...)
+static State *
+create_payloader (const gchar * caps_str,
+ GstStaticPadTemplate * sinktmpl, const gchar * property, ...)
{
va_list var_args;
GstCaps *caps;
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),
GST_STATE_CHANGE_SUCCESS);
}
-static void validate_would_not_be_filled (State *state, guint size,
- GstClockTime duration)
+static void
+validate_would_not_be_filled (State * state, guint size, GstClockTime duration)
{
GstRTPBasePayload *basepay;
basepay = GST_RTP_BASE_PAYLOAD (state->element);
fail_if (gst_rtp_base_payload_is_filled (basepay, size, duration));
}
-static void validate_would_be_filled (State *state, guint size,
- GstClockTime duration)
+static void
+validate_would_be_filled (State * state, guint size, GstClockTime duration)
{
GstRTPBasePayload *basepay;
basepay = GST_RTP_BASE_PAYLOAD (state->element);
fail_unless (gst_rtp_base_payload_is_filled (basepay, size, duration));
}
-static void ssrc_collision (State *state, guint ssrc,
+static void
+ssrc_collision (State * state, guint ssrc,
gboolean have_new_ssrc, guint new_ssrc)
{
GstStructure *s;
if (have_new_ssrc) {
s = gst_structure_new ("GstRTPCollision",
"ssrc", G_TYPE_UINT, ssrc,
- "suggested-ssrc", G_TYPE_UINT, new_ssrc,
- NULL);
+ "suggested-ssrc", G_TYPE_UINT, new_ssrc, NULL);
} else {
- s = gst_structure_new ("GstRTPCollision",
- "ssrc", G_TYPE_UINT, ssrc,
- NULL);
+ s = gst_structure_new ("GstRTPCollision", "ssrc", G_TYPE_UINT, ssrc, NULL);
}
event = gst_event_new_custom (GST_EVENT_CUSTOM_UPSTREAM, s);
fail_unless (gst_pad_push_event (state->sinkpad, event));
}
-static void reconfigure (State *state)
+static void
+reconfigure (State * state)
{
GstEvent *event;
event = gst_event_new_reconfigure ();
fail_unless (gst_pad_push_event (state->sinkpad, event));
}
-static void validate_stats (State *state, guint clock_rate,
+static void
+validate_stats (State * state, guint clock_rate,
GstClockTime running_time, guint16 seq, guint32 rtptime)
{
GstStructure *stats;
g_object_get (state->element, "stats", &stats, NULL);
- fail_unless_equals_int (
- g_value_get_uint (gst_structure_get_value (stats, "clock-rate")),
- clock_rate);
- fail_unless_equals_uint64 (
- g_value_get_uint64 (gst_structure_get_value (stats, "running-time")),
- running_time);
- fail_unless_equals_int (
- g_value_get_uint (gst_structure_get_value (stats, "seqnum")),
- seq);
- fail_unless_equals_int (
- g_value_get_uint (gst_structure_get_value (stats, "timestamp")),
- rtptime);
+ fail_unless_equals_int (g_value_get_uint (gst_structure_get_value (stats,
+ "clock-rate")), clock_rate);
+ fail_unless_equals_uint64 (g_value_get_uint64 (gst_structure_get_value (stats,
+ "running-time")), running_time);
+ fail_unless_equals_int (g_value_get_uint (gst_structure_get_value (stats,
+ "seqnum")), seq);
+ fail_unless_equals_int (g_value_get_uint (gst_structure_get_value (stats,
+ "timestamp")), rtptime);
gst_structure_free (stats);
}
-static void destroy_payloader (State *state)
+static void
+destroy_payloader (State * state)
{
gst_check_teardown_sink_pad (state->element);
gst_check_teardown_src_pad (state->element);
guint16 seq;
state = create_payloader ("application/x-rtp", &sinktmpl,
- "perfect-rtptime", FALSE,
- NULL);
+ "perfect-rtptime", FALSE, NULL);
set_state (state, GST_STATE_PLAYING);
- push_buffer (state,
- "pts", 0 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 0 * GST_SECOND, NULL);
- push_buffer (state,
- "pts", 1 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 1 * GST_SECOND, NULL);
set_state (state, GST_STATE_NULL);
validate_buffers_received (2);
- validate_buffer (0,
- "pts", 0 * GST_SECOND,
- NULL);
- get_buffer_field (0,
- "rtptime", &rtptime,
- "seq", &seq,
- NULL);
+ validate_buffer (0, "pts", 0 * GST_SECOND, NULL);
+ get_buffer_field (0, "rtptime", &rtptime, "seq", &seq, NULL);
validate_buffer (1,
"pts", 1 * GST_SECOND,
- "rtptime", rtptime + 1 * DEFAULT_CLOCK_RATE,
- "seq", seq + 1,
- NULL);
+ "rtptime", rtptime + 1 * DEFAULT_CLOCK_RATE, "seq", seq + 1, NULL);
validate_events_received (3);
set_state (state, GST_STATE_PLAYING);
for (i = 0; i < BUFFER_BEFORE_LIST + 1; i++) {
- push_buffer_list (state,
- "pts", i * GST_SECOND,
- NULL);
+ push_buffer_list (state, "pts", i * GST_SECOND, NULL);
}
set_state (state, GST_STATE_NULL);
validate_buffers_received (11);
- validate_buffer (0,
- "pts", 0 * GST_SECOND,
- NULL);
- get_buffer_field (0,
- "rtptime", &rtptime,
- "seq", &seq,
- NULL);
+ validate_buffer (0, "pts", 0 * GST_SECOND, NULL);
+ get_buffer_field (0, "rtptime", &rtptime, "seq", &seq, NULL);
for (i = 1; i < BUFFER_BEFORE_LIST + 1; i++) {
validate_buffer (i,
"pts", i * GST_SECOND,
- "rtptime", rtptime + i * DEFAULT_CLOCK_RATE,
- "seq", seq + i,
- NULL);
+ "rtptime", rtptime + i * DEFAULT_CLOCK_RATE, "seq", seq + i, NULL);
}
validate_events_received (3);
State *state;
state = create_payloader ("application/x-rtp", &sinktmpl,
- "perfect-rtptime", FALSE,
- NULL);
+ "perfect-rtptime", FALSE, NULL);
set_state (state, GST_STATE_PLAYING);
push_buffer (state,
- "pts", 0 * GST_SECOND,
- "offset", GST_BUFFER_OFFSET_NONE,
- NULL);
+ "pts", 0 * GST_SECOND, "offset", GST_BUFFER_OFFSET_NONE, NULL);
push_buffer (state,
- "pts", 1 * GST_SECOND,
- "offset", GST_BUFFER_OFFSET_NONE,
- NULL);
+ "pts", 1 * GST_SECOND, "offset", GST_BUFFER_OFFSET_NONE, NULL);
set_state (state, GST_STATE_NULL);
validate_buffers_received (2);
validate_buffer (0,
- "pts", 0 * GST_SECOND,
- "offset", GST_BUFFER_OFFSET_NONE,
- NULL);
- get_buffer_field (0,
- "rtptime", &rtptime,
- NULL);
+ "pts", 0 * GST_SECOND, "offset", GST_BUFFER_OFFSET_NONE, NULL);
+ get_buffer_field (0, "rtptime", &rtptime, NULL);
validate_buffer (1,
"pts", 1 * GST_SECOND,
"offset", GST_BUFFER_OFFSET_NONE,
- "rtptime", rtptime + DEFAULT_CLOCK_RATE,
- NULL);
+ "rtptime", rtptime + DEFAULT_CLOCK_RATE, NULL);
validate_events_received (3);
State *state;
state = create_payloader ("application/x-rtp", &sinktmpl,
- "perfect-rtptime", TRUE,
- NULL);
+ "perfect-rtptime", TRUE, NULL);
set_state (state, GST_STATE_PLAYING);
- push_buffer (state,
- "pts", 0 * GST_SECOND,
- "offset", 0,
- NULL);
+ push_buffer (state, "pts", 0 * GST_SECOND, "offset", 0, NULL);
- push_buffer (state,
- "pts", GST_CLOCK_TIME_NONE,
- "offset", 21,
- NULL);
+ push_buffer (state, "pts", GST_CLOCK_TIME_NONE, "offset", 21, NULL);
set_state (state, GST_STATE_NULL);
validate_buffers_received (2);
- validate_buffer (0,
- "pts", 0 * GST_SECOND,
- "offset", 0,
- NULL);
- get_buffer_field (0,
- "rtptime", &rtptime,
- NULL);
+ validate_buffer (0, "pts", 0 * GST_SECOND, "offset", 0, NULL);
+ get_buffer_field (0, "rtptime", &rtptime, NULL);
validate_buffer (1,
- "pts", GST_CLOCK_TIME_NONE,
- "offset", 21,
- "rtptime", rtptime + 21,
- NULL);
+ "pts", GST_CLOCK_TIME_NONE, "offset", 21, "rtptime", rtptime + 21, NULL);
validate_events_received (3);
State *state;
state = create_payloader ("application/x-rtp", &sinktmpl,
- "timestamp-offset", 0x42,
- NULL);
+ "timestamp-offset", 0x42, NULL);
set_state (state, GST_STATE_PLAYING);
push_buffer (state,
- "pts", 0 * GST_SECOND,
- "offset", GST_BUFFER_OFFSET_NONE,
- NULL);
+ "pts", 0 * GST_SECOND, "offset", GST_BUFFER_OFFSET_NONE, NULL);
push_buffer (state,
- "pts", 1 * GST_SECOND,
- "offset", GST_BUFFER_OFFSET_NONE,
- NULL);
+ "pts", 1 * GST_SECOND, "offset", GST_BUFFER_OFFSET_NONE, NULL);
push_buffer (state,
- "pts", GST_CLOCK_TIME_NONE,
- "offset", GST_BUFFER_OFFSET_NONE,
- NULL);
+ "pts", GST_CLOCK_TIME_NONE, "offset", GST_BUFFER_OFFSET_NONE, NULL);
set_state (state, GST_STATE_NULL);
validate_buffer (0,
"pts", 0 * GST_SECOND,
- "offset", GST_BUFFER_OFFSET_NONE,
- "rtptime", 0x42,
- NULL);
+ "offset", GST_BUFFER_OFFSET_NONE, "rtptime", 0x42, NULL);
validate_buffer (1,
"pts", 1 * GST_SECOND,
"offset", GST_BUFFER_OFFSET_NONE,
- "rtptime", 0x42 + 1 * DEFAULT_CLOCK_RATE,
- NULL);
+ "rtptime", 0x42 + 1 * DEFAULT_CLOCK_RATE, NULL);
validate_buffer (2,
"pts", GST_CLOCK_TIME_NONE,
"offset", GST_BUFFER_OFFSET_NONE,
- "rtptime", 0x42 + 1 * DEFAULT_CLOCK_RATE,
- NULL);
+ "rtptime", 0x42 + 1 * DEFAULT_CLOCK_RATE, NULL);
validate_events_received (3);
set_state (state, GST_STATE_PLAYING);
- push_buffer (state,
- "pts", 0 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 0 * GST_SECOND, NULL);
set_state (state, GST_STATE_NULL);
validate_buffer (0,
"pts", 0 * GST_SECOND,
- "seq", 2424,
- "payload-type", 98,
- "ssrc", 24,
- "rtptime", 212,
- NULL);
+ "seq", 2424, "payload-type", 98, "ssrc", 24, "rtptime", 212, NULL);
validate_events_received (3);
State *state;
guint32 ssrc;
- state = create_payloader ("application/x-rtp", &sinktmpl,
- NULL);
+ state = create_payloader ("application/x-rtp", &sinktmpl, NULL);
g_object_set (state->element, "ssrc", 0x4242, NULL);
g_object_get (state->element, "ssrc", &ssrc, NULL);
set_state (state, GST_STATE_PLAYING);
- push_buffer (state,
- "pts", 0 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 0 * GST_SECOND, NULL);
ssrc_collision (state, 0x4242, TRUE, 0x4343);
- push_buffer (state,
- "pts", 1 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 1 * GST_SECOND, NULL);
ssrc_collision (state, 0x4343, FALSE, 0);
- push_buffer (state,
- "pts", 2 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 2 * GST_SECOND, NULL);
set_state (state, GST_STATE_NULL);
validate_buffers_received (3);
- validate_buffer (0,
- "pts", 0 * GST_SECOND,
- "ssrc", 0x4242,
- NULL);
+ validate_buffer (0, "pts", 0 * GST_SECOND, "ssrc", 0x4242, NULL);
- validate_buffer (1,
- "pts", 1 * GST_SECOND,
- "ssrc", 0x4343,
- NULL);
+ validate_buffer (1, "pts", 1 * GST_SECOND, "ssrc", 0x4343, NULL);
- validate_buffer (2,
- "pts", 2 * GST_SECOND,
- NULL);
- get_buffer_field (2,
- "ssrc", &ssrc,
- NULL);
+ validate_buffer (2, "pts", 2 * GST_SECOND, NULL);
+ get_buffer_field (2, "ssrc", &ssrc, NULL);
fail_if (ssrc == 0x4343);
validate_events_received (5);
validate_normal_start_events (0);
validate_event (3, "caps",
- "media-type", "application/x-rtp",
- "ssrc", 0x4343,
- NULL);
+ "media-type", "application/x-rtp", "ssrc", 0x4343, NULL);
validate_event (4, "caps",
- "media-type", "application/x-rtp",
- "ssrc", ssrc,
- NULL);
+ "media-type", "application/x-rtp", "ssrc", ssrc, NULL);
destroy_payloader (state);
}
set_state (state, GST_STATE_PLAYING);
- push_buffer (state,
- "pts", 0 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 0 * GST_SECOND, NULL);
reconfigure (state);
- push_buffer (state,
- "pts", 1 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 1 * GST_SECOND, NULL);
set_state (state, GST_STATE_NULL);
validate_buffers_received (2);
- validate_buffer (0,
- "pts", 0 * GST_SECOND,
- NULL);
+ validate_buffer (0, "pts", 0 * GST_SECOND, NULL);
- validate_buffer (1,
- "pts", 1 * GST_SECOND,
- NULL);
+ validate_buffer (1, "pts", 1 * GST_SECOND, NULL);
validate_events_received (3);
set_state (state, GST_STATE_PLAYING);
g_object_get (state->element, "pt", &payload_type, NULL);
- push_buffer (state,
- "pts", 0 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 0 * GST_SECOND, NULL);
g_object_set (state->element, "pt", payload_type + 1, NULL);
g_object_get (state->element, "pt", &check, NULL);
fail_unless_equals_int (check, payload_type + 1);
- push_buffer (state,
- "pts", 1 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 1 * GST_SECOND, NULL);
g_object_set (state->element, "pt", 0, NULL);
g_object_get (state->element, "pt", &check, NULL);
fail_unless_equals_int (check, 0);
- push_buffer (state,
- "pts", 2 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 2 * GST_SECOND, NULL);
g_object_set (state->element, "pt", 0x7f, NULL);
g_object_get (state->element, "pt", &check, NULL);
fail_unless_equals_int (check, 0x7f);
- push_buffer (state,
- "pts", 3 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 3 * GST_SECOND, NULL);
set_state (state, GST_STATE_NULL);
validate_buffers_received (4);
validate_buffer (0,
- "pts", 0 * GST_SECOND,
- "payload-type", payload_type,
- NULL);
+ "pts", 0 * GST_SECOND, "payload-type", payload_type, NULL);
validate_buffer (1,
- "pts", 1 * GST_SECOND,
- "payload-type", payload_type + 1,
- NULL);
+ "pts", 1 * GST_SECOND, "payload-type", payload_type + 1, NULL);
- validate_buffer (2,
- "pts", 2 * GST_SECOND,
- "payload-type", 0,
- NULL);
+ validate_buffer (2, "pts", 2 * GST_SECOND, "payload-type", 0, NULL);
- validate_buffer (3,
- "pts", 3 * GST_SECOND,
- "payload-type", 0x7f,
- NULL);
+ validate_buffer (3, "pts", 3 * GST_SECOND, "payload-type", 0x7f, NULL);
validate_events_received (3);
g_object_get (state->element, "ssrc", &ssrc, NULL);
fail_unless_equals_int (ssrc, -1);
- push_buffer (state,
- "pts", 0 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 0 * GST_SECOND, NULL);
- push_buffer (state,
- "pts", 1 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 1 * GST_SECOND, NULL);
set_state (state, GST_STATE_NULL);
g_object_set (state->element, "ssrc", 0x4242, NULL);
fail_unless_equals_int (ssrc, 0x4242);
set_state (state, GST_STATE_PLAYING);
- push_buffer (state,
- "pts", 2 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 2 * GST_SECOND, NULL);
set_state (state, GST_STATE_NULL);
g_object_set (state->element, "ssrc", 0, NULL);
fail_unless_equals_int (ssrc, 0);
set_state (state, GST_STATE_PLAYING);
- push_buffer (state,
- "pts", 3 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 3 * GST_SECOND, NULL);
set_state (state, GST_STATE_NULL);
g_object_set (state->element, "ssrc", G_MAXUINT32, NULL);
fail_unless_equals_int (ssrc, G_MAXUINT32);
set_state (state, GST_STATE_PLAYING);
- push_buffer (state,
- "pts", 4 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 4 * GST_SECOND, NULL);
set_state (state, GST_STATE_NULL);
validate_buffers_received (5);
- validate_buffer (0,
- "pts", 0 * GST_SECOND,
- NULL);
- get_buffer_field (0,
- "ssrc", &ssrc,
- NULL);
+ validate_buffer (0, "pts", 0 * GST_SECOND, NULL);
+ get_buffer_field (0, "ssrc", &ssrc, NULL);
- validate_buffer (1,
- "pts", 1 * GST_SECOND,
- "ssrc", ssrc,
- NULL);
+ validate_buffer (1, "pts", 1 * GST_SECOND, "ssrc", ssrc, NULL);
- validate_buffer (2,
- "pts", 2 * GST_SECOND,
- "ssrc", 0x4242,
- NULL);
+ validate_buffer (2, "pts", 2 * GST_SECOND, "ssrc", 0x4242, NULL);
- validate_buffer (3,
- "pts", 3 * GST_SECOND,
- "ssrc", 0,
- NULL);
+ validate_buffer (3, "pts", 3 * GST_SECOND, "ssrc", 0, NULL);
- validate_buffer (4,
- "pts", 4 * GST_SECOND,
- "ssrc", G_MAXUINT32,
- NULL);
+ validate_buffer (4, "pts", 4 * GST_SECOND, "ssrc", G_MAXUINT32, NULL);
validate_events_received (12);
g_object_get (state->element, "timestamp-offset", &offset, NULL);
fail_unless_equals_int (offset, -1);
- push_buffer (state,
- "pts", 0 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 0 * GST_SECOND, NULL);
g_object_set (state->element, "timestamp-offset", 0x42, NULL);
g_object_get (state->element, "timestamp-offset", &offset, NULL);
fail_unless_equals_int (offset, 0x42);
- push_buffer (state,
- "pts", 1 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 1 * GST_SECOND, NULL);
set_state (state, GST_STATE_NULL);
g_object_set (state->element, "timestamp-offset", 0x4242, NULL);
fail_unless_equals_int (offset, 0x4242);
set_state (state, GST_STATE_PLAYING);
- push_buffer (state,
- "pts", 2 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 2 * GST_SECOND, NULL);
- push_buffer (state,
- "pts", 3 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 3 * GST_SECOND, NULL);
set_state (state, GST_STATE_NULL);
g_object_set (state->element, "timestamp-offset", 0, NULL);
set_state (state, GST_STATE_PLAYING);
- push_buffer (state,
- "pts", 4 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 4 * GST_SECOND, NULL);
- push_buffer (state,
- "pts", 5 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 5 * GST_SECOND, NULL);
set_state (state, GST_STATE_NULL);
g_object_set (state->element, "timestamp-offset", G_MAXUINT32, NULL);
set_state (state, GST_STATE_PLAYING);
- push_buffer (state,
- "pts", 6 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 6 * GST_SECOND, NULL);
- push_buffer (state,
- "pts", 7 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 7 * GST_SECOND, NULL);
set_state (state, GST_STATE_NULL);
validate_buffers_received (8);
- validate_buffer (0,
- "pts", 0 * GST_SECOND,
- NULL);
- get_buffer_field (0,
- "rtptime", &rtptime,
- NULL);
+ validate_buffer (0, "pts", 0 * GST_SECOND, NULL);
+ get_buffer_field (0, "rtptime", &rtptime, NULL);
validate_buffer (1,
- "pts", 1 * GST_SECOND,
- "rtptime", rtptime + 1 * DEFAULT_CLOCK_RATE,
- NULL);
+ "pts", 1 * GST_SECOND, "rtptime", rtptime + 1 * DEFAULT_CLOCK_RATE, NULL);
validate_buffer (2,
- "pts", 2 * GST_SECOND,
- "rtptime", 0x4242 + 2 * DEFAULT_CLOCK_RATE,
- NULL);
+ "pts", 2 * GST_SECOND, "rtptime", 0x4242 + 2 * DEFAULT_CLOCK_RATE, NULL);
validate_buffer (3,
- "pts", 3 * GST_SECOND,
- "rtptime", 0x4242 + 3 * DEFAULT_CLOCK_RATE,
- NULL);
+ "pts", 3 * GST_SECOND, "rtptime", 0x4242 + 3 * DEFAULT_CLOCK_RATE, NULL);
validate_buffer (4,
- "pts", 4 * GST_SECOND,
- "rtptime", 0 + 4 * DEFAULT_CLOCK_RATE,
- NULL);
+ "pts", 4 * GST_SECOND, "rtptime", 0 + 4 * DEFAULT_CLOCK_RATE, NULL);
validate_buffer (5,
- "pts", 5 * GST_SECOND,
- "rtptime", 0 + 5 * DEFAULT_CLOCK_RATE,
- NULL);
+ "pts", 5 * GST_SECOND, "rtptime", 0 + 5 * DEFAULT_CLOCK_RATE, NULL);
validate_buffer (6,
"pts", 6 * GST_SECOND,
- "rtptime", G_MAXUINT32 + 6 * DEFAULT_CLOCK_RATE,
- NULL);
+ "rtptime", G_MAXUINT32 + 6 * DEFAULT_CLOCK_RATE, NULL);
validate_buffer (7,
- "pts", 7 * GST_SECOND,
- "rtptime", 7 * DEFAULT_CLOCK_RATE - 1,
- NULL);
+ "pts", 7 * GST_SECOND, "rtptime", 7 * DEFAULT_CLOCK_RATE - 1, NULL);
validate_events_received (12);
g_object_get (state->element, "seqnum-offset", &offset, NULL);
fail_unless_equals_int (offset, -1);
- push_buffer (state,
- "pts", 0 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 0 * GST_SECOND, NULL);
g_object_set (state->element, "seqnum-offset", 0x42, NULL);
g_object_get (state->element, "seqnum-offset", &offset, NULL);
fail_unless_equals_int (offset, 0x42);
- push_buffer (state,
- "pts", 1 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 1 * GST_SECOND, NULL);
set_state (state, GST_STATE_NULL);
g_object_set (state->element, "seqnum-offset", 0x4242, NULL);
fail_unless_equals_int (offset, 0x4242);
set_state (state, GST_STATE_PLAYING);
- push_buffer (state,
- "pts", 2 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 2 * GST_SECOND, NULL);
- push_buffer (state,
- "pts", 3 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 3 * GST_SECOND, NULL);
set_state (state, GST_STATE_NULL);
g_object_set (state->element, "seqnum-offset", -1, NULL);
set_state (state, GST_STATE_PLAYING);
- push_buffer (state,
- "pts", 4 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 4 * GST_SECOND, NULL);
- push_buffer (state,
- "pts", 5 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 5 * GST_SECOND, NULL);
set_state (state, GST_STATE_NULL);
g_object_set (state->element, "seqnum-offset", G_MAXUINT16, NULL);
set_state (state, GST_STATE_PLAYING);
- push_buffer (state,
- "pts", 6 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 6 * GST_SECOND, NULL);
- push_buffer (state,
- "pts", 7 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 7 * GST_SECOND, NULL);
set_state (state, GST_STATE_NULL);
validate_buffers_received (8);
- validate_buffer (0,
- "pts", 0 * GST_SECOND,
- NULL);
- get_buffer_field (0,
- "seq", &seq,
- NULL);
+ validate_buffer (0, "pts", 0 * GST_SECOND, NULL);
+ get_buffer_field (0, "seq", &seq, NULL);
- validate_buffer (1,
- "pts", 1 * GST_SECOND,
- "seq", seq + 1,
- NULL);
+ validate_buffer (1, "pts", 1 * GST_SECOND, "seq", seq + 1, NULL);
- validate_buffer (2,
- "pts", 2 * GST_SECOND,
- "seq", 0x4242,
- NULL);
+ validate_buffer (2, "pts", 2 * GST_SECOND, "seq", 0x4242, NULL);
- validate_buffer (3,
- "pts", 3 * GST_SECOND,
- "seq", 0x4242 + 1,
- NULL);
+ validate_buffer (3, "pts", 3 * GST_SECOND, "seq", 0x4242 + 1, NULL);
- validate_buffer (4,
- "pts", 4 * GST_SECOND,
- NULL);
- get_buffer_field (4,
- "seq", &seq,
- NULL);
+ validate_buffer (4, "pts", 4 * GST_SECOND, NULL);
+ get_buffer_field (4, "seq", &seq, NULL);
- validate_buffer (5,
- "pts", 5 * GST_SECOND,
- "seq", seq + 1,
- NULL);
+ validate_buffer (5, "pts", 5 * GST_SECOND, "seq", seq + 1, NULL);
- validate_buffer (6,
- "pts", 6 * GST_SECOND,
- "seq", G_MAXUINT16,
- NULL);
+ validate_buffer (6, "pts", 6 * GST_SECOND, "seq", G_MAXUINT16, NULL);
- validate_buffer (7,
- "pts", 7 * GST_SECOND,
- "seq", 0,
- NULL);
+ validate_buffer (7, "pts", 7 * GST_SECOND, "seq", 0, NULL);
validate_events_received (12);
guint32 timestamp;
state = create_payloader ("application/x-rtp", &sinktmpl,
- "timestamp-offset", 0,
- NULL);
+ "timestamp-offset", 0, NULL);
set_state (state, GST_STATE_PLAYING);
- push_buffer (state,
- "pts", 0 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 0 * GST_SECOND, NULL);
g_object_get (state->element, "timestamp", ×tamp, NULL);
fail_unless_equals_int (timestamp, 0);
- push_buffer (state,
- "pts", 1 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 1 * GST_SECOND, NULL);
g_object_get (state->element, "timestamp", ×tamp, NULL);
fail_unless_equals_int (timestamp, DEFAULT_CLOCK_RATE);
validate_buffers_received (2);
- validate_buffer (0,
- "pts", 0 * GST_SECOND,
- "rtptime", 0,
- NULL);
+ validate_buffer (0, "pts", 0 * GST_SECOND, "rtptime", 0, NULL);
validate_buffer (1,
- "pts", 1 * GST_SECOND,
- "rtptime", DEFAULT_CLOCK_RATE,
- NULL);
+ "pts", 1 * GST_SECOND, "rtptime", DEFAULT_CLOCK_RATE, NULL);
validate_events_received (3);
set_state (state, GST_STATE_PLAYING);
- push_buffer (state,
- "pts", 0 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 0 * GST_SECOND, NULL);
g_object_get (state->element, "seqnum", &seq, NULL);
fail_unless_equals_int (seq, 0);
- push_buffer (state,
- "pts", 1 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 1 * GST_SECOND, NULL);
g_object_get (state->element, "seqnum", &seq, NULL);
fail_unless_equals_int (seq, 1);
validate_buffers_received (2);
- validate_buffer (0,
- "pts", 0 * GST_SECOND,
- "seq", 0,
- NULL);
+ validate_buffer (0, "pts", 0 * GST_SECOND, "seq", 0, NULL);
- validate_buffer (1,
- "pts", 1 * GST_SECOND,
- "seq", 1,
- NULL);
+ validate_buffer (1, "pts", 1 * GST_SECOND, "seq", 1, NULL);
validate_events_received (3);
gboolean perfect;
state = create_payloader ("application/x-rtp", &sinktmpl,
- "timestamp-offset", timestamp_base,
- NULL);
+ "timestamp-offset", timestamp_base, NULL);
set_state (state, GST_STATE_PLAYING);
g_object_get (state->element, "perfect-rtptime", &perfect, NULL);
fail_unless (!perfect);
- push_buffer (state,
- "pts", 0 * GST_SECOND,
- "offset", 0,
- NULL);
+ push_buffer (state, "pts", 0 * GST_SECOND, "offset", 0, NULL);
- push_buffer (state,
- "pts", 1 * GST_SECOND,
- "offset", 17,
- NULL);
+ push_buffer (state, "pts", 1 * GST_SECOND, "offset", 17, NULL);
g_object_set (state->element, "perfect-rtptime", TRUE, NULL);
g_object_get (state->element, "perfect-rtptime", &perfect, NULL);
fail_unless (perfect);
- push_buffer (state,
- "pts", 2 * GST_SECOND,
- "offset", 31,
- NULL);
+ push_buffer (state, "pts", 2 * GST_SECOND, "offset", 31, NULL);
- push_buffer (state,
- "pts", 3 * GST_SECOND,
- "offset", 67,
- NULL);
+ push_buffer (state, "pts", 3 * GST_SECOND, "offset", 67, NULL);
set_state (state, GST_STATE_NULL);
validate_buffers_received (4);
validate_buffer (0,
- "pts", 0 * GST_SECOND,
- "offset", 0,
- "rtptime", timestamp_base,
- NULL);
+ "pts", 0 * GST_SECOND, "offset", 0, "rtptime", timestamp_base, NULL);
validate_buffer (1,
"pts", 1 * GST_SECOND,
- "offset", 17,
- "rtptime", timestamp_base + 1 * DEFAULT_CLOCK_RATE,
- NULL);
+ "offset", 17, "rtptime", timestamp_base + 1 * DEFAULT_CLOCK_RATE, NULL);
validate_buffer (2,
"pts", 2 * GST_SECOND,
"offset", 31,
- "rtptime", timestamp_base + 1 * DEFAULT_CLOCK_RATE + (31 - 17),
- NULL);
+ "rtptime", timestamp_base + 1 * DEFAULT_CLOCK_RATE + (31 - 17), NULL);
validate_buffer (3,
"pts", 3 * GST_SECOND,
"offset", 67,
- "rtptime", timestamp_base + 1 * DEFAULT_CLOCK_RATE + (67 - 17),
- NULL);
+ "rtptime", timestamp_base + 1 * DEFAULT_CLOCK_RATE + (67 - 17), NULL);
validate_events_received (3);
State *state;
state = create_payloader ("application/x-rtp", &sinktmpl,
- "perfect-rtptime", TRUE,
- "seqnum-offset", 0,
- "timestamp-offset", 0,
- NULL);
+ "perfect-rtptime", TRUE, "seqnum-offset", 0, "timestamp-offset", 0, NULL);
set_state (state, GST_STATE_PLAYING);
- push_buffer (state,
- "pts", 0 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 0 * GST_SECOND, NULL);
validate_stats (state,
- DEFAULT_CLOCK_RATE,
- 0 * GST_SECOND,
- 0,
- 0 * DEFAULT_CLOCK_RATE);
+ DEFAULT_CLOCK_RATE, 0 * GST_SECOND, 0, 0 * DEFAULT_CLOCK_RATE);
- push_buffer (state,
- "pts", 1 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 1 * GST_SECOND, NULL);
validate_stats (state,
- DEFAULT_CLOCK_RATE,
- 1 * DEFAULT_CLOCK_RATE,
- 1,
- 1 * DEFAULT_CLOCK_RATE);
+ DEFAULT_CLOCK_RATE, 1 * DEFAULT_CLOCK_RATE, 1, 1 * DEFAULT_CLOCK_RATE);
set_state (state, GST_STATE_NULL);
g_object_set (state->element, "perfect-rtptime", FALSE, NULL);
set_state (state, GST_STATE_PLAYING);
- push_buffer (state,
- "pts", 2 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 2 * GST_SECOND, NULL);
validate_stats (state,
- DEFAULT_CLOCK_RATE,
- 2 * GST_SECOND,
- 0,
- 2 * DEFAULT_CLOCK_RATE);
+ DEFAULT_CLOCK_RATE, 2 * GST_SECOND, 0, 2 * DEFAULT_CLOCK_RATE);
- push_buffer (state,
- "pts", 3 * GST_SECOND,
- NULL);
+ push_buffer (state, "pts", 3 * GST_SECOND, NULL);
validate_stats (state,
- DEFAULT_CLOCK_RATE,
- 3 * GST_SECOND,
- 1,
- 3 * DEFAULT_CLOCK_RATE);
+ DEFAULT_CLOCK_RATE, 3 * GST_SECOND, 1, 3 * DEFAULT_CLOCK_RATE);
set_state (state, GST_STATE_NULL);
validate_buffers_received (4);
- validate_buffer (0,
- "pts", 0 * GST_SECOND,
- NULL);
+ validate_buffer (0, "pts", 0 * GST_SECOND, NULL);
- validate_buffer (1,
- "pts", 1 * GST_SECOND,
- NULL);
+ validate_buffer (1, "pts", 1 * GST_SECOND, NULL);
- validate_buffer (2,
- "pts", 2 * GST_SECOND,
- NULL);
+ validate_buffer (2, "pts", 2 * GST_SECOND, NULL);
- validate_buffer (3,
- "pts", 3 * GST_SECOND,
- NULL);
+ validate_buffer (3, "pts", 3 * GST_SECOND, NULL);
validate_events_received (6);