test_db.c File Reference

AstDB Unit Tests. More...

#include "asterisk.h"
#include "asterisk/test.h"
#include "asterisk/module.h"
#include "asterisk/astdb.h"
#include "asterisk/logger.h"

Include dependency graph for test_db.c:

Go to the source code of this file.

Macros
#define	BASE   "astdbtest"
#define	FAM1   BASE "/" SUB1
#define	FAM2   BASE "/" SUB2
#define	STR_FILL_32   "abcdefghijklmnopqrstuvwxyz123456"
#define	SUB1   "one"
#define	SUB2   "two"

Enumerations
enum	{ FAMILY = 0 , KEY = 1 , VALUE = 2 }

Functions
static void	__reg_module (void)
static void	__unreg_module (void)
struct ast_module *	AST_MODULE_SELF_SYM (void)
	AST_TEST_DEFINE (gettree_deltree)
	AST_TEST_DEFINE (perftest)
	AST_TEST_DEFINE (put_get_del)
	AST_TEST_DEFINE (put_get_long)
static int	load_module (void)
static int	unload_module (void)

Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "AstDB test module" , .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	long_val [] = "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx"

Detailed Description

AstDB Unit Tests.

Author

Terry Wilson twils.nosp@m.on@d.nosp@m.igium.nosp@m..com

Definition in file test_db.c.

Macro Definition Documentation

BASE

#define BASE   "astdbtest"

FAM1

#define FAM1   BASE "/" SUB1

FAM2

#define FAM2   BASE "/" SUB2

STR_FILL_32

#define STR_FILL_32   "abcdefghijklmnopqrstuvwxyz123456"

SUB1

#define SUB1   "one"

SUB2

#define SUB2   "two"

Enumeration Type Documentation

anonymous enum

anonymous enum

Enumerator
FAMILY
KEY
VALUE

Definition at line 39 of file test_db.c.

     {
    FAMILY = 0,
    KEY    = 1,
    VALUE  = 2,
};

Function Documentation

__reg_module()

static void __reg_module ( void  )

static

Definition at line 320 of file test_db.c.

__unreg_module()

static void __unreg_module ( void  )

static

Definition at line 320 of file test_db.c.

AST_MODULE_SELF_SYM()

struct ast_module * AST_MODULE_SELF_SYM

(

void

)

Definition at line 320 of file test_db.c.

AST_TEST_DEFINE() [1/4]

AST_TEST_DEFINE

(

gettree_deltree

)

Definition at line 99 of file test_db.c.

{
    int res = AST_TEST_PASS;
    const char *inputs[][3] = {
#define BASE "astdbtest"
#define SUB1 "one"
#define SUB2 "two"
#define FAM1 BASE "/" SUB1
#define FAM2 BASE "/" SUB2
        {FAM1, "one", "blah"},
        {FAM1, "two", "bling"},
        {FAM1, "three", "blast"},
        {FAM2, "one", "blah"},
        {FAM2, "two", "bling"},
        {FAM2, "three", "blast"},
    };
    size_t x;
    struct ast_db_entry *dbes, *cur;
    int num_deleted;
 
    switch (cmd) {
    case TEST_INIT:
        info->name = "gettree_deltree";
        info->category = "/main/astdb/";
        info->summary = "ast_db_(gettree|deltree) unit test";
        info->description =
            "Ensures that the ast_db gettree and deltree functions work";
        return AST_TEST_NOT_RUN;
    case TEST_EXECUTE:
        break;
    }
 
    for (x = 0; x < ARRAY_LEN(inputs); x++) {
        if (ast_db_put(inputs[x][FAMILY], inputs[x][KEY], inputs[x][VALUE])) {
            ast_test_status_update(test, "Failed to put %s : %s : %s\n", inputs[x][FAMILY], inputs[x][KEY], inputs[x][VALUE]);
            res = AST_TEST_FAIL;
        }
    }
 
    if (!(dbes = ast_db_gettree(BASE, NULL))) {
        ast_test_status_update(test, "Failed to ast_db_gettree family %s\n", BASE);
        res = AST_TEST_FAIL;
    }
 
    for (cur = dbes, x = 0; cur; cur = cur->next, x++) {
        int found = 0;
        size_t z;
        for (z = 0; z < ARRAY_LEN(inputs); z++) {
            char buf[256];
            snprintf(buf, sizeof(buf), "/%s/%s", inputs[z][FAMILY], inputs[z][KEY]);
            if (!strcmp(buf, cur->key) && !strcmp(inputs[z][VALUE], cur->data)) {
                found = 1;
            }
        }
        if (!found) {
            ast_test_status_update(test, "inputs array has no entry for %s == %s\n", cur->key, cur->data);
            res = AST_TEST_FAIL;
        }
    }
 
    if (x != ARRAY_LEN(inputs)) {
        ast_test_status_update(test, "ast_db_gettree returned %zu entries when we expected %zu\n", x, ARRAY_LEN(inputs));
        res = AST_TEST_FAIL;
    }
 
    ast_db_freetree(dbes);
 
    if (!(dbes = ast_db_gettree(BASE, SUB1))) {
        ast_test_status_update(test, "Failed to ast_db_gettree for %s/%s\n", BASE, SUB1);
        res = AST_TEST_FAIL;
    }
 
    for (cur = dbes, x = 0; cur; cur = cur->next, x++) {
        int found = 0;
        size_t z;
        for (z = 0; z < ARRAY_LEN(inputs); z++) {
            char buf[256];
            snprintf(buf, sizeof(buf), "/%s/%s", inputs[z][FAMILY], inputs[z][KEY]);
            if (!strcmp(buf, cur->key) && !strcmp(inputs[z][VALUE], cur->data)) {
                found = 1;
            }
        }
        if (!found) {
            ast_test_status_update(test, "inputs array has no entry for %s == %s\n", cur->key, cur->data);
            res = AST_TEST_FAIL;
        }
    }
 
    if (x != (ARRAY_LEN(inputs) / 2)) {
        ast_test_status_update(test, "ast_db_gettree returned %zu entries when we expected %zu\n", x, ARRAY_LEN(inputs) / 2);
        res = AST_TEST_FAIL;
    }
 
    ast_db_freetree(dbes);
 
    if ((num_deleted = ast_db_deltree(BASE, SUB2)) != ARRAY_LEN(inputs) / 2) {
        ast_test_status_update(test, "Failed to deltree %s/%s, expected %zu deletions and got %d\n", BASE, SUB2, ARRAY_LEN(inputs) / 2, num_deleted);
        res = AST_TEST_FAIL;
    }
 
    if ((num_deleted = ast_db_deltree(BASE, NULL)) != ARRAY_LEN(inputs) / 2) {
        ast_test_status_update(test, "Failed to deltree %s, expected %zu deletions and got %d\n", BASE, ARRAY_LEN(inputs) / 2, num_deleted);
        res = AST_TEST_FAIL;
    }
 
    return res;
}

