Unit tests for jitterbuf.c. More...

#include "asterisk.h"
#include "asterisk/utils.h"
#include "asterisk/module.h"
#include "asterisk/test.h"
#include "jitterbuf.h"

Include dependency graph for test_jitterbuf.c:

Go to the source code of this file.

Macros
#define	DEFAULT_CODEC_INTERP_LEN 20

#define	DEFAULT_MAX_CONTIG_INTERP 10

#define	DEFAULT_MAX_JITTERBUFFER 1000

#define	DEFAULT_RESYNCH_THRESHOLD 1000

#define	DEFAULT_TARGET_EXTRA -1

#define	JB_INFO_PRINT_FRAME_DEBUG(jbinfo)

#define	JB_NUMERIC_TEST(attribute, expected)

#define	JB_TEST_BEGIN(test_name)

#define	JB_TEST_END

Functions
static void	__reg_module (void)

static void	__unreg_module (void)

struct ast_module *	AST_MODULE_SELF_SYM (void)

	AST_TEST_DEFINE (jitterbuffer_late_control)

	AST_TEST_DEFINE (jitterbuffer_late_voice)

	AST_TEST_DEFINE (jitterbuffer_lost_control)

	AST_TEST_DEFINE (jitterbuffer_lost_voice)

	AST_TEST_DEFINE (jitterbuffer_nominal_control_frames)

	AST_TEST_DEFINE (jitterbuffer_nominal_voice_frames)

	AST_TEST_DEFINE (jitterbuffer_out_of_order_control)

	AST_TEST_DEFINE (jitterbuffer_out_of_order_voice)

	AST_TEST_DEFINE (jitterbuffer_overflow_control)

	AST_TEST_DEFINE (jitterbuffer_overflow_voice)

	AST_TEST_DEFINE (jitterbuffer_resynch_control)

	AST_TEST_DEFINE (jitterbuffer_resynch_voice)

static int	load_module (void)

static void	test_jb_debug_output (const char *fmt,...)

static void	test_jb_error_output (const char *fmt,...)

static int	test_jb_late_frame_insertion (struct ast_test test, struct jitterbuf jb, enum jb_frame_type frame_type)

static int	test_jb_lost_frame_insertion (struct ast_test test, struct jitterbuf jb, enum jb_frame_type frame_type)

static int	test_jb_nominal_frame_insertion (struct ast_test test, struct jitterbuf jb, enum jb_frame_type frame_type)

static int	test_jb_out_of_order_frame_insertion (struct ast_test test, struct jitterbuf jb, enum jb_frame_type frame_type)

static void	test_jb_overflow_frame_insertion (struct jitterbuf *jb, enum jb_frame_type frame_type)

static void	test_jb_populate_config (struct jb_conf *jbconf)

static void	test_jb_resynch_frame_insertion (struct jitterbuf *jb, enum jb_frame_type frame_type)

static void	test_jb_warn_output (const char *fmt,...)

static int	unload_module (void)

Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "Jitter Buffer Tests" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = AST_BUILDOPT_SUM, .load = load_module, .unload = unload_module, .load_pri = AST_MODPRI_DEFAULT, .support_level = AST_MODULE_SUPPORT_CORE, }

static const struct ast_module_info *	ast_module_info = &__mod_info

static const char *	jitter_buffer_return_codes []

Detailed Description

Unit tests for jitterbuf.c.

Author

Matt Jordan <mjordan@digium.com>

Definition in file test_jitterbuf.c.

Macro Definition Documentation

◆ DEFAULT_CODEC_INTERP_LEN

#define DEFAULT_CODEC_INTERP_LEN 20

Definition at line 44 of file test_jitterbuf.c.

◆ DEFAULT_MAX_CONTIG_INTERP

#define DEFAULT_MAX_CONTIG_INTERP 10

Definition at line 42 of file test_jitterbuf.c.

◆ DEFAULT_MAX_JITTERBUFFER

#define DEFAULT_MAX_JITTERBUFFER 1000

Definition at line 40 of file test_jitterbuf.c.

◆ DEFAULT_RESYNCH_THRESHOLD

#define DEFAULT_RESYNCH_THRESHOLD 1000

Definition at line 41 of file test_jitterbuf.c.

◆ DEFAULT_TARGET_EXTRA

#define DEFAULT_TARGET_EXTRA -1

Definition at line 43 of file test_jitterbuf.c.

◆ JB_INFO_PRINT_FRAME_DEBUG

#define JB_INFO_PRINT_FRAME_DEBUG ( jbinfo )

Definition at line 60 of file test_jitterbuf.c.

◆ JB_NUMERIC_TEST

#define JB_NUMERIC_TEST	(	attribute,
		expected
	)

Definition at line 50 of file test_jitterbuf.c.

◆ JB_TEST_BEGIN

#define JB_TEST_BEGIN ( test_name )

Value:

    do { \
    jb_setoutput(test_jb_error_output, test_jb_warn_output, test_jb_debug_output); \
    ast_debug(1, "Starting %s\n", test_name); \
} while (0)

Definition at line 76 of file test_jitterbuf.c.

◆ JB_TEST_END

#define JB_TEST_END

Value:

    do { \
    jb_setoutput(NULL, NULL, NULL); \
} while (0)

Definition at line 84 of file test_jitterbuf.c.

Function Documentation

◆ __reg_module()

static void __reg_module ( void )

static

Definition at line 1282 of file test_jitterbuf.c.

◆ __unreg_module()

static void __unreg_module ( void )

static

Definition at line 1282 of file test_jitterbuf.c.

◆ AST_MODULE_SELF_SYM()

struct ast_module * AST_MODULE_SELF_SYM ( void )

Definition at line 1282 of file test_jitterbuf.c.

◆ AST_TEST_DEFINE() [1/12]

AST_TEST_DEFINE ( jitterbuffer_late_control )

Definition at line 837 of file test_jitterbuf.c.

{
    enum ast_test_result_state result = AST_TEST_FAIL;
    struct jitterbuf *jb = NULL;
    struct jb_frame frame;
    struct jb_info jbinfo;
    struct jb_conf jbconf;
    int i;
 
    switch (cmd) {
    case TEST_INIT:
        info->name = "jitterbuffer_late_control";
        info->category = "/main/jitterbuf/";
        info->summary = "Tests sending frames to a jitter buffer that arrive late";
        info->description =
            "Every 5th frame sent to a jitter buffer arrives late, but still in "
            "order with respect to the previous and next packet";
        return AST_TEST_NOT_RUN;
    case TEST_EXECUTE:
        break;
    }
 
    JB_TEST_BEGIN("jitterbuffer_late_voice");
 
    if (!(jb = jb_new())) {
        ast_test_status_update(test, "Failed to allocate memory for jitterbuffer\n");
        goto cleanup;
    }
 
    test_jb_populate_config(&jbconf);
    if (jb_setconf(jb, &jbconf) != JB_OK) {
        ast_test_status_update(test, "Failed to set jitterbuffer configuration\n");
        goto cleanup;
    }
 
    if (test_jb_late_frame_insertion(test, jb, JB_TYPE_CONTROL)) {
        goto cleanup;
    }
 
    for (i = 0; i < 40; i++) {
        enum jb_return_code ret;
        /* We should have a frame for each point in time */
        if ((ret = jb_get(jb, &frame, i * 20 + 5, DEFAULT_CODEC_INTERP_LEN)) != JB_OK) {
            ast_test_status_update(test,
                "Unexpected jitter buffer return code [%s] when retrieving frame %d\n",
                jitter_buffer_return_codes[ret], i);
            goto cleanup;
        }
        JB_NUMERIC_TEST(frame.ms, 20);
        JB_NUMERIC_TEST(frame.ts, i * 20 - jb->info.resync_offset);
    }
 
    if (jb_getinfo(jb, &jbinfo) != JB_OK) {
        ast_test_status_update(test, "Failed to get jitterbuffer information\n");
        goto cleanup;
    }
    JB_INFO_PRINT_FRAME_DEBUG(jbinfo);
    JB_NUMERIC_TEST(jbinfo.frames_ooo, 0);
    JB_NUMERIC_TEST(jbinfo.frames_late, 0);
    JB_NUMERIC_TEST(jbinfo.frames_lost, 0);
    JB_NUMERIC_TEST(jbinfo.frames_in, 40);
    JB_NUMERIC_TEST(jbinfo.frames_out, 40);
    JB_NUMERIC_TEST(jbinfo.frames_dropped, 0);
 
    result = AST_TEST_PASS;
 
cleanup:
    if (jb) {
        /* No need to do anything - this will put all frames on the 'free' list,
         * so jb_destroy will dispose of them */
        while (jb_getall(jb, &frame) == JB_OK) { }
        jb_destroy(jb);
    }
 
    JB_TEST_END;
 
    return result;
}

