app_forkcdr.c File Reference

Fork CDR application. More...

#include "asterisk.h"
#include "asterisk/file.h"
#include "asterisk/channel.h"
#include "asterisk/pbx.h"
#include "asterisk/cdr.h"
#include "asterisk/app.h"
#include "asterisk/module.h"
#include "asterisk/stasis.h"
#include "asterisk/stasis_message_router.h"

Include dependency graph for app_forkcdr.c:

Go to the source code of this file.

Data Structures
struct	fork_cdr_message_payload

Functions
static void	__reg_module (void)
static void	__unreg_module (void)
struct ast_module *	AST_MODULE_SELF_SYM (void)
static void	forkcdr_callback (void *data, struct stasis_subscription *sub, struct stasis_message *message)
static int	forkcdr_exec (struct ast_channel *chan, const char *data)
static int	load_module (void)
	STASIS_MESSAGE_TYPE_DEFN_LOCAL (forkcdr_message_type)
static int	unload_module (void)

Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_DEFAULT , .description = "Fork The CDR into 2 separate entities" , .key = ASTERISK_GPL_KEY , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_CORE, .load = load_module, .unload = unload_module, .requires = "cdr", }
static char *	app = "ForkCDR"
static const struct ast_module_info *	ast_module_info = &__mod_info
static const struct ast_app_option	forkcdr_exec_options [128] = { [ 'a' ] = { .flag = AST_CDR_FLAG_SET_ANSWER }, [ 'e' ] = { .flag = AST_CDR_FLAG_FINALIZE }, [ 'r' ] = { .flag = AST_CDR_FLAG_RESET }, [ 'v' ] = { .flag = AST_CDR_FLAG_KEEP_VARS }, }

Detailed Description

Fork CDR application.

Author

Anthony Minessale anthm.nosp@m.ct@y.nosp@m.ahoo..nosp@m.com

Note

Development of this app Sponsored/Funded by TAAN Softworks Corp

Definition in file app_forkcdr.c.

Function Documentation

__reg_module()

static void __reg_module ( void  )

static

Definition at line 226 of file app_forkcdr.c.

__unreg_module()

static void __unreg_module ( void  )

static

Definition at line 226 of file app_forkcdr.c.

AST_MODULE_SELF_SYM()

struct ast_module * AST_MODULE_SELF_SYM

(

void

)

Definition at line 226 of file app_forkcdr.c.

forkcdr_callback()

static void forkcdr_callback ( void *  data, struct stasis_subscription *  sub, struct stasis_message *  message  )

static

Definition at line 118 of file app_forkcdr.c.

{
    struct fork_cdr_message_payload *payload;
 
    if (stasis_message_type(message) != forkcdr_message_type()) {
        return;
    }
 
    payload = stasis_message_data(message);
    if (!payload) {
        return;
    }
 
    if (ast_cdr_fork(payload->channel_name, payload->flags)) {
        ast_log(AST_LOG_WARNING, "Failed to fork CDR for channel %s\n",
            payload->channel_name);
    }
}

References ast_cdr_fork(), ast_log, AST_LOG_WARNING, fork_cdr_message_payload::channel_name, fork_cdr_message_payload::flags, and stasis_message_data().

Referenced by load_module().

forkcdr_exec()

static int forkcdr_exec ( struct ast_channel *  chan, const char *  data  )

static

Definition at line 137 of file app_forkcdr.c.

{
    RAII_VAR(struct stasis_message *, message, NULL, ao2_cleanup);
    RAII_VAR(struct fork_cdr_message_payload *, payload, NULL, ao2_cleanup);
    RAII_VAR(struct stasis_message_router *, router, ast_cdr_message_router(), ao2_cleanup);
 
    char *parse;
    struct ast_flags flags = { 0, };
    AST_DECLARE_APP_ARGS(args,
        AST_APP_ARG(options);
    );
 
    parse = ast_strdupa(data);
 
    AST_STANDARD_APP_ARGS(args, parse);
 
    if (!ast_strlen_zero(args.options)) {
        ast_app_parse_options(forkcdr_exec_options, &flags, NULL, args.options);
    }
 
    if (!forkcdr_message_type()) {
        ast_log(AST_LOG_WARNING, "Failed to manipulate CDR for channel %s: no message type\n",
            ast_channel_name(chan));
        return -1;
    }
 
    payload = ao2_alloc(sizeof(*payload), NULL);
    if (!payload) {
        return -1;
    }
 
    if (!router) {
        ast_log(AST_LOG_WARNING, "Failed to manipulate CDR for channel %s: no message router\n",
            ast_channel_name(chan));
        return -1;
    }
 
    payload->channel_name = ast_channel_name(chan);
    payload->flags = &flags;
    message = stasis_message_create(forkcdr_message_type(), payload);
    if (!message) {
        ast_log(AST_LOG_WARNING, "Failed to fork CDR for channel %s: unable to create message\n",
            ast_channel_name(chan));
        return -1;
    }
    stasis_message_router_publish_sync(router, message);
 
    return 0;
}