References ARRAY_LEN, ast_db_deltree(), ast_db_freetree(), ast_db_gettree(), ast_db_put(), AST_TEST_FAIL, AST_TEST_NOT_RUN, AST_TEST_PASS, ast_test_status_update, BASE, buf, ast_db_entry::data, FAM1, FAM2, FAMILY, ast_db_entry::key, KEY, ast_db_entry::next, NULL, SUB1, SUB2, TEST_EXECUTE, TEST_INIT, and VALUE.

AST_TEST_DEFINE() [2/4]

AST_TEST_DEFINE

(

perftest

)

Definition at line 207 of file test_db.c.

{
    int res = AST_TEST_PASS;
    size_t x;
    char buf[10];
 
    switch (cmd) {
    case TEST_INIT:
        info->name = "perftest";
        info->category = "/main/astdb/";
        info->summary = "astdb performance unit test";
        info->description =
            "Measure astdb performance";
        return AST_TEST_NOT_RUN;
    case TEST_EXECUTE:
        break;
    }
 
    for (x = 0; x < 100000; x++) {
        sprintf(buf, "%zu", x);
        ast_db_put("astdbtest", buf, buf);
    }
    ast_db_deltree("astdbtest", NULL);
 
    return res;
}

References ast_db_deltree(), ast_db_put(), AST_TEST_NOT_RUN, AST_TEST_PASS, buf, NULL, TEST_EXECUTE, and TEST_INIT.

AST_TEST_DEFINE() [3/4]

AST_TEST_DEFINE

(

put_get_del

)

Definition at line 49 of file test_db.c.

{
    int res = AST_TEST_PASS;
    const char *inputs[][3] = {
        {"family", "key", "value"},
        {"astdbtest", "a", "b"},
        {"astdbtest", "a", "a"},
        {"astdbtest", "b", "a"},
        {"astdbtest", "b", "b"},
        {"astdbtest", "b", "!@#$%^&*()|+-<>?"},
        {"astdbtest", long_val, "b"},
        {"astdbtest", "b", long_val},
        {"astdbtest", "!@#$%^&*()|+-<>?", "b"},
    };
    size_t x;
    char buf[sizeof(long_val)] = { 0, };
 
    switch (cmd) {
    case TEST_INIT:
        info->name = "put_get_del";
        info->category = "/main/astdb/";
        info->summary = "ast_db_(put|get|del) unit test";
        info->description =
            "Ensures that the ast_db put, get, and del functions work";
        return AST_TEST_NOT_RUN;
    case TEST_EXECUTE:
        break;
    }
 
    for (x = 0; x < ARRAY_LEN(inputs); x++) {
        if (ast_db_put(inputs[x][FAMILY], inputs[x][KEY], inputs[x][VALUE])) {
            ast_test_status_update(test, "Failed to put %s : %s : %s\n", inputs[x][FAMILY], inputs[x][KEY], inputs[x][VALUE]);
            res = AST_TEST_FAIL;
        }
        if (ast_db_get(inputs[x][FAMILY], inputs[x][KEY], buf, sizeof(buf))) {
            ast_test_status_update(test, "Failed to get %s : %s : %s\n", inputs[x][FAMILY], inputs[x][KEY], inputs[x][VALUE]);
            res = AST_TEST_FAIL;
        } else if (strcmp(buf, inputs[x][VALUE])) {
            ast_test_status_update(test, "Failed to match key '%s/%s' value '%s' to '%s'\n", inputs[x][FAMILY], inputs[x][KEY], inputs[x][VALUE], buf);
            res = AST_TEST_FAIL;
        }
        if (ast_db_del(inputs[x][FAMILY], inputs[x][KEY])) {
            ast_test_status_update(test, "Failed to del %s : %s\n", inputs[x][FAMILY], inputs[x][KEY]);
            res = AST_TEST_FAIL;
        }
    }
 
    return res;
}

