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	__init_custom_buf (void)
static void	__reg_module (void)
static void	__unreg_module (void)
struct ast_module *	AST_MODULE_SELF_SYM (void)
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 = "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, .reload = reload, .load_pri = AST_MODPRI_CDR_DRIVER, .requires = "cdr", }
static const struct ast_module_info *	ast_module_info = &__mod_info
static struct ast_threadstorage	custom_buf = { .once = PTHREAD_ONCE_INIT , .key_init = __init_custom_buf , .custom_init = NULL , }
static const char	name [] = "cdr-custom"
static struct sinks	sinks = { .first = NULL, .last = NULL, .lock = { PTHREAD_RWLOCK_INITIALIZER , NULL, {1, 0} } , }

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

__init_custom_buf()

static void __init_custom_buf ( void  )

static

Definition at line 63 of file cdr_custom.c.

{

__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.

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 subsitution.\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, custom_buf, dummy(), errno, 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, 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::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 = "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, .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.

custom_buf

struct ast_threadstorage custom_buf = { .once = PTHREAD_ONCE_INIT , .key_init = __init_custom_buf , .custom_init = NULL , }

static

Definition at line 63 of file cdr_custom.c.

Referenced by custom_log().

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 = { .first = NULL, .last = NULL, .lock = { PTHREAD_RWLOCK_INITIALIZER , NULL, {1, 0} } , }

static