References ao2_alloc, ao2_cleanup, args, AST_APP_ARG, ast_app_parse_options(), ast_cdr_message_router(), ast_channel_name(), AST_DECLARE_APP_ARGS, ast_log, AST_LOG_WARNING, AST_STANDARD_APP_ARGS, ast_strdupa, ast_strlen_zero(), ast_flags::flags, forkcdr_exec_options, NULL, options, RAII_VAR, router, stasis_message_create(), and stasis_message_router_publish_sync().

Referenced by load_module().

load_module()

static int load_module ( void  )

static

Definition at line 199 of file app_forkcdr.c.

{
    RAII_VAR(struct stasis_message_router *, router, ast_cdr_message_router(), ao2_cleanup);
    int res = 0;
 
    if (!router) {
        return AST_MODULE_LOAD_DECLINE;
    }
 
    res |= STASIS_MESSAGE_TYPE_INIT(forkcdr_message_type);
    res |= ast_register_application_xml(app, forkcdr_exec);
    res |= stasis_message_router_add(router, forkcdr_message_type(),
                                     forkcdr_callback, NULL);
 
    if (res) {
        unload_module();
 
        return AST_MODULE_LOAD_DECLINE;
    }
    return AST_MODULE_LOAD_SUCCESS;
}

References ao2_cleanup, app, ast_cdr_message_router(), AST_MODULE_LOAD_DECLINE, AST_MODULE_LOAD_SUCCESS, ast_register_application_xml, forkcdr_callback(), forkcdr_exec(), NULL, RAII_VAR, router, stasis_message_router_add(), STASIS_MESSAGE_TYPE_INIT, and unload_module().

STASIS_MESSAGE_TYPE_DEFN_LOCAL()

STASIS_MESSAGE_TYPE_DEFN_LOCAL

(

forkcdr_message_type

)

unload_module()

static int unload_module ( void  )

static

Definition at line 187 of file app_forkcdr.c.

{
    RAII_VAR(struct stasis_message_router *, router, ast_cdr_message_router(), ao2_cleanup);
 
    if (router) {
        stasis_message_router_remove(router, forkcdr_message_type());
    }
    STASIS_MESSAGE_TYPE_CLEANUP(forkcdr_message_type);
    ast_unregister_application(app);
    return 0;
}

References ao2_cleanup, app, ast_cdr_message_router(), ast_unregister_application(), RAII_VAR, router, stasis_message_router_remove(), and STASIS_MESSAGE_TYPE_CLEANUP.

Referenced by load_module().

Variable Documentation

__mod_info

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_DEFAULT , .description = "Fork The CDR into 2 separate entities" , .key = ASTERISK_GPL_KEY , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_CORE, .load = load_module, .unload = unload_module, .requires = "cdr", }

static

Definition at line 226 of file app_forkcdr.c.

app

char* app = "ForkCDR"

static

Definition at line 99 of file app_forkcdr.c.

Referenced by load_module(), and unload_module().

ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info

static

Definition at line 226 of file app_forkcdr.c.

forkcdr_exec_options

const struct ast_app_option forkcdr_exec_options[128] = { [ 'a' ] = { .flag = AST_CDR_FLAG_SET_ANSWER }, [ 'e' ] = { .flag = AST_CDR_FLAG_FINALIZE }, [ 'r' ] = { .flag = AST_CDR_FLAG_RESET }, [ 'v' ] = { .flag = AST_CDR_FLAG_KEEP_VARS }, }

static

Definition at line 106 of file app_forkcdr.c.

Referenced by forkcdr_exec().