cdr_custom.c File Reference

Custom Comma Separated Value CDR records. More...

#include "asterisk.h"
#include <time.h>
#include "asterisk/paths.h"
#include "asterisk/channel.h"
#include "asterisk/cdr.h"
#include "asterisk/module.h"
#include "asterisk/config.h"
#include "asterisk/pbx.h"
#include "asterisk/utils.h"
#include "asterisk/lock.h"
#include "asterisk/threadstorage.h"
#include "asterisk/strings.h"

Include dependency graph for cdr_custom.c:

Go to the source code of this file.

Data Structures
struct	cdr_custom_config
struct	sinks

Macros
#define	CONFIG   "cdr_custom.conf"

Functions
static void	__reg_module (void)
static void	__unreg_module (void)
struct ast_module *	AST_MODULE_SELF_SYM (void)
	AST_THREADSTORAGE_CUSTOM_SCOPE (custom_buf, NULL, ast_free_ptr, static)
static int	custom_log (struct ast_cdr *cdr)
static void	free_config (void)
static int	load_config (void)
static enum ast_module_load_result	load_module (void)
static int	reload (void)
static int	unload_module (void)

Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "Customizable Comma Separated Values CDR Backend" , .key = ASTERISK_GPL_KEY , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_CORE, .load = load_module, .unload = unload_module, .reload = reload, .load_pri = AST_MODPRI_CDR_DRIVER, .requires = "cdr", }
static const struct ast_module_info *	ast_module_info = &__mod_info
static const char	name [] = "cdr-custom"
static struct sinks	sinks = AST_RWLIST_HEAD_INIT_VALUE

Detailed Description

Custom Comma Separated Value CDR records.

Author

Mark Spencer marks.nosp@m.ter@.nosp@m.digiu.nosp@m.m.co.nosp@m.m

• See also CDR - Call Data Records and billing

Logs in LOG_DIR/cdr_custom

Definition in file cdr_custom.c.

Macro Definition Documentation

CONFIG

#define CONFIG   "cdr_custom.conf"

Definition at line 61 of file cdr_custom.c.

Function Documentation

__reg_module()

static void __reg_module ( void  )

static

Definition at line 238 of file cdr_custom.c.

__unreg_module()

static void __unreg_module ( void  )

static

Definition at line 238 of file cdr_custom.c.

AST_MODULE_SELF_SYM()

struct ast_module * AST_MODULE_SELF_SYM

(

void

)

Definition at line 238 of file cdr_custom.c.

AST_THREADSTORAGE_CUSTOM_SCOPE()

AST_THREADSTORAGE_CUSTOM_SCOPE	(	custom_buf	,
		NULL	,
		ast_free_ptr	,
		static
	)

custom_log()

static int custom_log ( struct ast_cdr *  cdr )

static

Definition at line 132 of file cdr_custom.c.

{
    struct ast_channel *dummy;
    struct ast_str *str;
    struct cdr_custom_config *config;
 
    /* Batching saves memory management here.  Otherwise, it's the same as doing an allocation and free each time. */
    if (!(str = ast_str_thread_get(&custom_buf, 16))) {
        return -1;
    }
 
    dummy = ast_dummy_channel_alloc();
    if (!dummy) {
        ast_log(LOG_ERROR, "Unable to allocate channel for variable substitution.\n");
        return -1;
    }
 
    /* We need to dup here since the cdr actually belongs to the other channel,
       so when we release this channel we don't want the CDR getting cleaned
       up prematurely. */
    ast_channel_cdr_set(dummy, ast_cdr_dup(cdr));
 
    AST_RWLIST_RDLOCK(&sinks);
 
    AST_LIST_TRAVERSE(&sinks, config, list) {
        FILE *out;
 
        ast_str_substitute_variables(&str, 0, dummy, config->format);
 
        /* Even though we have a lock on the list, we could be being chased by
           another thread and this lock ensures that we won't step on anyone's
           toes.  Once each CDR backend gets it's own thread, this lock can be
           removed. */
        ast_mutex_lock(&config->lock);
 
        /* Because of the absolutely unconditional need for the
           highest reliability possible in writing billing records,
           we open write and close the log file each time */
        if ((out = fopen(config->filename, "a"))) {
            fputs(ast_str_buffer(str), out);
            fflush(out); /* be particularly anal here */
            fclose(out);
        } else {
            ast_log(LOG_ERROR, "Unable to re-open master file %s : %s\n", config->filename, strerror(errno));
        }
 
        ast_mutex_unlock(&config->lock);
    }
 
    AST_RWLIST_UNLOCK(&sinks);
 
    ast_channel_unref(dummy);
 
    return 0;
}

References ast_cdr_dup(), ast_channel_cdr_set(), ast_channel_unref, ast_dummy_channel_alloc, AST_LIST_TRAVERSE, ast_log, ast_mutex_lock, ast_mutex_unlock, AST_RWLIST_RDLOCK, AST_RWLIST_UNLOCK, ast_str_buffer(), ast_str_substitute_variables(), ast_str_thread_get(), config, dummy(), errno, cdr_custom_config::list, LOG_ERROR, out, and str.

Referenced by load_module(), and unload_module().

free_config()

static void free_config ( void  )

static

Definition at line 78 of file cdr_custom.c.

{
    struct cdr_custom_config *sink;
 
    while ((sink = AST_RWLIST_REMOVE_HEAD(&sinks, list))) {
        ast_mutex_destroy(&sink->lock);
        ast_string_field_free_memory(sink);
        ast_free(sink);
    }
}

