test_aeap_transaction.c File Reference

#include "asterisk.h"
#include <pthread.h>
#include "asterisk/lock.h"
#include "asterisk/test.h"
#include "asterisk/module.h"
#include "asterisk/res_aeap.h"
#include "asterisk/res_aeap_message.h"
#include "../res/res_aeap/general.h"
#include "../res/res_aeap/transaction.h"

Include dependency graph for test_aeap_transaction.c:

Go to the source code of this file.

Macros
#define	AEAP_TRANSACTION_ID   "foo"
#define	CATEGORY   "/res/aeap/transaction/"

Functions
static void	__reg_module (void)
static void	__unreg_module (void)
struct ast_module *	AST_MODULE_SELF_SYM (void)
	AST_TEST_DEFINE (transaction_exec)
	AST_TEST_DEFINE (transaction_exec_timeout)
static void *	end_transaction (void *data)
static enum ast_test_result_state	exec (struct ast_test *test, struct ast_aeap_tsx_params *params)
static void	handle_timeout (struct ast_aeap *aeap, struct ast_aeap_message *msg, void *obj)
static int	load_module (void)
static int	unload_module (void)

Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_DEFAULT , .description = "Asterisk External Application Protocol Transaction Tests" , .key = ASTERISK_GPL_KEY , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_CORE, .load = load_module, .unload = unload_module, .requires = "res_aeap", }
static const struct ast_module_info *	ast_module_info = &__mod_info

Macro Definition Documentation

AEAP_TRANSACTION_ID

#define AEAP_TRANSACTION_ID   "foo"

Definition at line 40 of file test_aeap_transaction.c.

CATEGORY

#define CATEGORY   "/res/aeap/transaction/"

Definition at line 38 of file test_aeap_transaction.c.

Function Documentation

__reg_module()

static void __reg_module ( void  )

static

Definition at line 179 of file test_aeap_transaction.c.

__unreg_module()

static void __unreg_module ( void  )

static

Definition at line 179 of file test_aeap_transaction.c.

AST_MODULE_SELF_SYM()

struct ast_module * AST_MODULE_SELF_SYM

(

void

)

Definition at line 179 of file test_aeap_transaction.c.

AST_TEST_DEFINE() [1/2]

AST_TEST_DEFINE

(

transaction_exec

)

Definition at line 115 of file test_aeap_transaction.c.

{
    struct ast_aeap_tsx_params params = {
        .timeout = 5000, /* Give plenty of time for test thread to end */
    };
 
    switch (cmd) {
    case TEST_INIT:
        info->name = __func__;
        info->explicit_only = 0;
        info->category = CATEGORY;
        info->summary = "test creating a basic AEAP transaction request";
        info->description = info->summary;
        return AST_TEST_NOT_RUN;
    case TEST_EXECUTE:
        break;
    }
 
    return exec(test, &params);
}

References AST_TEST_NOT_RUN, CATEGORY, exec(), TEST_EXECUTE, TEST_INIT, and ast_aeap_tsx_params::timeout.

AST_TEST_DEFINE() [2/2]

AST_TEST_DEFINE

(

transaction_exec_timeout

)

Definition at line 136 of file test_aeap_transaction.c.

{
    struct ast_aeap_tsx_params params = {
        .timeout = 100, /* Ensure timeout occurs before test thread ends */
        .on_timeout = handle_timeout,
    };
 
    switch (cmd) {
    case TEST_INIT:
        info->name = __func__;
        info->explicit_only = 0;
        info->category = CATEGORY;
        info->summary = "test creating a AEAP transaction request that times out";
        info->description = info->summary;
        return AST_TEST_NOT_RUN;
    case TEST_EXECUTE:
        break;
    }
 
    return exec(test, &params);
}

References AST_TEST_NOT_RUN, CATEGORY, exec(), handle_timeout(), TEST_EXECUTE, TEST_INIT, and ast_aeap_tsx_params::timeout.

end_transaction()

static void * end_transaction ( void *  data )