References AST_TEST_FAIL, AST_TEST_NOT_RUN, AST_TEST_PASS, ast_test_status_update, cleanup(), DEFAULT_CODEC_INTERP_LEN, jb_info::frames_dropped, jb_info::frames_in, jb_info::frames_late, jb_info::frames_lost, jb_info::frames_ooo, jb_info::frames_out, sip_to_pjsip::info(), jitterbuf::info, jb_destroy(), jb_get(), jb_getall(), jb_getinfo(), JB_INFO_PRINT_FRAME_DEBUG, jb_new(), JB_NUMERIC_TEST, JB_OK, jb_setconf(), JB_TEST_BEGIN, JB_TEST_END, JB_TYPE_CONTROL, jitter_buffer_return_codes, jb_frame::ms, NULL, result, jb_info::resync_offset, TEST_EXECUTE, TEST_INIT, test_jb_late_frame_insertion(), test_jb_populate_config(), and jb_frame::ts.

◆ AST_TEST_DEFINE() [2/12]

AST_TEST_DEFINE ( jitterbuffer_late_voice )

Definition at line 758 of file test_jitterbuf.c.

{
    enum ast_test_result_state result = AST_TEST_FAIL;
    struct jitterbuf *jb = NULL;
    struct jb_frame frame;
    struct jb_info jbinfo;
    struct jb_conf jbconf;
    int i;
 
    switch (cmd) {
    case TEST_INIT:
        info->name = "jitterbuffer_late_voice";
        info->category = "/main/jitterbuf/";
        info->summary = "Tests sending frames to a jitter buffer that arrive late";
        info->description =
            "Every 5th frame sent to a jitter buffer arrives late, but still in "
            "order with respect to the previous and next packet";
        return AST_TEST_NOT_RUN;
    case TEST_EXECUTE:
        break;
    }
 
    JB_TEST_BEGIN("jitterbuffer_late_voice");
 
    if (!(jb = jb_new())) {
        ast_test_status_update(test, "Failed to allocate memory for jitterbuffer\n");
        goto cleanup;
    }
 
    test_jb_populate_config(&jbconf);
    if (jb_setconf(jb, &jbconf) != JB_OK) {
        ast_test_status_update(test, "Failed to set jitterbuffer configuration\n");
        goto cleanup;
    }
 
    if (test_jb_late_frame_insertion(test, jb, JB_TYPE_VOICE)) {
        goto cleanup;
    }
 
    for (i = 0; i < 40; i++) {
        enum jb_return_code ret;
        /* We should have a frame for each point in time */
        if ((ret = jb_get(jb, &frame, i * 20 + 5, DEFAULT_CODEC_INTERP_LEN)) != JB_OK) {
            ast_test_status_update(test,
                "Unexpected jitter buffer return code [%s] when retrieving frame %d\n",
                jitter_buffer_return_codes[ret], i);
            goto cleanup;
        }
        JB_NUMERIC_TEST(frame.ms, 20);
        JB_NUMERIC_TEST(frame.ts, i * 20 - jb->info.resync_offset);
    }
 
    if (jb_getinfo(jb, &jbinfo) != JB_OK) {
        ast_test_status_update(test, "Failed to get jitterbuffer information\n");
        goto cleanup;
    }
    JB_INFO_PRINT_FRAME_DEBUG(jbinfo);
    JB_NUMERIC_TEST(jbinfo.frames_ooo, 0);
    JB_NUMERIC_TEST(jbinfo.frames_late, 0);
    JB_NUMERIC_TEST(jbinfo.frames_lost, 0);
    JB_NUMERIC_TEST(jbinfo.frames_in, 40);
    JB_NUMERIC_TEST(jbinfo.frames_out, 40);
    JB_NUMERIC_TEST(jbinfo.frames_dropped, 0);
 
    result = AST_TEST_PASS;
 
cleanup:
    if (jb) {
        /* No need to do anything - this will put all frames on the 'free' list,
         * so jb_destroy will dispose of them */
        while (jb_getall(jb, &frame) == JB_OK) { }
        jb_destroy(jb);
    }
 
    JB_TEST_END;
 
    return result;
}

References AST_TEST_FAIL, AST_TEST_NOT_RUN, AST_TEST_PASS, ast_test_status_update, cleanup(), DEFAULT_CODEC_INTERP_LEN, jb_info::frames_dropped, jb_info::frames_in, jb_info::frames_late, jb_info::frames_lost, jb_info::frames_ooo, jb_info::frames_out, sip_to_pjsip::info(), jitterbuf::info, jb_destroy(), jb_get(), jb_getall(), jb_getinfo(), JB_INFO_PRINT_FRAME_DEBUG, jb_new(), JB_NUMERIC_TEST, JB_OK, jb_setconf(), JB_TEST_BEGIN, JB_TEST_END, JB_TYPE_VOICE, jitter_buffer_return_codes, jb_frame::ms, NULL, result, jb_info::resync_offset, TEST_EXECUTE, TEST_INIT, test_jb_late_frame_insertion(), test_jb_populate_config(), and jb_frame::ts.

◆ AST_TEST_DEFINE() [3/12]

AST_TEST_DEFINE ( jitterbuffer_lost_control )

Definition at line 644 of file test_jitterbuf.c.

{
    enum ast_test_result_state result = AST_TEST_FAIL;
    struct jitterbuf *jb = NULL;
    struct jb_frame frame;
    struct jb_conf jbconf;
    struct jb_info jbinfo;
    int i;
 
    switch (cmd) {
    case TEST_INIT:
        info->name = "jitterbuffer_lost_control";
        info->category = "/main/jitterbuf/";
        info->summary = "Tests missing frames in the jitterbuffer";
        info->description =
            "Every 5th frame that would be sent to a jitter buffer is instead"
            "dropped.  When reading data from the jitter buffer, the jitter buffer"
            "simply reports that no frame exists for that time slot";
        return AST_TEST_NOT_RUN;
    case TEST_EXECUTE:
        break;
    }
 
    JB_TEST_BEGIN("jitterbuffer_lost_control");
 
    if (!(jb = jb_new())) {
        ast_test_status_update(test, "Failed to allocate memory for jitterbuffer\n");
        goto cleanup;
    }
 
    test_jb_populate_config(&jbconf);
    if (jb_setconf(jb, &jbconf) != JB_OK) {
        ast_test_status_update(test, "Failed to set jitterbuffer configuration\n");
        goto cleanup;
    }
 
    if (test_jb_lost_frame_insertion(test, jb, JB_TYPE_CONTROL)) {
        goto cleanup;
    }
 
    for (i = 0; i < 40; i++) {
        enum jb_return_code ret;
        if ((ret = jb_get(jb, &frame, i * 20 + 5, DEFAULT_CODEC_INTERP_LEN)) != JB_OK) {
            /* If we didn't get an OK, make sure that it was an expected lost frame */
            if (!(ret == JB_NOFRAME && i % 5 == 0)) {
                ast_test_status_update(test,
                    "Unexpected jitter buffer return code [%s] when retrieving frame %d\n",
                    jitter_buffer_return_codes[ret], i);
                goto cleanup;
            }
        } else {
            JB_NUMERIC_TEST(frame.ms, 20);
            JB_NUMERIC_TEST(frame.ts, i * 20 - jb->info.resync_offset);
        }
    }
 
    if (jb_getinfo(jb, &jbinfo) != JB_OK) {
        ast_test_status_update(test, "Failed to get jitterbuffer information\n");
        goto cleanup;
    }
    JB_INFO_PRINT_FRAME_DEBUG(jbinfo);
    /* Note: The first frame (at i = 0) never got added, so nothing existed at that point.
     * Its neither dropped nor lost.
     */
    JB_NUMERIC_TEST(jbinfo.frames_ooo, 0);
    JB_NUMERIC_TEST(jbinfo.frames_late, 0);
    JB_NUMERIC_TEST(jbinfo.frames_lost, 0);
    JB_NUMERIC_TEST(jbinfo.frames_in, 32);
    JB_NUMERIC_TEST(jbinfo.frames_out, 32);
    JB_NUMERIC_TEST(jbinfo.frames_dropped, 0);
 
    result = AST_TEST_PASS;
 
cleanup:
    if (jb) {
        /* No need to do anything - this will put all frames on the 'free' list,
         * so jb_destroy will dispose of them */
        while (jb_getall(jb, &frame) == JB_OK) { }
        jb_destroy(jb);
    }
 
    JB_TEST_END;
 
    return result;
}