References ARRAY_LEN, ast_db_del(), ast_db_get(), ast_db_put(), AST_TEST_FAIL, AST_TEST_NOT_RUN, AST_TEST_PASS, ast_test_status_update, buf, FAMILY, KEY, long_val, TEST_EXECUTE, TEST_INIT, and VALUE.

AST_TEST_DEFINE() [4/4]

AST_TEST_DEFINE

(

put_get_long

)

Definition at line 234 of file test_db.c.

{
    int res = AST_TEST_PASS;
    struct ast_str *s;
    struct ast_str *key;
    int i, j;
 
#define STR_FILL_32 "abcdefghijklmnopqrstuvwxyz123456"
 
    switch (cmd) {
    case TEST_INIT:
        info->name = "put_get_long";
        info->category = "/main/astdb/";
        info->summary = "ast_db_(put|get_allocated) unit test";
        info->description =
            "Ensures that the ast_db_put and ast_db_get_allocated functions work with log key and long data";
        return AST_TEST_NOT_RUN;
    case TEST_EXECUTE:
        break;
    }
 
    if (!(s = ast_str_create(4096))) {
        return AST_TEST_FAIL;
    }
 
    if (!(key = ast_str_create(512))) {
        return AST_TEST_FAIL;
    }
 
    for (j = 0; j < 512; j += sizeof(STR_FILL_32) - 1) {
        ast_str_append(&key, 0, "%s", STR_FILL_32);
    }
 
    for (i = 1024; i <= 1024 * 1024 * 8; i *= 2) {
        char *out = NULL;
 
        ast_str_reset(s);
        ast_str_reset(key);
 
        for (j = 0; j < i; j += sizeof(STR_FILL_32) - 1) {
            ast_str_append(&s, 0, "%s", STR_FILL_32);
        }
 
        if (ast_db_put("astdbtest", ast_str_buffer(key), ast_str_buffer(s))) {
            ast_test_status_update(test, "Failed to put value of %zu bytes\n", ast_str_strlen(s));
            res = AST_TEST_FAIL;
        } else if (ast_db_get_allocated("astdbtest", ast_str_buffer(key), &out)) {
            ast_test_status_update(test, "Failed to get value of %zu bytes\n", ast_str_strlen(s));
            res = AST_TEST_FAIL;
        } else if (strcmp(ast_str_buffer(s), out)) {
            ast_test_status_update(test, "Failed to match value of %zu bytes\n", ast_str_strlen(s));
            res = AST_TEST_FAIL;
        } else if (ast_db_del("astdbtest", ast_str_buffer(key))) {
            ast_test_status_update(test, "Failed to delete astdbtest/long\n");
            res = AST_TEST_FAIL;
        }
 
        if (out) {
            ast_free(out);
        }
    }
 
    ast_free(s);
    ast_free(key);
 
    return res;
}

References ast_db_del(), ast_db_get_allocated(), ast_db_put(), ast_free, ast_str_append(), ast_str_buffer(), ast_str_create, ast_str_reset(), ast_str_strlen(), AST_TEST_FAIL, AST_TEST_NOT_RUN, AST_TEST_PASS, ast_test_status_update, NULL, out, STR_FILL_32, TEST_EXECUTE, and TEST_INIT.

load_module()

static int load_module ( void  )

static

Definition at line 311 of file test_db.c.

{
    AST_TEST_REGISTER(put_get_del);
    AST_TEST_REGISTER(gettree_deltree);
    AST_TEST_REGISTER(perftest);
    AST_TEST_REGISTER(put_get_long);
    return AST_MODULE_LOAD_SUCCESS;
}

References AST_MODULE_LOAD_SUCCESS, and AST_TEST_REGISTER.

unload_module()

static int unload_module ( void  )

static

Definition at line 302 of file test_db.c.

{
    AST_TEST_UNREGISTER(put_get_del);
    AST_TEST_UNREGISTER(gettree_deltree);
    AST_TEST_UNREGISTER(perftest);
    AST_TEST_UNREGISTER(put_get_long);
    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 = "AstDB test module" , .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 320 of file test_db.c.

ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info

static

Definition at line 320 of file test_db.c.

long_val

const char long_val[] = "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx"

static

Definition at line 47 of file test_db.c.

Referenced by AST_TEST_DEFINE().