static

Definition at line 49 of file test_aeap_transaction.c.

{
    /* Delay a second before ending transaction */
    struct timespec delay = { 1, 0 };
    int *passed = aeap_transaction_user_obj(data);
 
    while (nanosleep(&delay, &delay));
 
    ++*passed;
    aeap_transaction_end(data, 0);
 
    return NULL;
}

References aeap_transaction_end(), aeap_transaction_user_obj(), and NULL.

Referenced by exec().

exec()

static enum ast_test_result_state exec ( struct ast_test *  test, struct ast_aeap_tsx_params *  params  )

static

Definition at line 63 of file test_aeap_transaction.c.

{
    pthread_t thread_id = AST_PTHREADT_NULL;
    struct ao2_container *tsxs = NULL;
    struct aeap_transaction *tsx = NULL;
    enum ast_test_result_state res = AST_TEST_FAIL;
    int passed = 0;
 
    tsxs = aeap_transactions_create();
    if (!tsxs) {
        ast_test_status_update(test, "Failed to create transactions object\n");
        goto exec_cleanup;
    }
 
    params->wait = 1;
    params->obj = &passed;
 
    tsx = aeap_transaction_create_and_add(tsxs, AEAP_TRANSACTION_ID, params, NULL);
    if (!tsx) {
        ast_test_status_update(test, "Failed to create transaction object\n");
        goto exec_cleanup;
    }
 
    if (ast_pthread_create(&thread_id, NULL, end_transaction, ao2_bump(tsx))) {
        ast_test_status_update(test, "Failed to create response thread\n");
        ao2_ref(tsx, -1);
        goto exec_cleanup;
    }
 
    if (aeap_transaction_start(tsx)) {
        ast_test_status_update(test, "Failed to start transaction request\n");
        goto exec_cleanup;
    }
 
    if (passed == 1) {
        res = AST_TEST_PASS;
    }
 
exec_cleanup:
 
    if (thread_id != AST_PTHREADT_NULL) {
        pthread_cancel(thread_id);
        pthread_join(thread_id, NULL);
    }
 
    aeap_transaction_end(tsx, 0);
    ao2_cleanup(tsxs);
 
    return res;
}

References aeap_transaction_create_and_add(), aeap_transaction_end(), AEAP_TRANSACTION_ID, aeap_transaction_start(), aeap_transactions_create(), ao2_bump, ao2_cleanup, ao2_ref, ast_pthread_create, AST_PTHREADT_NULL, AST_TEST_FAIL, AST_TEST_PASS, ast_test_status_update, end_transaction(), NULL, ast_aeap_tsx_params::obj, aeap_transaction::params, and ast_aeap_tsx_params::wait.

Referenced by AST_TEST_DEFINE(), and AST_TEST_DEFINE().

handle_timeout()

static void handle_timeout ( struct ast_aeap *  aeap, struct ast_aeap_message *  msg, void *  obj  )

static

Definition at line 42 of file test_aeap_transaction.c.

{
    int *passed = obj;
 
    ++*passed;
}

Referenced by AST_TEST_DEFINE().

load_module()

static int load_module ( void  )

static

Definition at line 158 of file test_aeap_transaction.c.

{
    AST_TEST_REGISTER(transaction_exec);
    AST_TEST_REGISTER(transaction_exec_timeout);
 
    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 166 of file test_aeap_transaction.c.

{
    AST_TEST_UNREGISTER(transaction_exec_timeout);
    AST_TEST_UNREGISTER(transaction_exec);
 
    return 0;
}

References AST_TEST_UNREGISTER.

Variable Documentation

__mod_info

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_DEFAULT , .description = "Asterisk External Application Protocol Transaction Tests" , .key = ASTERISK_GPL_KEY , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_CORE, .load = load_module, .unload = unload_module, .requires = "res_aeap", }

static

Definition at line 179 of file test_aeap_transaction.c.

ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info

static

Definition at line 179 of file test_aeap_transaction.c.