References AST_TEST_FAIL, AST_TEST_NOT_RUN, AST_TEST_PASS, ast_test_status_update, cleanup(), DEFAULT_CODEC_INTERP_LEN, jb_info::frames_dropped, jb_info::frames_in, jb_info::frames_late, jb_info::frames_lost, jb_info::frames_ooo, jb_info::frames_out, sip_to_pjsip::info(), jitterbuf::info, jb_destroy(), jb_get(), jb_getall(), jb_getinfo(), JB_INFO_PRINT_FRAME_DEBUG, jb_new(), JB_NOFRAME, JB_NUMERIC_TEST, JB_OK, jb_setconf(), JB_TEST_BEGIN, JB_TEST_END, JB_TYPE_CONTROL, jitter_buffer_return_codes, jb_frame::ms, NULL, result, jb_info::resync_offset, TEST_EXECUTE, TEST_INIT, test_jb_lost_frame_insertion(), test_jb_populate_config(), and jb_frame::ts.

◆ AST_TEST_DEFINE() [4/12]

AST_TEST_DEFINE ( jitterbuffer_lost_voice )

Definition at line 558 of file test_jitterbuf.c.

{
    enum ast_test_result_state result = AST_TEST_FAIL;
    struct jitterbuf *jb = NULL;
    struct jb_frame frame;
    struct jb_conf jbconf;
    struct jb_info jbinfo;
    int i;
 
    switch (cmd) {
    case TEST_INIT:
        info->name = "jitterbuffer_lost_voice";
        info->category = "/main/jitterbuf/";
        info->summary = "Tests missing frames in the jitterbuffer";
        info->description =
            "Every 5th frame that would be sent to a jitter buffer is instead"
            "dropped.  When reading data from the jitter buffer, the jitter buffer"
            "should interpolate the voice frame.";
        return AST_TEST_NOT_RUN;
    case TEST_EXECUTE:
        break;
    }
 
    JB_TEST_BEGIN("jitterbuffer_lost_voice");
 
    if (!(jb = jb_new())) {
        ast_test_status_update(test, "Failed to allocate memory for jitterbuffer\n");
        goto cleanup;
    }
 
    test_jb_populate_config(&jbconf);
    if (jb_setconf(jb, &jbconf) != JB_OK) {
        ast_test_status_update(test, "Failed to set jitterbuffer configuration\n");
        goto cleanup;
    }
 
    if (test_jb_lost_frame_insertion(test, jb, JB_TYPE_VOICE)) {
        goto cleanup;
    }
 
    for (i = 0; i < 40; i++) {
        enum jb_return_code ret;
        if ((ret = jb_get(jb, &frame, i * 20 + 5, DEFAULT_CODEC_INTERP_LEN)) != JB_OK) {
            /* If we didn't get an OK, make sure that it was an expected lost frame */
            if (!((ret == JB_INTERP && i % 5 == 0) || (ret == JB_NOFRAME && i == 0))) {
                ast_test_status_update(test,
                    "Unexpected jitter buffer return code [%s] when retrieving frame %d\n",
                    jitter_buffer_return_codes[ret], i);
                goto cleanup;
            }
        } else {
            JB_NUMERIC_TEST(frame.ms, 20);
            JB_NUMERIC_TEST(frame.ts, i * 20 - jb->info.resync_offset);
        }
    }
 
    if (jb_getinfo(jb, &jbinfo) != JB_OK) {
        ast_test_status_update(test, "Failed to get jitterbuffer information\n");
        goto cleanup;
    }
    JB_INFO_PRINT_FRAME_DEBUG(jbinfo);
    /* Note: The first frame (at i = 0) never got added, so nothing existed at that point.
     * Its neither dropped nor lost.
     */
    JB_NUMERIC_TEST(jbinfo.frames_ooo, 0);
    JB_NUMERIC_TEST(jbinfo.frames_late, 0);
    JB_NUMERIC_TEST(jbinfo.frames_lost, 7);
    JB_NUMERIC_TEST(jbinfo.frames_in, 32);
    JB_NUMERIC_TEST(jbinfo.frames_out, 32);
    JB_NUMERIC_TEST(jbinfo.frames_dropped, 0);
 
    result = AST_TEST_PASS;
 
cleanup:
    if (jb) {
        /* No need to do anything - this will put all frames on the 'free' list,
         * so jb_destroy will dispose of them */
        while (jb_getall(jb, &frame) == JB_OK) { }
        jb_destroy(jb);
    }
 
    JB_TEST_END;
 
    return result;
}

References AST_TEST_FAIL, AST_TEST_NOT_RUN, AST_TEST_PASS, ast_test_status_update, cleanup(), DEFAULT_CODEC_INTERP_LEN, jb_info::frames_dropped, jb_info::frames_in, jb_info::frames_late, jb_info::frames_lost, jb_info::frames_ooo, jb_info::frames_out, sip_to_pjsip::info(), jitterbuf::info, jb_destroy(), jb_get(), jb_getall(), jb_getinfo(), JB_INFO_PRINT_FRAME_DEBUG, JB_INTERP, jb_new(), JB_NOFRAME, JB_NUMERIC_TEST, JB_OK, jb_setconf(), JB_TEST_BEGIN, JB_TEST_END, JB_TYPE_VOICE, jitter_buffer_return_codes, jb_frame::ms, NULL, result, jb_info::resync_offset, TEST_EXECUTE, TEST_INIT, test_jb_lost_frame_insertion(), test_jb_populate_config(), and jb_frame::ts.

◆ AST_TEST_DEFINE() [5/12]

AST_TEST_DEFINE ( jitterbuffer_nominal_control_frames )

Definition at line 260 of file test_jitterbuf.c.

{
    enum ast_test_result_state result = AST_TEST_FAIL;
    struct jitterbuf *jb = NULL;
    struct jb_frame frame;
    struct jb_conf jbconf;
    struct jb_info jbinfo;
    int i = 0;
 
    switch (cmd) {
    case TEST_INIT:
        info->name = "jitterbuffer_nominal_control_frames";
        info->category = "/main/jitterbuf/";
        info->summary = "Nominal operation of jitter buffer with control frames";
        info->description =
            "Tests the nominal case of putting control frames into a jitter buffer, "
            "retrieving the frames, and querying for the next frame";
        return AST_TEST_NOT_RUN;
    case TEST_EXECUTE:
        break;
    }
 
    JB_TEST_BEGIN("jitterbuffer_nominal_control_frames");
 
    if (!(jb = jb_new())) {
        ast_test_status_update(test, "Failed to allocate memory for jitterbuffer\n");
        goto cleanup;
    }
 
    test_jb_populate_config(&jbconf);
    if (jb_setconf(jb, &jbconf) != JB_OK) {
        ast_test_status_update(test, "Failed to set jitterbuffer configuration\n");
        goto cleanup;
    }
 
    if (test_jb_nominal_frame_insertion(test, jb, JB_TYPE_CONTROL)) {
        goto cleanup;
    }
 
    for (i = 0; i < 40; i++) {
        enum jb_return_code ret;
        /* We should have a frame for each point in time */
        if ((ret = jb_get(jb, &frame, i * 20 + 5, DEFAULT_CODEC_INTERP_LEN)) != JB_OK) {
            ast_test_status_update(test,
                "Unexpected jitter buffer return code [%s] when retrieving frame %d\n",
                jitter_buffer_return_codes[ret], i);
            goto cleanup;
        }
        JB_NUMERIC_TEST(frame.ms, 20);
        JB_NUMERIC_TEST(frame.ts, i * 20 - jb->info.resync_offset);
    }
 
    if (jb_getinfo(jb, &jbinfo) != JB_OK) {
        ast_test_status_update(test, "Failed to get jitterbuffer information\n");
        goto cleanup;
    }
    JB_INFO_PRINT_FRAME_DEBUG(jbinfo);
    JB_NUMERIC_TEST(jbinfo.frames_dropped, 0);
    JB_NUMERIC_TEST(jbinfo.frames_in, 40);
    JB_NUMERIC_TEST(jbinfo.frames_out, 40);
    JB_NUMERIC_TEST(jbinfo.frames_late, 0);
    JB_NUMERIC_TEST(jbinfo.frames_lost, 0);
    JB_NUMERIC_TEST(jbinfo.frames_ooo, 0);
 
    result = AST_TEST_PASS;
 
cleanup:
    if (jb) {
        /* No need to do anything - this will put all frames on the 'free' list,
         * so jb_destroy will dispose of them */
        while (jb_getall(jb, &frame) == JB_OK) { }
        jb_destroy(jb);
    }
 
    JB_TEST_END;
 
    return result;
}

