gstreamer/subprojects/gst-plugins-bad/tests/check/elements/avtpcrfbase.c

748 lines
23 KiB
C

/*
* GStreamer AVTP Plugin
* Copyright (C) 2019 Intel Corporation
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2.1 of the License, or (at your option) any later
* version.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the
* Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
* Boston, MA 02110-1301 USA
*/
#include "../../../ext/avtp/gstavtpcrfbase.c"
#undef GST_CAT_DEFAULT
#include <glib.h>
#include <avtp_crf.h>
#include <gst/check/gstcheck.h>
#include <gst/check/gstharness.h>
static struct avtp_crf_pdu *
generate_crf_pdu (int data_len, guint64 first_tstamp)
{
struct avtp_crf_pdu *crf_pdu =
g_malloc0 (sizeof (struct avtp_crf_pdu) + data_len);
avtp_crf_pdu_init (crf_pdu);
avtp_crf_pdu_set (crf_pdu, AVTP_CRF_FIELD_SV, 1);
avtp_crf_pdu_set (crf_pdu, AVTP_CRF_FIELD_STREAM_ID, 0xABCD1234ABCD1234);
avtp_crf_pdu_set (crf_pdu, AVTP_CRF_FIELD_TYPE, AVTP_CRF_TYPE_AUDIO_SAMPLE);
avtp_crf_pdu_set (crf_pdu, AVTP_CRF_FIELD_BASE_FREQ, 48000);
avtp_crf_pdu_set (crf_pdu, AVTP_CRF_FIELD_PULL, 1);
avtp_crf_pdu_set (crf_pdu, AVTP_CRF_FIELD_CRF_DATA_LEN, data_len);
avtp_crf_pdu_set (crf_pdu, AVTP_CRF_FIELD_TIMESTAMP_INTERVAL, 160);
for (int i = 0; i < data_len / 8; i++)
crf_pdu->crf_data[i] = htobe64 (first_tstamp + i * 3333333);
return crf_pdu;
}
GST_START_TEST (test_validate_crf_pdu_success)
{
GstAvtpCrfBase *avtpcrfbase = g_object_new (GST_TYPE_AVTP_CRF_BASE, NULL);
struct avtp_crf_pdu *crf_pdu = generate_crf_pdu (64, 1000);
GstAvtpCrfThreadData *thread_data = &avtpcrfbase->thread_data;
gboolean ret;
avtpcrfbase->streamid = 0xABCD1234ABCD1234;
ret =
validate_crf_pdu (avtpcrfbase, crf_pdu,
sizeof (struct avtp_crf_pdu) + 64);
fail_unless (ret == TRUE);
/* Validate thread_data fields. */
fail_unless (thread_data->base_freq == 48000);
fail_unless (thread_data->pull == 1);
fail_unless (thread_data->type == AVTP_CRF_TYPE_AUDIO_SAMPLE);
fail_unless (thread_data->mr == 0);
fail_unless (thread_data->timestamp_interval == 160);
g_free (crf_pdu);
gst_object_unref (avtpcrfbase);
}
GST_END_TEST;
GST_START_TEST (test_validate_crf_pdu_multiple_packets_success)
{
GstAvtpCrfBase *avtpcrfbase = g_object_new (GST_TYPE_AVTP_CRF_BASE, NULL);
struct avtp_crf_pdu *crf_pdu1 = generate_crf_pdu (64, 1000);
struct avtp_crf_pdu *crf_pdu2 = generate_crf_pdu (64, 1800);
GstAvtpCrfThreadData *thread_data = &avtpcrfbase->thread_data;
gboolean ret;
avtpcrfbase->streamid = 0xABCD1234ABCD1234;
ret =
validate_crf_pdu (avtpcrfbase, crf_pdu1,
sizeof (struct avtp_crf_pdu) + 64);
fail_unless (ret == TRUE);
/* Validate thread_data fields. */
fail_unless (thread_data->base_freq == 48000);
fail_unless (thread_data->pull == 1);
fail_unless (thread_data->type == AVTP_CRF_TYPE_AUDIO_SAMPLE);
fail_unless (thread_data->mr == 0);
fail_unless (thread_data->timestamp_interval == 160);
ret =
validate_crf_pdu (avtpcrfbase, crf_pdu2,
sizeof (struct avtp_crf_pdu) + 64);
fail_unless (ret == TRUE);
g_free (crf_pdu1);
g_free (crf_pdu2);
gst_object_unref (avtpcrfbase);
}
GST_END_TEST;
GST_START_TEST (test_validate_crf_pdu_wrong_subtype)
{
GstAvtpCrfBase *avtpcrfbase = g_object_new (GST_TYPE_AVTP_CRF_BASE, NULL);
struct avtp_crf_pdu *crf_pdu = generate_crf_pdu (64, 1000);
gboolean ret;
avtpcrfbase->streamid = 0xABCD1234ABCD1234;
avtp_pdu_set ((struct avtp_common_pdu *) crf_pdu, AVTP_FIELD_SUBTYPE,
AVTP_SUBTYPE_CVF);
ret =
validate_crf_pdu (avtpcrfbase, crf_pdu,
sizeof (struct avtp_crf_pdu) + 64);
fail_unless (ret == FALSE);
g_free (crf_pdu);
gst_object_unref (avtpcrfbase);
}
GST_END_TEST;
GST_START_TEST (test_validate_crf_pdu_streamid_invalid)
{
GstAvtpCrfBase *avtpcrfbase = g_object_new (GST_TYPE_AVTP_CRF_BASE, NULL);
struct avtp_crf_pdu *crf_pdu = generate_crf_pdu (64, 1000);
gboolean ret;
avtpcrfbase->streamid = 0xABCD1234ABCD1234;
avtp_crf_pdu_set (crf_pdu, AVTP_CRF_FIELD_SV, 0);
ret =
validate_crf_pdu (avtpcrfbase, crf_pdu,
sizeof (struct avtp_crf_pdu) + 64);
fail_unless (ret == FALSE);
g_free (crf_pdu);
gst_object_unref (avtpcrfbase);
}
GST_END_TEST;
GST_START_TEST (test_validate_crf_pdu_streamid_different)
{
GstAvtpCrfBase *avtpcrfbase = g_object_new (GST_TYPE_AVTP_CRF_BASE, NULL);
struct avtp_crf_pdu *crf_pdu = generate_crf_pdu (64, 1000);
gboolean ret;
avtpcrfbase->streamid = 0xABCD1234ABCDABCD;
ret =
validate_crf_pdu (avtpcrfbase, crf_pdu,
sizeof (struct avtp_crf_pdu) + 64);
fail_unless (ret == FALSE);
g_free (crf_pdu);
gst_object_unref (avtpcrfbase);
}
GST_END_TEST;
GST_START_TEST (test_validate_crf_pdu_data_len_too_long)
{
GstAvtpCrfBase *avtpcrfbase = g_object_new (GST_TYPE_AVTP_CRF_BASE, NULL);
struct avtp_crf_pdu *crf_pdu = generate_crf_pdu (64, 1000);
gboolean ret;
avtpcrfbase->streamid = 0xABCD1234ABCD1234;
ret =
validate_crf_pdu (avtpcrfbase, crf_pdu,
sizeof (struct avtp_crf_pdu) + 40);
fail_unless (ret == FALSE);
g_free (crf_pdu);
gst_object_unref (avtpcrfbase);
}
GST_END_TEST;
GST_START_TEST (test_validate_crf_pdu_timestamp_interval_zero)
{
GstAvtpCrfBase *avtpcrfbase = g_object_new (GST_TYPE_AVTP_CRF_BASE, NULL);
struct avtp_crf_pdu *crf_pdu = generate_crf_pdu (64, 1000);
gboolean ret;
avtpcrfbase->streamid = 0xABCD1234ABCD1234;
avtp_crf_pdu_set (crf_pdu, AVTP_CRF_FIELD_TIMESTAMP_INTERVAL, 0);
ret =
validate_crf_pdu (avtpcrfbase, crf_pdu,
sizeof (struct avtp_crf_pdu) + 64);
fail_unless (ret == FALSE);
g_free (crf_pdu);
gst_object_unref (avtpcrfbase);
}
GST_END_TEST;
GST_START_TEST (test_validate_crf_pdu_base_freq_zero)
{
GstAvtpCrfBase *avtpcrfbase = g_object_new (GST_TYPE_AVTP_CRF_BASE, NULL);
struct avtp_crf_pdu *crf_pdu = generate_crf_pdu (64, 1000);
gboolean ret;
avtpcrfbase->streamid = 0xABCD1234ABCD1234;
avtp_crf_pdu_set (crf_pdu, AVTP_CRF_FIELD_BASE_FREQ, 0);
ret =
validate_crf_pdu (avtpcrfbase, crf_pdu,
sizeof (struct avtp_crf_pdu) + 64);
fail_unless (ret == FALSE);
g_free (crf_pdu);
gst_object_unref (avtpcrfbase);
}
GST_END_TEST;
GST_START_TEST (test_validate_crf_pdu_pull_invalid)
{
GstAvtpCrfBase *avtpcrfbase = g_object_new (GST_TYPE_AVTP_CRF_BASE, NULL);
struct avtp_crf_pdu *crf_pdu = generate_crf_pdu (64, 1000);
gboolean ret;
avtpcrfbase->streamid = 0xABCD1234ABCD1234;
avtp_crf_pdu_set (crf_pdu, AVTP_CRF_FIELD_PULL, 7);
ret =
validate_crf_pdu (avtpcrfbase, crf_pdu,
sizeof (struct avtp_crf_pdu) + 64);
fail_unless (ret == FALSE);
g_free (crf_pdu);
gst_object_unref (avtpcrfbase);
}
GST_END_TEST;
GST_START_TEST (test_validate_crf_pdu_type_invalid)
{
GstAvtpCrfBase *avtpcrfbase = g_object_new (GST_TYPE_AVTP_CRF_BASE, NULL);
struct avtp_crf_pdu *crf_pdu = generate_crf_pdu (64, 1000);
gboolean ret;
avtpcrfbase->streamid = 0xABCD1234ABCD1234;
avtp_crf_pdu_set (crf_pdu, AVTP_CRF_FIELD_TYPE, 8);
ret =
validate_crf_pdu (avtpcrfbase, crf_pdu,
sizeof (struct avtp_crf_pdu) + 64);
fail_unless (ret == FALSE);
g_free (crf_pdu);
gst_object_unref (avtpcrfbase);
}
GST_END_TEST;
GST_START_TEST (test_validate_crf_pdu_data_len_invalid)
{
GstAvtpCrfBase *avtpcrfbase = g_object_new (GST_TYPE_AVTP_CRF_BASE, NULL);
struct avtp_crf_pdu *crf_pdu = generate_crf_pdu (64, 1000);
gboolean ret;
avtpcrfbase->streamid = 0xABCD1234ABCD1234;
avtp_crf_pdu_set (crf_pdu, AVTP_CRF_FIELD_CRF_DATA_LEN, 20);
ret =
validate_crf_pdu (avtpcrfbase, crf_pdu,
sizeof (struct avtp_crf_pdu) + 64);
fail_unless (ret == FALSE);
g_free (crf_pdu);
gst_object_unref (avtpcrfbase);
}
GST_END_TEST;
GST_START_TEST (test_validate_crf_pdu_timestamp_interval_mismatch)
{
GstAvtpCrfBase *avtpcrfbase = g_object_new (GST_TYPE_AVTP_CRF_BASE, NULL);
struct avtp_crf_pdu *crf_pdu = generate_crf_pdu (64, 1000);
GstAvtpCrfThreadData *thread_data = &avtpcrfbase->thread_data;
gboolean ret;
avtpcrfbase->streamid = 0xABCD1234ABCD1234;
thread_data->timestamp_interval = 120;
thread_data->base_freq = 48000;
thread_data->pull = 1;
thread_data->type = AVTP_CRF_TYPE_AUDIO_SAMPLE;
thread_data->num_pkt_tstamps = 8;
ret =
validate_crf_pdu (avtpcrfbase, crf_pdu,
sizeof (struct avtp_crf_pdu) + 64);
fail_unless (ret == FALSE);
g_free (crf_pdu);
gst_object_unref (avtpcrfbase);
}
GST_END_TEST;
GST_START_TEST (test_validate_crf_pdu_base_freq_mismatch)
{
GstAvtpCrfBase *avtpcrfbase = g_object_new (GST_TYPE_AVTP_CRF_BASE, NULL);
struct avtp_crf_pdu *crf_pdu = generate_crf_pdu (64, 1000);
GstAvtpCrfThreadData *thread_data = &avtpcrfbase->thread_data;
gboolean ret;
avtpcrfbase->streamid = 0xABCD1234ABCD1234;
thread_data->timestamp_interval = 160;
thread_data->base_freq = 44100;
thread_data->pull = 1;
thread_data->type = AVTP_CRF_TYPE_AUDIO_SAMPLE;
thread_data->num_pkt_tstamps = 8;
ret =
validate_crf_pdu (avtpcrfbase, crf_pdu,
sizeof (struct avtp_crf_pdu) + 64);
fail_unless (ret == FALSE);
g_free (crf_pdu);
gst_object_unref (avtpcrfbase);
}
GST_END_TEST;
GST_START_TEST (test_validate_crf_pdu_pull_mismatch)
{
GstAvtpCrfBase *avtpcrfbase = g_object_new (GST_TYPE_AVTP_CRF_BASE, NULL);
struct avtp_crf_pdu *crf_pdu = generate_crf_pdu (64, 1000);
GstAvtpCrfThreadData *thread_data = &avtpcrfbase->thread_data;
gboolean ret;
avtpcrfbase->streamid = 0xABCD1234ABCD1234;
thread_data->timestamp_interval = 160;
thread_data->base_freq = 48000;
thread_data->pull = 2;
thread_data->type = AVTP_CRF_TYPE_AUDIO_SAMPLE;
thread_data->num_pkt_tstamps = 8;
ret =
validate_crf_pdu (avtpcrfbase, crf_pdu,
sizeof (struct avtp_crf_pdu) + 64);
fail_unless (ret == FALSE);
g_free (crf_pdu);
gst_object_unref (avtpcrfbase);
}
GST_END_TEST;
GST_START_TEST (test_validate_crf_pdu_type_mismatch)
{
GstAvtpCrfBase *avtpcrfbase = g_object_new (GST_TYPE_AVTP_CRF_BASE, NULL);
struct avtp_crf_pdu *crf_pdu = generate_crf_pdu (64, 1000);
GstAvtpCrfThreadData *thread_data = &avtpcrfbase->thread_data;
gboolean ret;
avtpcrfbase->streamid = 0xABCD1234ABCD1234;
thread_data->timestamp_interval = 160;
thread_data->base_freq = 48000;
thread_data->pull = 1;
thread_data->type = AVTP_CRF_TYPE_VIDEO_FRAME;
thread_data->num_pkt_tstamps = 8;
ret =
validate_crf_pdu (avtpcrfbase, crf_pdu,
sizeof (struct avtp_crf_pdu) + 64);
fail_unless (ret == FALSE);
g_free (crf_pdu);
gst_object_unref (avtpcrfbase);
}
GST_END_TEST;
GST_START_TEST (test_validate_crf_pdu_data_len_mismatch)
{
int data_len = 48;
GstAvtpCrfBase *avtpcrfbase = g_object_new (GST_TYPE_AVTP_CRF_BASE, NULL);
struct avtp_crf_pdu *crf_pdu = generate_crf_pdu (data_len, 1000);
GstAvtpCrfThreadData *thread_data = &avtpcrfbase->thread_data;
gboolean ret;
avtpcrfbase->streamid = 0xABCD1234ABCD1234;
thread_data->timestamp_interval = 160;
thread_data->base_freq = 48000;
thread_data->pull = 1;
thread_data->type = AVTP_CRF_TYPE_AUDIO_SAMPLE;
thread_data->num_pkt_tstamps = 6;
avtp_crf_pdu_set (crf_pdu, AVTP_CRF_FIELD_CRF_DATA_LEN, 20);
ret =
validate_crf_pdu (avtpcrfbase, crf_pdu,
sizeof (struct avtp_crf_pdu) + data_len);
fail_unless (ret == FALSE);
g_free (crf_pdu);
gst_object_unref (avtpcrfbase);
}
GST_END_TEST;
GST_START_TEST (test_validate_crf_pdu_tstamps_not_monotonic)
{
int data_len = 48;
GstAvtpCrfBase *avtpcrfbase = g_object_new (GST_TYPE_AVTP_CRF_BASE, NULL);
struct avtp_crf_pdu *crf_pdu = generate_crf_pdu (data_len, 1000);
GstAvtpCrfThreadData *thread_data = &avtpcrfbase->thread_data;
gboolean ret;
avtpcrfbase->streamid = 0xABCD1234ABCD1234;
thread_data->timestamp_interval = 160;
thread_data->base_freq = 48000;
thread_data->pull = 1;
thread_data->type = AVTP_CRF_TYPE_AUDIO_SAMPLE;
thread_data->num_pkt_tstamps = 6;
crf_pdu->crf_data[3] = 1145;
ret =
validate_crf_pdu (avtpcrfbase, crf_pdu,
sizeof (struct avtp_crf_pdu) + data_len);
fail_unless (ret == FALSE);
g_free (crf_pdu);
gst_object_unref (avtpcrfbase);
}
GST_END_TEST;
GST_START_TEST (test_gst_base_freq_multiplier)
{
GstAvtpCrfBase *avtpcrfbase = g_object_new (GST_TYPE_AVTP_CRF_BASE, NULL);
gdouble ret;
ret = get_base_freq_multiplier (avtpcrfbase, 0);
fail_unless_equals_float (ret, 1.0);
ret = get_base_freq_multiplier (avtpcrfbase, 1);
fail_unless_equals_float (ret, 1 / 1.001);
ret = get_base_freq_multiplier (avtpcrfbase, 2);
fail_unless_equals_float (ret, 1.001);
ret = get_base_freq_multiplier (avtpcrfbase, 3);
fail_unless_equals_float (ret, 24.0 / 25);
ret = get_base_freq_multiplier (avtpcrfbase, 4);
fail_unless_equals_float (ret, 25.0 / 24);
ret = get_base_freq_multiplier (avtpcrfbase, 5);
fail_unless_equals_float (ret, 1.0 / 8);
ret = get_base_freq_multiplier (avtpcrfbase, 6);
fail_unless_equals_float (ret, -1);
gst_object_unref (avtpcrfbase);
}
GST_END_TEST;
static void
setup_thread_defaults (GstAvtpCrfBase * avtpcrfbase,
GstClockTime * past_periods)
{
GstAvtpCrfThreadData *thread_data = &avtpcrfbase->thread_data;
avtpcrfbase->streamid = 0xABCD1234ABCD1234;
thread_data->base_freq = 48000;
thread_data->pull = 1;
thread_data->type = AVTP_CRF_TYPE_AUDIO_SAMPLE;
thread_data->past_periods = past_periods;
}
/*
* Test for more than 1 timestamp per CRF AVTPDU. This is just a simple success
* case.
*/
GST_START_TEST (test_calculate_average_period_multiple_crf_tstamps)
{
int data_len = 64;
struct avtp_crf_pdu *crf_pdu = generate_crf_pdu (data_len, 1000);
GstClockTime past_periods[10] = { 21000, 20500, 0, 0, 0, 0, 0, 0, 0, 0 };
GstAvtpCrfBase *avtpcrfbase = g_object_new (GST_TYPE_AVTP_CRF_BASE, NULL);
GstAvtpCrfThreadData *thread_data = &avtpcrfbase->thread_data;
setup_thread_defaults (avtpcrfbase, past_periods);
thread_data->timestamp_interval = 160;
thread_data->num_pkt_tstamps = 6;
thread_data->past_periods_iter = 2;
thread_data->periods_stored = 2;
calculate_average_period (avtpcrfbase, crf_pdu);
fail_unless_equals_uint64 (thread_data->average_period, 20777);
fail_unless_equals_uint64 (thread_data->past_periods[2], 20833);
fail_unless_equals_uint64 (thread_data->current_ts, 1000);
gst_object_unref (avtpcrfbase);
g_free (crf_pdu);
}
GST_END_TEST;
/*
* Test for an overflow in the 64-bit CRF timestamp in the CRF AVTPDU when
* there are multiple CRF timestamps in a packet.
*/
GST_START_TEST
(test_calculate_average_period_multiple_crf_tstamps_64_bit_overflow) {
int data_len = 64;
struct avtp_crf_pdu *crf_pdu =
generate_crf_pdu (data_len, 18446744073709501615ULL);
GstClockTime past_periods[10] =
{ 21000, 20500, 21220, 21345, 20990, 21996, 20220, 20915, 21324, 23123 };
GstAvtpCrfBase *avtpcrfbase = g_object_new (GST_TYPE_AVTP_CRF_BASE, NULL);
GstAvtpCrfThreadData *thread_data = &avtpcrfbase->thread_data;
setup_thread_defaults (avtpcrfbase, past_periods);
thread_data->timestamp_interval = 160;
thread_data->num_pkt_tstamps = 6;
thread_data->past_periods_iter = 5;
thread_data->periods_stored = 10;
calculate_average_period (avtpcrfbase, crf_pdu);
fail_unless_equals_uint64 (thread_data->average_period, 21147);
fail_unless_equals_uint64 (thread_data->past_periods[5], 20833);
fail_unless_equals_uint64 (thread_data->current_ts, 18446744073709501615ULL);
g_free (crf_pdu);
gst_object_unref (avtpcrfbase);
}
GST_END_TEST;
/*
* Test case for single timestamp per CRF AVTPDU. This is just a simple success
* case.
*/
GST_START_TEST (test_calculate_average_period_single_crf_tstamp)
{
int data_len = 8;
struct avtp_crf_pdu *crf_pdu = generate_crf_pdu (data_len, 21833);
GstClockTime past_periods[10] = { 21000, 20500, 0, 0, 0, 0, 0, 0, 0, 0 };
GstAvtpCrfBase *avtpcrfbase = g_object_new (GST_TYPE_AVTP_CRF_BASE, NULL);
GstAvtpCrfThreadData *thread_data = &avtpcrfbase->thread_data;
setup_thread_defaults (avtpcrfbase, past_periods);
thread_data->timestamp_interval = 1;
thread_data->num_pkt_tstamps = 1;
thread_data->past_periods_iter = 2;
thread_data->periods_stored = 2;
thread_data->last_received_tstamp = 1000;
thread_data->last_seqnum = 9;
avtp_crf_pdu_set (crf_pdu, AVTP_CRF_FIELD_SEQ_NUM, 10);
calculate_average_period (avtpcrfbase, crf_pdu);
fail_unless_equals_uint64 (thread_data->average_period, 20777);
fail_unless_equals_uint64 (thread_data->past_periods[2], 20833);
fail_unless_equals_uint64 (thread_data->last_seqnum, 10);
fail_unless_equals_uint64 (thread_data->last_received_tstamp, 21833);
fail_unless_equals_uint64 (thread_data->current_ts, 21833);
g_free (crf_pdu);
gst_object_unref (avtpcrfbase);
}
GST_END_TEST;
/*
* Test to ensure all members of thread_data struct are initialized as expected
* when receiving multiple CRF AVTPDUs with single CRF timestamp.
*/
GST_START_TEST (test_calculate_average_period_single_crf_tstamp_init)
{
int data_len = 8;
struct avtp_crf_pdu *crf_pdu1 = generate_crf_pdu (data_len, 1000);
struct avtp_crf_pdu *crf_pdu2 = generate_crf_pdu (data_len, 21833);
GstClockTime past_periods[10] = { 0 };
GstAvtpCrfBase *avtpcrfbase = g_object_new (GST_TYPE_AVTP_CRF_BASE, NULL);
GstAvtpCrfThreadData *thread_data = &avtpcrfbase->thread_data;
setup_thread_defaults (avtpcrfbase, past_periods);
thread_data->timestamp_interval = 1;
thread_data->num_pkt_tstamps = 1;
avtp_crf_pdu_set (crf_pdu1, AVTP_CRF_FIELD_SEQ_NUM, 10);
avtp_crf_pdu_set (crf_pdu2, AVTP_CRF_FIELD_SEQ_NUM, 11);
calculate_average_period (avtpcrfbase, crf_pdu1);
fail_unless_equals_uint64 (thread_data->past_periods[0], 0);
fail_unless_equals_uint64 (thread_data->last_seqnum, 10);
fail_unless_equals_uint64 (thread_data->average_period, 20854);
fail_unless_equals_uint64 (thread_data->current_ts, 1000);
calculate_average_period (avtpcrfbase, crf_pdu2);
fail_unless_equals_uint64 (thread_data->past_periods[0], 20833);
fail_unless_equals_uint64 (thread_data->last_seqnum, 11);
fail_unless_equals_uint64 (thread_data->average_period, 20833);
fail_unless_equals_uint64 (thread_data->current_ts, 21833);
g_free (crf_pdu1);
g_free (crf_pdu2);
gst_object_unref (avtpcrfbase);
}
GST_END_TEST;
/*
* Test for an overflow in the 64-bit CRF timestamp in the CRF AVTPDU when
* there is a single CRF timestamp in a packet.
*/
GST_START_TEST (test_calculate_average_period_single_crf_tstamp_64_bit_overflow)
{
int data_len = 8;
struct avtp_crf_pdu *crf_pdu = generate_crf_pdu (data_len, 20833);
GstClockTime past_periods[10] = { 21000, 20500, 0, 0, 0, 0, 0, 0, 0, 0 };
GstAvtpCrfBase *avtpcrfbase = g_object_new (GST_TYPE_AVTP_CRF_BASE, NULL);
GstAvtpCrfThreadData *thread_data = &avtpcrfbase->thread_data;
setup_thread_defaults (avtpcrfbase, past_periods);
thread_data->timestamp_interval = 1;
thread_data->num_pkt_tstamps = 1;
thread_data->past_periods_iter = 2;
thread_data->periods_stored = 2;
thread_data->last_received_tstamp = 18446744073709551615ULL;
thread_data->last_seqnum = 9;
avtp_crf_pdu_set (crf_pdu, AVTP_CRF_FIELD_SEQ_NUM, 10);
calculate_average_period (avtpcrfbase, crf_pdu);
fail_unless_equals_uint64 (thread_data->average_period, 20778);
fail_unless_equals_uint64 (thread_data->past_periods[2], 20834);
fail_unless_equals_uint64 (thread_data->last_seqnum, 10);
fail_unless_equals_uint64 (thread_data->last_received_tstamp, 20833);
fail_unless_equals_uint64 (thread_data->current_ts, 20833);
g_free (crf_pdu);
gst_object_unref (avtpcrfbase);
}
GST_END_TEST;
/*
* Test to ensure expected behevior when a sequence number is skipped (probably
* due to packet loss or delay) in CRF AVTPDUs with single timestamp per
* AVTPDU.
*/
GST_START_TEST (test_calculate_average_period_single_crf_tstamp_seq_num_skip)
{
int data_len = 8;
struct avtp_crf_pdu *crf_pdu = generate_crf_pdu (data_len, 21833);
GstClockTime past_periods[10] = { 21000, 20500, 0, 0, 0, 0, 0, 0, 0, 0 };
GstAvtpCrfBase *avtpcrfbase = g_object_new (GST_TYPE_AVTP_CRF_BASE, NULL);
GstAvtpCrfThreadData *thread_data = &avtpcrfbase->thread_data;
setup_thread_defaults (avtpcrfbase, past_periods);
thread_data->timestamp_interval = 1;
thread_data->num_pkt_tstamps = 1;
thread_data->past_periods_iter = 2;
thread_data->last_received_tstamp = 1000;
thread_data->last_seqnum = 9;
thread_data->average_period = 20750;
avtp_crf_pdu_set (crf_pdu, AVTP_CRF_FIELD_SEQ_NUM, 12);
calculate_average_period (avtpcrfbase, crf_pdu);
fail_unless_equals_uint64 (thread_data->average_period, 20750);
fail_unless_equals_uint64 (thread_data->past_periods[2], 0);
fail_unless_equals_uint64 (thread_data->last_seqnum, 12);
fail_unless_equals_uint64 (thread_data->last_received_tstamp, 21833);
fail_unless_equals_uint64 (thread_data->current_ts, 21833);
g_free (crf_pdu);
gst_object_unref (avtpcrfbase);
}
GST_END_TEST;
static Suite *
avtpcrfbase_suite (void)
{
Suite *s = suite_create ("avtpcrfbase");
TCase *tc_chain = tcase_create ("general");
GST_DEBUG_CATEGORY_INIT (avtpcrfbase_debug, "avtpcrfbase", 0, "CRF Base");
suite_add_tcase (s, tc_chain);
tcase_add_test (tc_chain, test_validate_crf_pdu_success);
tcase_add_test (tc_chain, test_validate_crf_pdu_multiple_packets_success);
tcase_add_test (tc_chain, test_validate_crf_pdu_wrong_subtype);
tcase_add_test (tc_chain, test_validate_crf_pdu_streamid_invalid);
tcase_add_test (tc_chain, test_validate_crf_pdu_streamid_different);
tcase_add_test (tc_chain, test_validate_crf_pdu_data_len_too_long);
tcase_add_test (tc_chain, test_validate_crf_pdu_timestamp_interval_zero);
tcase_add_test (tc_chain, test_validate_crf_pdu_base_freq_zero);
tcase_add_test (tc_chain, test_validate_crf_pdu_pull_invalid);
tcase_add_test (tc_chain, test_validate_crf_pdu_type_invalid);
tcase_add_test (tc_chain, test_validate_crf_pdu_data_len_invalid);
tcase_add_test (tc_chain, test_validate_crf_pdu_timestamp_interval_mismatch);
tcase_add_test (tc_chain, test_validate_crf_pdu_base_freq_mismatch);
tcase_add_test (tc_chain, test_validate_crf_pdu_pull_mismatch);
tcase_add_test (tc_chain, test_validate_crf_pdu_type_mismatch);
tcase_add_test (tc_chain, test_validate_crf_pdu_data_len_mismatch);
tcase_add_test (tc_chain, test_validate_crf_pdu_tstamps_not_monotonic);
tcase_add_test (tc_chain, test_gst_base_freq_multiplier);
tcase_add_test (tc_chain, test_calculate_average_period_multiple_crf_tstamps);
tcase_add_test (tc_chain,
test_calculate_average_period_multiple_crf_tstamps_64_bit_overflow);
tcase_add_test (tc_chain, test_calculate_average_period_single_crf_tstamp);
tcase_add_test (tc_chain,
test_calculate_average_period_single_crf_tstamp_init);
tcase_add_test (tc_chain,
test_calculate_average_period_single_crf_tstamp_64_bit_overflow);
tcase_add_test (tc_chain,
test_calculate_average_period_single_crf_tstamp_seq_num_skip);
return s;
}
GST_CHECK_MAIN (avtpcrfbase);