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 = "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, .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(), sip_to_pjsip::info(), 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(), sip_to_pjsip::info(), 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().

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