References AST_TEST_FAIL, AST_TEST_NOT_RUN, AST_TEST_PASS, ast_test_status_update, cleanup(), DEFAULT_CODEC_INTERP_LEN, jb_info::frames_dropped, jb_info::frames_in, jb_info::frames_late, jb_info::frames_lost, jb_info::frames_ooo, jb_info::frames_out, sip_to_pjsip::info(), jitterbuf::info, jb_destroy(), jb_get(), jb_getall(), jb_getinfo(), JB_INFO_PRINT_FRAME_DEBUG, jb_new(), JB_NUMERIC_TEST, JB_OK, jb_setconf(), JB_TEST_BEGIN, JB_TEST_END, JB_TYPE_CONTROL, jitter_buffer_return_codes, jb_frame::ms, NULL, result, jb_info::resync_offset, TEST_EXECUTE, TEST_INIT, test_jb_nominal_frame_insertion(), test_jb_populate_config(), and jb_frame::ts.

◆ AST_TEST_DEFINE() [6/12]

AST_TEST_DEFINE ( jitterbuffer_nominal_voice_frames )

Definition at line 180 of file test_jitterbuf.c.

{
    enum ast_test_result_state result = AST_TEST_FAIL;
    struct jitterbuf *jb = NULL;
    struct jb_frame frame;
    struct jb_conf jbconf;
    struct jb_info jbinfo;
    int i = 0;
 
    switch (cmd) {
    case TEST_INIT:
        info->name = "jitterbuffer_nominal_voice_frames";
        info->category = "/main/jitterbuf/";
        info->summary = "Nominal operation of jitter buffer with audio data";
        info->description =
            "Tests the nominal case of putting audio data into a jitter buffer, "
            "retrieving the frames, and querying for the next frame";
        return AST_TEST_NOT_RUN;
    case TEST_EXECUTE:
        break;
    }
 
    JB_TEST_BEGIN("jitterbuffer_nominal_voice_frames");
 
    if (!(jb = jb_new())) {
        ast_test_status_update(test, "Failed to allocate memory for jitterbuffer\n");
        goto cleanup;
    }
 
    test_jb_populate_config(&jbconf);
    if (jb_setconf(jb, &jbconf) != JB_OK) {
        ast_test_status_update(test, "Failed to set jitterbuffer configuration\n");
        goto cleanup;
    }
 
    if (test_jb_nominal_frame_insertion(test, jb, JB_TYPE_VOICE)) {
        goto cleanup;
    }
 
    for (i = 0; i < 40; i++) {
        enum jb_return_code ret;
        /* We should have a frame for each point in time */
        if ((ret = jb_get(jb, &frame, i * 20 + 5, DEFAULT_CODEC_INTERP_LEN)) != JB_OK) {
            ast_test_status_update(test,
                "Unexpected jitter buffer return code [%s] when retrieving frame %d\n",
                jitter_buffer_return_codes[ret], i);
            goto cleanup;
        }
        JB_NUMERIC_TEST(frame.ms, 20);
        JB_NUMERIC_TEST(frame.ts, i * 20 - jb->info.resync_offset);
        JB_NUMERIC_TEST(jb_next(jb), (i + 1) * 20 + 5);
    }
 
    result = AST_TEST_PASS;
 
    if (jb_getinfo(jb, &jbinfo) != JB_OK) {
        ast_test_status_update(test, "Failed to get jitterbuffer information\n");
        goto cleanup;
    }
    JB_INFO_PRINT_FRAME_DEBUG(jbinfo);
    JB_NUMERIC_TEST(jbinfo.frames_dropped, 0);
    JB_NUMERIC_TEST(jbinfo.frames_in, 40);
    JB_NUMERIC_TEST(jbinfo.frames_out, 40);
    JB_NUMERIC_TEST(jbinfo.frames_late, 0);
    JB_NUMERIC_TEST(jbinfo.frames_lost, 0);
    JB_NUMERIC_TEST(jbinfo.frames_ooo, 0);
 
cleanup:
    if (jb) {
        /* No need to do anything - this will put all frames on the 'free' list,
         * so jb_destroy will dispose of them */
        while (jb_getall(jb, &frame) == JB_OK) { }
        jb_destroy(jb);
    }
 
    JB_TEST_END;
 
    return result;
}

References AST_TEST_FAIL, AST_TEST_NOT_RUN, AST_TEST_PASS, ast_test_status_update, cleanup(), DEFAULT_CODEC_INTERP_LEN, jb_info::frames_dropped, jb_info::frames_in, jb_info::frames_late, jb_info::frames_lost, jb_info::frames_ooo, jb_info::frames_out, sip_to_pjsip::info(), jitterbuf::info, jb_destroy(), jb_get(), jb_getall(), jb_getinfo(), JB_INFO_PRINT_FRAME_DEBUG, jb_new(), jb_next(), JB_NUMERIC_TEST, JB_OK, jb_setconf(), JB_TEST_BEGIN, JB_TEST_END, JB_TYPE_VOICE, jitter_buffer_return_codes, jb_frame::ms, NULL, result, jb_info::resync_offset, TEST_EXECUTE, TEST_INIT, test_jb_nominal_frame_insertion(), test_jb_populate_config(), and jb_frame::ts.

◆ AST_TEST_DEFINE() [7/12]

AST_TEST_DEFINE ( jitterbuffer_out_of_order_control )

Definition at line 455 of file test_jitterbuf.c.

{
    enum ast_test_result_state result = AST_TEST_FAIL;
    struct jitterbuf *jb = NULL;
    struct jb_frame frame;
    struct jb_info jbinfo;
    struct jb_conf jbconf;
    int i;
 
    switch (cmd) {
    case TEST_INIT:
        info->name = "jitterbuffer_out_of_order_voice";
        info->category = "/main/jitterbuf/";
        info->summary = "Tests sending out of order audio frames to a jitter buffer";
        info->description =
            "Every 5th frame sent to a jitter buffer is reversed with the previous "
            "frame.  The expected result is to have a jitter buffer with the frames "
            "in order, while a total of 10 frames should be recorded as having been "
            "received out of order.";
        return AST_TEST_NOT_RUN;
    case TEST_EXECUTE:
        break;
    }
 
    JB_TEST_BEGIN("jitterbuffer_out_of_order_control");
 
    if (!(jb = jb_new())) {
        ast_test_status_update(test, "Failed to allocate memory for jitterbuffer\n");
        goto cleanup;
    }
 
    test_jb_populate_config(&jbconf);
    if (jb_setconf(jb, &jbconf) != JB_OK) {
        ast_test_status_update(test, "Failed to set jitterbuffer configuration\n");
        goto cleanup;
    }
 
    if (test_jb_out_of_order_frame_insertion(test, jb, JB_TYPE_CONTROL)) {
        goto cleanup;
    }
 
    for (i = 0; i < 40; i++) {
        enum jb_return_code ret;
        /* We should have a frame for each point in time */
        if ((ret = jb_get(jb, &frame, i * 20 + 5, DEFAULT_CODEC_INTERP_LEN)) != JB_OK) {
            ast_test_status_update(test,
                "Unexpected jitter buffer return code [%s] when retrieving frame %d\n",
                jitter_buffer_return_codes[ret], i);
            goto cleanup;
        }
        JB_NUMERIC_TEST(frame.ms, 20);
        JB_NUMERIC_TEST(frame.ts, i * 20 - jb->info.resync_offset);
    }
 
    if (jb_getinfo(jb, &jbinfo) != JB_OK) {
        ast_test_status_update(test, "Failed to get jitterbuffer information\n");
        goto cleanup;
    }
    JB_INFO_PRINT_FRAME_DEBUG(jbinfo);
    JB_NUMERIC_TEST(jbinfo.frames_dropped, 0);
    JB_NUMERIC_TEST(jbinfo.frames_in, 40);
    JB_NUMERIC_TEST(jbinfo.frames_out, 40);
    JB_NUMERIC_TEST(jbinfo.frames_late, 0);
    JB_NUMERIC_TEST(jbinfo.frames_lost, 0);
    JB_NUMERIC_TEST(jbinfo.frames_ooo, 10);
 
    result = AST_TEST_PASS;
 
cleanup:
    if (jb) {
        /* No need to do anything - this will put all frames on the 'free' list,
         * so jb_destroy will dispose of them */
        while (jb_getall(jb, &frame) == JB_OK) { }
        jb_destroy(jb);
    }
 
    JB_TEST_END;
 
    return result;
}