References ast_free, ast_mutex_destroy, AST_RWLIST_REMOVE_HEAD, ast_string_field_free_memory, cdr_custom_config::list, and cdr_custom_config::lock.

Referenced by reload(), and unload_module().

load_config()

static int load_config ( void  )

static

Definition at line 89 of file cdr_custom.c.

{
    struct ast_config *cfg;
    struct ast_variable *var;
    struct ast_flags config_flags = { 0 };
    int res = 0;
 
    cfg = ast_config_load(CONFIG, config_flags);
    if (!cfg || cfg == CONFIG_STATUS_FILEINVALID) {
        ast_log(LOG_ERROR, "Unable to load " CONFIG ". Not logging custom CSV CDRs.\n");
        return -1;
    }
 
    var = ast_variable_browse(cfg, "mappings");
    while (var) {
        if (!ast_strlen_zero(var->name) && !ast_strlen_zero(var->value)) {
            struct cdr_custom_config *sink = ast_calloc_with_stringfields(1, struct cdr_custom_config, 1024);
 
            if (!sink) {
                ast_log(LOG_ERROR, "Unable to allocate memory for configuration settings.\n");
                res = -2;
                break;
            }
 
            ast_string_field_build(sink, format, "%s\n", var->value);
            if (var->name[0] == '/') {
                ast_string_field_build(sink, filename, "%s", var->name);
            } else {
                ast_string_field_build(sink, filename, "%s/%s/%s", ast_config_AST_LOG_DIR, name, var->name);
            }
            ast_mutex_init(&sink->lock);
 
            AST_RWLIST_INSERT_TAIL(&sinks, sink, list);
        } else {
            ast_log(LOG_NOTICE, "Mapping must have both a filename and a format at line %d\n", var->lineno);
        }
        var = var->next;
    }
    ast_config_destroy(cfg);
 
    return res;
}

References ast_calloc_with_stringfields, ast_config_AST_LOG_DIR, ast_config_destroy(), ast_config_load, ast_log, ast_mutex_init, AST_RWLIST_INSERT_TAIL, ast_string_field_build, ast_strlen_zero(), ast_variable_browse(), CONFIG, CONFIG_STATUS_FILEINVALID, cdr_custom_config::filename, cdr_custom_config::format, cdr_custom_config::list, cdr_custom_config::lock, LOG_ERROR, LOG_NOTICE, name, and var.

Referenced by load_module(), and reload().

load_module()

static enum ast_module_load_result load_module ( void  )

static

Definition at line 205 of file cdr_custom.c.

{
    if (AST_RWLIST_WRLOCK(&sinks)) {
        ast_log(LOG_ERROR, "Unable to lock sink list.  Load failed.\n");
        return AST_MODULE_LOAD_DECLINE;
    }
 
    load_config();
    AST_RWLIST_UNLOCK(&sinks);
    ast_cdr_register(name, ast_module_info->description, custom_log);
    return AST_MODULE_LOAD_SUCCESS;
}

References ast_cdr_register(), ast_log, AST_MODULE_LOAD_DECLINE, AST_MODULE_LOAD_SUCCESS, AST_RWLIST_UNLOCK, AST_RWLIST_WRLOCK, custom_log(), ast_module_info::description, load_config(), LOG_ERROR, and name.

reload()

static int reload ( void  )

static

Definition at line 218 of file cdr_custom.c.

{
    if (AST_RWLIST_WRLOCK(&sinks)) {
        ast_log(LOG_ERROR, "Unable to lock sink list.  Load failed.\n");
        return AST_MODULE_LOAD_DECLINE;
    }
 
    free_config();
    load_config();
    AST_RWLIST_UNLOCK(&sinks);
    return AST_MODULE_LOAD_SUCCESS;
}

References ast_log, AST_MODULE_LOAD_DECLINE, AST_MODULE_LOAD_SUCCESS, AST_RWLIST_UNLOCK, AST_RWLIST_WRLOCK, free_config(), load_config(), and LOG_ERROR.

unload_module()

static int unload_module ( void  )

static

Definition at line 188 of file cdr_custom.c.

{
    if (ast_cdr_unregister(name)) {
        return -1;
    }
 
    if (AST_RWLIST_WRLOCK(&sinks)) {
        ast_cdr_register(name, ast_module_info->description, custom_log);
        ast_log(LOG_ERROR, "Unable to lock sink list.  Unload failed.\n");
        return -1;
    }
 
    free_config();
    AST_RWLIST_UNLOCK(&sinks);
    return 0;
}

References ast_cdr_register(), ast_cdr_unregister(), ast_log, AST_RWLIST_UNLOCK, AST_RWLIST_WRLOCK, custom_log(), ast_module_info::description, free_config(), LOG_ERROR, and name.

Variable Documentation

__mod_info

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "Customizable Comma Separated Values CDR Backend" , .key = ASTERISK_GPL_KEY , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_CORE, .load = load_module, .unload = unload_module, .reload = reload, .load_pri = AST_MODPRI_CDR_DRIVER, .requires = "cdr", }

static

Definition at line 238 of file cdr_custom.c.

ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info

static

Definition at line 238 of file cdr_custom.c.

name

const char name[] = "cdr-custom"

static

Definition at line 65 of file cdr_custom.c.

Referenced by load_config(), load_module(), and unload_module().

sinks

struct sinks sinks = AST_RWLIST_HEAD_INIT_VALUE

static