test_jitterbuf.c File Reference

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 = ASTERISK_GPL_KEY , .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.

                                             { \
    ast_debug(1, "JitterBuffer Frame Info:\n" \
        "\tFrames In: %ld\n\tFrames Out: %ld\n" \
        "\tDropped Frames: %ld\n\tLate Frames: %ld\n" \
        "\tLost Frames: %ld\n\tOut of Order Frames: %ld\n" \
        "\tCurrent Frame: %ld\n", jbinfo.frames_in, jbinfo.frames_out, \
        jbinfo.frames_dropped, jbinfo.frames_late, jbinfo.frames_lost, \
        jbinfo.frames_ooo, jbinfo.frames_cur); \
} while (0)

JB_NUMERIC_TEST

#define JB_NUMERIC_TEST	(		attribute,
			expected
	)

Definition at line 50 of file test_jitterbuf.c.

                                                { \
    if ((attribute) != (expected)) { \
        ast_test_status_update(test, #attribute ": expected [%ld]; actual [%ld]\n", (long int)(expected), (attribute)); \
        goto cleanup; \
    } \
} while (0)

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_setoutput(test_jb_error_output, test_jb_warn_output, test_jb_debug_output); \
    ast_debug(1, "Starting %s\n", test_name); \
} while (0)

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.

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

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, 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, 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, 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, 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, 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, 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, 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, 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, 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, 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, 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, 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(), and 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(), and 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(), and 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(), and 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(), and 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(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), and 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(), and 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 = ASTERISK_GPL_KEY , .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.

                                                  {
    "JB_OK",            /* 0 */
    "JB_EMPTY",         /* 1 */
    "JB_NOFRAME",       /* 2 */
    "JB_INTERP",        /* 3 */
    "JB_DROP",          /* 4 */
    "JB_SCHED"          /* 5 */
};

Referenced by AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), and AST_TEST_DEFINE().