References AST_TEST_FAIL, AST_TEST_NOT_RUN, AST_TEST_PASS, ast_test_status_update, cleanup(), DEFAULT_CODEC_INTERP_LEN, jb_info::frames_dropped, jb_info::frames_in, jb_info::frames_late, jb_info::frames_lost, jb_info::frames_ooo, jb_info::frames_out, sip_to_pjsip::info(), jitterbuf::info, jb_destroy(), jb_get(), jb_getall(), jb_getinfo(), JB_INFO_PRINT_FRAME_DEBUG, jb_new(), JB_NUMERIC_TEST, JB_OK, jb_setconf(), JB_TEST_BEGIN, JB_TEST_END, JB_TYPE_CONTROL, jitter_buffer_return_codes, jb_frame::ms, NULL, result, jb_info::resync_offset, TEST_EXECUTE, TEST_INIT, test_jb_out_of_order_frame_insertion(), test_jb_populate_config(), and jb_frame::ts.

◆ AST_TEST_DEFINE() [8/12]

AST_TEST_DEFINE ( jitterbuffer_out_of_order_voice )

Definition at line 374 of file test_jitterbuf.c.

{
    enum ast_test_result_state result = AST_TEST_FAIL;
    struct jitterbuf *jb = NULL;
    struct jb_frame frame;
    struct jb_info jbinfo;
    struct jb_conf jbconf;
    int i;
 
    switch (cmd) {
    case TEST_INIT:
        info->name = "jitterbuffer_out_of_order_voice";
        info->category = "/main/jitterbuf/";
        info->summary = "Tests sending out of order audio frames to a jitter buffer";
        info->description =
            "Every 5th frame sent to a jitter buffer is reversed with the previous "
            "frame.  The expected result is to have a jitter buffer with the frames "
            "in order, while a total of 10 frames should be recorded as having been "
            "received out of order.";
        return AST_TEST_NOT_RUN;
    case TEST_EXECUTE:
        break;
    }
 
    JB_TEST_BEGIN("jitterbuffer_out_of_order_voice");
 
    if (!(jb = jb_new())) {
        ast_test_status_update(test, "Failed to allocate memory for jitterbuffer\n");
        goto cleanup;
    }
 
    test_jb_populate_config(&jbconf);
    if (jb_setconf(jb, &jbconf) != JB_OK) {
        ast_test_status_update(test, "Failed to set jitterbuffer configuration\n");
        goto cleanup;
    }
 
    if (test_jb_out_of_order_frame_insertion(test, jb, JB_TYPE_VOICE)) {
        goto cleanup;
    }
 
    for (i = 0; i < 40; i++) {
        enum jb_return_code ret;
        /* We should have a frame for each point in time */
        if ((ret = jb_get(jb, &frame, i * 20 + 5, DEFAULT_CODEC_INTERP_LEN)) != JB_OK) {
            ast_test_status_update(test,
                "Unexpected jitter buffer return code [%s] when retrieving frame %d\n",
                jitter_buffer_return_codes[ret], i);
            goto cleanup;
        }
        JB_NUMERIC_TEST(frame.ms, 20);
        JB_NUMERIC_TEST(frame.ts, i * 20 - jb->info.resync_offset);
    }
 
    if (jb_getinfo(jb, &jbinfo) != JB_OK) {
        ast_test_status_update(test, "Failed to get jitterbuffer information\n");
        goto cleanup;
    }
    JB_INFO_PRINT_FRAME_DEBUG(jbinfo);
    JB_NUMERIC_TEST(jbinfo.frames_dropped, 0);
    JB_NUMERIC_TEST(jbinfo.frames_in, 40);
    JB_NUMERIC_TEST(jbinfo.frames_out, 40);
    JB_NUMERIC_TEST(jbinfo.frames_late, 0);
    JB_NUMERIC_TEST(jbinfo.frames_lost, 0);
    JB_NUMERIC_TEST(jbinfo.frames_ooo, 10);
 
    result = AST_TEST_PASS;
 
cleanup:
    if (jb) {
        /* No need to do anything - this will put all frames on the 'free' list,
         * so jb_destroy will dispose of them */
        while (jb_getall(jb, &frame) == JB_OK) { }
        jb_destroy(jb);
    }
 
    JB_TEST_END;
 
    return result;
}

References AST_TEST_FAIL, AST_TEST_NOT_RUN, AST_TEST_PASS, ast_test_status_update, cleanup(), DEFAULT_CODEC_INTERP_LEN, jb_info::frames_dropped, jb_info::frames_in, jb_info::frames_late, jb_info::frames_lost, jb_info::frames_ooo, jb_info::frames_out, sip_to_pjsip::info(), jitterbuf::info, jb_destroy(), jb_get(), jb_getall(), jb_getinfo(), JB_INFO_PRINT_FRAME_DEBUG, jb_new(), JB_NUMERIC_TEST, JB_OK, jb_setconf(), JB_TEST_BEGIN, JB_TEST_END, JB_TYPE_VOICE, jitter_buffer_return_codes, jb_frame::ms, NULL, result, jb_info::resync_offset, TEST_EXECUTE, TEST_INIT, test_jb_out_of_order_frame_insertion(), test_jb_populate_config(), and jb_frame::ts.

◆ AST_TEST_DEFINE() [9/12]

AST_TEST_DEFINE ( jitterbuffer_overflow_control )

Definition at line 999 of file test_jitterbuf.c.

{
    enum ast_test_result_state result = AST_TEST_FAIL;
    struct jitterbuf *jb = NULL;
    struct jb_frame frame;
    struct jb_info jbinfo;
    struct jb_conf jbconf;
    int i = 0;
 
    switch (cmd) {
    case TEST_INIT:
        info->name = "jitterbuffer_overflow_control";
        info->category = "/main/jitterbuf/";
        info->summary = "Tests overfilling a jitter buffer with control frames";
        info->description = "Tests overfilling a jitter buffer with control frames";
        return AST_TEST_NOT_RUN;
    case TEST_EXECUTE:
        break;
    }
 
    JB_TEST_BEGIN("jitterbuffer_overflow_control");
 
    if (!(jb = jb_new())) {
        ast_test_status_update(test, "Failed to allocate memory for jitterbuffer\n");
        goto cleanup;
    }
 
    test_jb_populate_config(&jbconf);
    if (jb_setconf(jb, &jbconf) != JB_OK) {
        ast_test_status_update(test, "Failed to set jitterbuffer configuration\n");
        goto cleanup;
    }
 
    test_jb_overflow_frame_insertion(jb, JB_TYPE_CONTROL);
 
    while (jb_get(jb, &frame, i * 20 + 5, DEFAULT_CODEC_INTERP_LEN) == JB_OK) {
        JB_NUMERIC_TEST(frame.ms, 20);
        JB_NUMERIC_TEST(frame.ts, i * 20 - jb->info.resync_offset);
        ++i;
    }
 
    if (jb_getinfo(jb, &jbinfo) != JB_OK) {
        ast_test_status_update(test, "Failed to get jitterbuffer information\n");
        goto cleanup;
    }
 
    JB_INFO_PRINT_FRAME_DEBUG(jbinfo);
    JB_NUMERIC_TEST(jbinfo.frames_dropped, 49);
    JB_NUMERIC_TEST(jbinfo.frames_out, 51);
    JB_NUMERIC_TEST(jbinfo.frames_in, 51);
    JB_NUMERIC_TEST(jbinfo.frames_late, 0);
    JB_NUMERIC_TEST(jbinfo.frames_lost, 0);
    JB_NUMERIC_TEST(jbinfo.frames_ooo, 0);
 
    result = AST_TEST_PASS;
 
cleanup:
    if (jb) {
        /* No need to do anything - this will put all frames on the 'free' list,
         * so jb_destroy will dispose of them */
        while (jb_getall(jb, &frame) == JB_OK) { }
        jb_destroy(jb);
    }
 
    JB_TEST_END;
 
    return result;
}

References AST_TEST_FAIL, AST_TEST_NOT_RUN, AST_TEST_PASS, ast_test_status_update, cleanup(), DEFAULT_CODEC_INTERP_LEN, jb_info::frames_dropped, jb_info::frames_in, jb_info::frames_late, jb_info::frames_lost, jb_info::frames_ooo, jb_info::frames_out, sip_to_pjsip::info(), jitterbuf::info, jb_destroy(), jb_get(), jb_getall(), jb_getinfo(), JB_INFO_PRINT_FRAME_DEBUG, jb_new(), JB_NUMERIC_TEST, JB_OK, jb_setconf(), JB_TEST_BEGIN, JB_TEST_END, JB_TYPE_CONTROL, jb_frame::ms, NULL, result, jb_info::resync_offset, TEST_EXECUTE, TEST_INIT, test_jb_overflow_frame_insertion(), test_jb_populate_config(), and jb_frame::ts.

◆ AST_TEST_DEFINE() [10/12]

AST_TEST_DEFINE ( jitterbuffer_overflow_voice )

Definition at line 929 of file test_jitterbuf.c.

{
    enum ast_test_result_state result = AST_TEST_FAIL;
    struct jitterbuf *jb = NULL;
    struct jb_frame frame;
    struct jb_info jbinfo;
    struct jb_conf jbconf;
    int i = 0;
 
    switch (cmd) {
    case TEST_INIT:
        info->name = "jitterbuffer_overflow_voice";
        info->category = "/main/jitterbuf/";
        info->summary = "Tests overfilling a jitter buffer with voice frames";
        info->description = "Tests overfilling a jitter buffer with voice frames";
        return AST_TEST_NOT_RUN;
    case TEST_EXECUTE:
        break;
    }
 
    JB_TEST_BEGIN("jitterbuffer_overflow_voice");
 
    if (!(jb = jb_new())) {
        ast_test_status_update(test, "Failed to allocate memory for jitterbuffer\n");
        goto cleanup;
    }
 
    test_jb_populate_config(&jbconf);
    if (jb_setconf(jb, &jbconf) != JB_OK) {
        ast_test_status_update(test, "Failed to set jitterbuffer configuration\n");
        goto cleanup;
    }
 
    test_jb_overflow_frame_insertion(jb, JB_TYPE_VOICE);
 
    while (jb_get(jb, &frame, i * 20 + 5, DEFAULT_CODEC_INTERP_LEN) == JB_OK) {
        JB_NUMERIC_TEST(frame.ms, 20);
        JB_NUMERIC_TEST(frame.ts, i * 20 - jb->info.resync_offset);
        ++i;
    }
 
    if (jb_getinfo(jb, &jbinfo) != JB_OK) {
        ast_test_status_update(test, "Failed to get jitterbuffer information\n");
        goto cleanup;
    }
 
    JB_INFO_PRINT_FRAME_DEBUG(jbinfo);
    JB_NUMERIC_TEST(jbinfo.frames_dropped, 49);
    JB_NUMERIC_TEST(jbinfo.frames_out, 51);
    JB_NUMERIC_TEST(jbinfo.frames_in, 51);
    JB_NUMERIC_TEST(jbinfo.frames_late, 0);
    /* Note that the last frame will be interpolated */
    JB_NUMERIC_TEST(jbinfo.frames_lost, 1);
    JB_NUMERIC_TEST(jbinfo.frames_ooo, 0);
 
    result = AST_TEST_PASS;
 
cleanup:
    if (jb) {
        /* No need to do anything - this will put all frames on the 'free' list,
         * so jb_destroy will dispose of them */
        while (jb_getall(jb, &frame) == JB_OK) { }
        jb_destroy(jb);
    }
 
    JB_TEST_END;
 
    return result;
}

References AST_TEST_FAIL, AST_TEST_NOT_RUN, AST_TEST_PASS, ast_test_status_update, cleanup(), DEFAULT_CODEC_INTERP_LEN, jb_info::frames_dropped, jb_info::frames_in, jb_info::frames_late, jb_info::frames_lost, jb_info::frames_ooo, jb_info::frames_out, sip_to_pjsip::info(), jitterbuf::info, jb_destroy(), jb_get(), jb_getall(), jb_getinfo(), JB_INFO_PRINT_FRAME_DEBUG, jb_new(), JB_NUMERIC_TEST, JB_OK, jb_setconf(), JB_TEST_BEGIN, JB_TEST_END, JB_TYPE_VOICE, jb_frame::ms, NULL, result, jb_info::resync_offset, TEST_EXECUTE, TEST_INIT, test_jb_overflow_frame_insertion(), test_jb_populate_config(), and jb_frame::ts.

◆ AST_TEST_DEFINE() [11/12]

AST_TEST_DEFINE ( jitterbuffer_resynch_control )

Definition at line 1085 of file test_jitterbuf.c.

{
    enum ast_test_result_state result = AST_TEST_FAIL;
    struct jitterbuf *jb = NULL;
    struct jb_frame frame;
    struct jb_info jbinfo;
    struct jb_conf jbconf;
    int interpolated_frames = 0;
    int i;
 
    switch (cmd) {
    case TEST_INIT:
        info->name = "jitterbuffer_resynch_control";
        info->category = "/main/jitterbuf/";
        info->summary = "Tests sending control frames that force a resynch";
        info->description = "Control frames are sent to a jitter buffer.  After some "
            "number of frames, the source timestamps jump, forcing a resync of "
            "the jitter buffer.  Since the frames are control, the resync happens "
            "immediately.";
        return AST_TEST_NOT_RUN;
    case TEST_EXECUTE:
        break;
    }
 
    JB_TEST_BEGIN("jitterbuffer_resynch_control");
 
    if (!(jb = jb_new())) {
        ast_test_status_update(test, "Failed to allocate memory for jitterbuffer\n");
        goto cleanup;
    }
 
    test_jb_populate_config(&jbconf);
    jbconf.resync_threshold = 200;
    if (jb_setconf(jb, &jbconf) != JB_OK) {
        ast_test_status_update(test, "Failed to set jitterbuffer configuration\n");
        goto cleanup;
    }
 
    test_jb_resynch_frame_insertion(jb, JB_TYPE_CONTROL);
 
    for (i = 0; i <= 40; i++) {
        if (jb_get(jb, &frame, i * 20 + 5, DEFAULT_CODEC_INTERP_LEN) == JB_INTERP) {
            ++interpolated_frames;
        }
    }
 
    if (jb_getinfo(jb, &jbinfo) != JB_OK) {
        ast_test_status_update(test, "Failed to get jitterbuffer information\n");
        goto cleanup;
    }
    /* With control frames, a resync happens automatically */
    JB_INFO_PRINT_FRAME_DEBUG(jbinfo);
    JB_NUMERIC_TEST(jbinfo.frames_dropped, 0);
    JB_NUMERIC_TEST(jbinfo.frames_out, 40);
    JB_NUMERIC_TEST(jbinfo.frames_in, 40);
    /* Verify that each of the interpolated frames is counted */
    JB_NUMERIC_TEST(jbinfo.frames_lost, interpolated_frames);
    JB_NUMERIC_TEST(jbinfo.frames_late, 0);
    JB_NUMERIC_TEST(jbinfo.frames_ooo, 0);
 
    result = AST_TEST_PASS;
 
cleanup:
    if (jb) {
        /* No need to do anything - this will put all frames on the 'free' list,
         * so jb_destroy will dispose of them */
        while (jb_getall(jb, &frame) == JB_OK) { }
        jb_destroy(jb);
    }
 
    JB_TEST_END;
 
    return result;
}

References AST_TEST_FAIL, AST_TEST_NOT_RUN, AST_TEST_PASS, ast_test_status_update, cleanup(), DEFAULT_CODEC_INTERP_LEN, jb_info::frames_dropped, jb_info::frames_in, jb_info::frames_late, jb_info::frames_lost, jb_info::frames_ooo, jb_info::frames_out, sip_to_pjsip::info(), jb_destroy(), jb_get(), jb_getall(), jb_getinfo(), JB_INFO_PRINT_FRAME_DEBUG, JB_INTERP, jb_new(), JB_NUMERIC_TEST, JB_OK, jb_setconf(), JB_TEST_BEGIN, JB_TEST_END, JB_TYPE_CONTROL, NULL, result, jb_conf::resync_threshold, TEST_EXECUTE, TEST_INIT, test_jb_populate_config(), and test_jb_resynch_frame_insertion().

◆ AST_TEST_DEFINE() [12/12]

AST_TEST_DEFINE ( jitterbuffer_resynch_voice )

Definition at line 1160 of file test_jitterbuf.c.

{
    enum ast_test_result_state result = AST_TEST_FAIL;
    struct jitterbuf *jb = NULL;
    struct jb_frame frame;
    struct jb_info jbinfo;
    struct jb_conf jbconf;
    int interpolated_frames = 0;
    int i;
 
    switch (cmd) {
    case TEST_INIT:
        info->name = "jitterbuffer_resynch_voice";
        info->category = "/main/jitterbuf/";
        info->summary = "Tests sending voice frames that force a resynch";
        info->description = "Voice frames are sent to a jitter buffer.  After some "
            "number of frames, the source timestamps jump, forcing a resync of "
            "the jitter buffer.  Since the frames are voice, the resync happens "
            "after observing three packets that break the resync threshold.";
        return AST_TEST_NOT_RUN;
    case TEST_EXECUTE:
        break;
    }
 
    JB_TEST_BEGIN("jitterbuffer_resynch_voice");
 
    if (!(jb = jb_new())) {
        ast_test_status_update(test, "Failed to allocate memory for jitterbuffer\n");
        goto cleanup;
    }
 
    test_jb_populate_config(&jbconf);
    jbconf.resync_threshold = 200;
    if (jb_setconf(jb, &jbconf) != JB_OK) {
        ast_test_status_update(test, "Failed to set jitterbuffer configuration\n");
        goto cleanup;
    }
 
    test_jb_resynch_frame_insertion(jb, JB_TYPE_VOICE);
 
    for (i = 0; i <= 40; i++) {
        if (jb_get(jb, &frame, i * 20 + 5, DEFAULT_CODEC_INTERP_LEN) == JB_INTERP) {
            ++interpolated_frames;
        }
    }
 
    if (jb_getinfo(jb, &jbinfo) != JB_OK) {
        ast_test_status_update(test, "Failed to get jitterbuffer information\n");
        goto cleanup;
    }
    /* The first three packets before the resync should be dropped */
    JB_INFO_PRINT_FRAME_DEBUG(jbinfo);
    JB_NUMERIC_TEST(jbinfo.frames_dropped, 3);
    JB_NUMERIC_TEST(jbinfo.frames_out, 37);
    JB_NUMERIC_TEST(jbinfo.frames_in, 37);
    /* Verify that each of the interpolated frames is counted */
    JB_NUMERIC_TEST(jbinfo.frames_lost, interpolated_frames);
    JB_NUMERIC_TEST(jbinfo.frames_late, 0);
    JB_NUMERIC_TEST(jbinfo.frames_ooo, 0);
 
 
    result = AST_TEST_PASS;
 
cleanup:
    if (jb) {
        /* No need to do anything - this will put all frames on the 'free' list,
         * so jb_destroy will dispose of them */
        while (jb_getall(jb, &frame) == JB_OK) { }
        jb_destroy(jb);
    }
 
    JB_TEST_END;
 
    return result;
}

References AST_TEST_FAIL, AST_TEST_NOT_RUN, AST_TEST_PASS, ast_test_status_update, cleanup(), DEFAULT_CODEC_INTERP_LEN, jb_info::frames_dropped, jb_info::frames_in, jb_info::frames_late, jb_info::frames_lost, jb_info::frames_ooo, jb_info::frames_out, sip_to_pjsip::info(), jb_destroy(), jb_get(), jb_getall(), jb_getinfo(), JB_INFO_PRINT_FRAME_DEBUG, JB_INTERP, jb_new(), JB_NUMERIC_TEST, JB_OK, jb_setconf(), JB_TEST_BEGIN, JB_TEST_END, JB_TYPE_VOICE, NULL, result, jb_conf::resync_threshold, TEST_EXECUTE, TEST_INIT, test_jb_populate_config(), and test_jb_resynch_frame_insertion().

◆ load_module()

static int load_module ( void )

static

Definition at line 1253 of file test_jitterbuf.c.

{
    /* Nominal - put / get frames */
    AST_TEST_REGISTER(jitterbuffer_nominal_voice_frames);
    AST_TEST_REGISTER(jitterbuffer_nominal_control_frames);
 
    /* Out of order frame arrival */
    AST_TEST_REGISTER(jitterbuffer_out_of_order_voice);
    AST_TEST_REGISTER(jitterbuffer_out_of_order_control);
 
    /* Lost frame arrival */
    AST_TEST_REGISTER(jitterbuffer_lost_voice);
    AST_TEST_REGISTER(jitterbuffer_lost_control);
 
    /* Late frame arrival */
    AST_TEST_REGISTER(jitterbuffer_late_voice);
    AST_TEST_REGISTER(jitterbuffer_late_control);
 
    /* Buffer overflow */
    AST_TEST_REGISTER(jitterbuffer_overflow_voice);
    AST_TEST_REGISTER(jitterbuffer_overflow_control);
 
    /* Buffer resynch */
    AST_TEST_REGISTER(jitterbuffer_resynch_voice);
    AST_TEST_REGISTER(jitterbuffer_resynch_control);
 
    return AST_MODULE_LOAD_SUCCESS;
}

References AST_MODULE_LOAD_SUCCESS, and AST_TEST_REGISTER.

◆ test_jb_debug_output()

static void test_jb_debug_output	(	const char *	fmt,
			...
	)

static

Definition at line 117 of file test_jitterbuf.c.

{
    va_list args;
    char buf[1024];
 
    va_start(args, fmt);
    vsnprintf(buf, sizeof(buf), fmt, args);
    va_end(args);
 
    ast_debug(1, "%s", buf);
}

References args, ast_debug, and buf.

◆ test_jb_error_output()

static void test_jb_error_output	(	const char *	fmt,
			...
	)

static

Definition at line 149 of file test_jitterbuf.c.

{
    va_list args;
    char buf[1024];
 
    va_start(args, fmt);
    vsnprintf(buf, sizeof(buf), fmt, args);
    va_end(args);
 
    ast_log(AST_LOG_ERROR, "%s", buf);
}

References args, ast_log, AST_LOG_ERROR, and buf.

◆ test_jb_late_frame_insertion()

static int test_jb_late_frame_insertion	(	struct ast_test *	test,
		struct jitterbuf *	jb,
		enum jb_frame_type	frame_type
	)

static

Definition at line 734 of file test_jitterbuf.c.

{
    int i = 0, ret = 0;
 
    for (i = 0; i < 40; i++) {
        if (i % 5 == 0) {
            /* Add 5th frame */
            if (jb_put(jb, NULL, frame_type, 20, i * 20, i * 20 + 20) == JB_DROP) {
                ast_test_status_update(test, "Jitter buffer dropped packet %d\n", (i+1));
                ret = 1;
                break;
            }
        } else {
            if (jb_put(jb, NULL, frame_type, 20, i * 20, i * 20 + 5) == JB_DROP) {
                ast_test_status_update(test, "Jitter buffer dropped packet %d\n", i);
                ret = 1;
                break;
            }
        }
    }
 
    return ret;
}

References ast_test_status_update, JB_DROP, jb_put(), and NULL.

Referenced by AST_TEST_DEFINE().

◆ test_jb_lost_frame_insertion()

static int test_jb_lost_frame_insertion	(	struct ast_test *	test,
		struct jitterbuf *	jb,
		enum jb_frame_type	frame_type
	)

static

Definition at line 540 of file test_jitterbuf.c.

{
    int i = 0, ret = 0;
 
    for (i = 0; i < 40; i++) {
        if (i % 5 == 0) {
            i++;
        }
        if (jb_put(jb, NULL, frame_type, 20, i * 20, i * 20 + 5) == JB_DROP) {
            ast_test_status_update(test, "Jitter buffer dropped packet %d\n", i);
            ret = 1;
            break;
        }
    }
 
    return ret;
}

References ast_test_status_update, JB_DROP, jb_put(), and NULL.

Referenced by AST_TEST_DEFINE().

◆ test_jb_nominal_frame_insertion()

static int test_jb_nominal_frame_insertion	(	struct ast_test *	test,
		struct jitterbuf *	jb,
		enum jb_frame_type	frame_type
	)

static

Definition at line 165 of file test_jitterbuf.c.

{
    int i = 0, ret = 0;
 
    for (i = 0; i < 40; i++) {
        if (jb_put(jb, NULL, frame_type, 20, i * 20, i * 20 + 5) == JB_DROP) {
            ast_test_status_update(test, "Jitter buffer dropped packet %d\n", i);
            ret = 1;
            break;
        }
    }
 
    return ret;
}

References ast_test_status_update, JB_DROP, jb_put(), and NULL.

Referenced by AST_TEST_DEFINE().

◆ test_jb_out_of_order_frame_insertion()

static int test_jb_out_of_order_frame_insertion	(	struct ast_test *	test,
		struct jitterbuf *	jb,
		enum jb_frame_type	frame_type
	)

static

Definition at line 343 of file test_jitterbuf.c.

{
    int i = 0, ret = 0;
 
    for (i = 0; i < 40; i++) {
        if (i % 4 == 0) {
            /* Add the next frame */
            if (jb_put(jb, NULL, frame_type, 20, (i + 1) * 20, (i + 1) * 20 + 5) == JB_DROP) {
                ast_test_status_update(test, "Jitter buffer dropped packet %d\n", (i+1));
                ret = 1;
                break;
            }
            /* Add the current frame */
            if (jb_put(jb, NULL, frame_type, 20, i * 20, i * 20 + 5) == JB_DROP) {
                ast_test_status_update(test, "Jitter buffer dropped packet %d\n", i);
                ret = 1;
                break;
            }
            i++;
        } else {
            if (jb_put(jb, NULL, frame_type, 20, i * 20, i * 20 + 5) == JB_DROP) {
                ast_test_status_update(test, "Jitter buffer dropped packet %d\n", i);
                ret = 1;
                break;
            }
        }
    }
 
    return ret;
}

References ast_test_status_update, JB_DROP, jb_put(), and NULL.

Referenced by AST_TEST_DEFINE().

◆ test_jb_overflow_frame_insertion()

static void test_jb_overflow_frame_insertion	(	struct jitterbuf *	jb,
		enum jb_frame_type	frame_type
	)

static

Definition at line 920 of file test_jitterbuf.c.

{
    int i = 0;
 
    for (i = 0; i < 100; i++) {
        jb_put(jb, NULL, frame_type, 20, i * 20, i * 20 + 5);
    }
}

References jb_put(), and NULL.

Referenced by AST_TEST_DEFINE().

◆ test_jb_populate_config()

static void test_jb_populate_config ( struct jb_conf * jbconf )

static

Definition at line 101 of file test_jitterbuf.c.

{
    if (!jbconf) {
        return;
    }
 
    jbconf->max_jitterbuf = DEFAULT_MAX_JITTERBUFFER;
    jbconf->resync_threshold = DEFAULT_RESYNCH_THRESHOLD;
    jbconf->max_contig_interp = DEFAULT_MAX_CONTIG_INTERP;
    jbconf->target_extra = 0;
}

References DEFAULT_MAX_CONTIG_INTERP, DEFAULT_MAX_JITTERBUFFER, DEFAULT_RESYNCH_THRESHOLD, jb_conf::max_contig_interp, jb_conf::max_jitterbuf, jb_conf::resync_threshold, and jb_conf::target_extra.

Referenced by AST_TEST_DEFINE().

◆ test_jb_resynch_frame_insertion()

static void test_jb_resynch_frame_insertion	(	struct jitterbuf *	jb,
		enum jb_frame_type	frame_type
	)

static

Definition at line 1072 of file test_jitterbuf.c.

{
    int i = 0;
 
    for (i = 0; i < 20; i++) {
        jb_put(jb, NULL, frame_type, 20, i * 20, i * 20 + 5);
    }
 
    for (i = 20; i < 40; i++) {
        jb_put(jb, NULL, frame_type, 20, i * 20 + 500, i * 20 + 5);
    }
}

References jb_put(), and NULL.

Referenced by AST_TEST_DEFINE().

◆ test_jb_warn_output()

static void test_jb_warn_output	(	const char *	fmt,
			...
	)

static

Definition at line 133 of file test_jitterbuf.c.

{
    va_list args;
    char buf[1024];
 
    va_start(args, fmt);
    vsnprintf(buf, sizeof(buf), fmt, args);
    va_end(args);
 
    ast_log(AST_LOG_WARNING, "%s", buf);
}

References args, ast_log, AST_LOG_WARNING, and buf.

◆ unload_module()

static int unload_module ( void )

static

Definition at line 1236 of file test_jitterbuf.c.

{
    AST_TEST_UNREGISTER(jitterbuffer_nominal_voice_frames);
    AST_TEST_UNREGISTER(jitterbuffer_nominal_control_frames);
    AST_TEST_UNREGISTER(jitterbuffer_out_of_order_voice);
    AST_TEST_UNREGISTER(jitterbuffer_out_of_order_control);
    AST_TEST_UNREGISTER(jitterbuffer_lost_voice);
    AST_TEST_UNREGISTER(jitterbuffer_lost_control);
    AST_TEST_UNREGISTER(jitterbuffer_late_voice);
    AST_TEST_UNREGISTER(jitterbuffer_late_control);
    AST_TEST_UNREGISTER(jitterbuffer_overflow_voice);
    AST_TEST_UNREGISTER(jitterbuffer_overflow_control);
    AST_TEST_UNREGISTER(jitterbuffer_resynch_voice);
    AST_TEST_UNREGISTER(jitterbuffer_resynch_control);
    return 0;
}

References AST_TEST_UNREGISTER.

Variable Documentation

◆ __mod_info

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "Jitter Buffer Tests" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = AST_BUILDOPT_SUM, .load = load_module, .unload = unload_module, .load_pri = AST_MODPRI_DEFAULT, .support_level = AST_MODULE_SUPPORT_CORE, }

static

Definition at line 1282 of file test_jitterbuf.c.

◆ ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info

static

Definition at line 1282 of file test_jitterbuf.c.

◆ jitter_buffer_return_codes

const char* jitter_buffer_return_codes[]

static

Definition at line 88 of file test_jitterbuf.c.

Referenced by AST_TEST_DEFINE().

Macros

Functions

Variables

Detailed Description

Macro Definition Documentation

◆ DEFAULT_CODEC_INTERP_LEN

◆ DEFAULT_MAX_CONTIG_INTERP

◆ DEFAULT_MAX_JITTERBUFFER

◆ DEFAULT_RESYNCH_THRESHOLD

◆ DEFAULT_TARGET_EXTRA

◆ JB_INFO_PRINT_FRAME_DEBUG

◆ JB_NUMERIC_TEST

◆ JB_TEST_BEGIN

◆ JB_TEST_END

Function Documentation

◆ __reg_module()

◆ __unreg_module()

◆ AST_MODULE_SELF_SYM()

◆ AST_TEST_DEFINE() [1/12]

◆ AST_TEST_DEFINE() [2/12]

◆ AST_TEST_DEFINE() [3/12]

◆ AST_TEST_DEFINE() [4/12]

◆ AST_TEST_DEFINE() [5/12]

◆ AST_TEST_DEFINE() [6/12]

◆ AST_TEST_DEFINE() [7/12]

◆ AST_TEST_DEFINE() [8/12]

◆ AST_TEST_DEFINE() [9/12]

◆ AST_TEST_DEFINE() [10/12]

◆ AST_TEST_DEFINE() [11/12]

◆ AST_TEST_DEFINE() [12/12]

◆ load_module()

◆ test_jb_debug_output()

◆ test_jb_error_output()

◆ test_jb_late_frame_insertion()

◆ test_jb_lost_frame_insertion()

◆ test_jb_nominal_frame_insertion()

◆ test_jb_out_of_order_frame_insertion()

◆ test_jb_overflow_frame_insertion()

◆ test_jb_populate_config()

◆ test_jb_resynch_frame_insertion()

◆ test_jb_warn_output()

◆ unload_module()

Variable Documentation

◆ __mod_info

◆ ast_module_info

◆ jitter_buffer_return_codes