Custom SQLite3 CDR records. More...

#include "asterisk.h"
#include <sqlite3.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/cli.h"
#include "asterisk/app.h"

Include dependency graph for cdr_sqlite3_custom.c:

Go to the source code of this file.

Data Structures
struct	sql_values

struct	values

Functions
static void	free_config (int reload)

static int	load_column_config (const char *tmp)

static int	load_values_config (const char *tmp)

Variables
static int	busy_timeout

static char *	columns

static const char	config_file [] = "cdr_sqlite3_custom.conf"

static sqlite3 *	db = NULL

static const char	desc [] = "Customizable SQLite3 CDR Backend"

static ast_mutex_t	lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }

static const char	name [] = "cdr_sqlite3_custom"

static struct sql_values	sql_values = { .first = NULL, .last = NULL, .lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} } , }

static char	table [80]

Detailed Description

Custom SQLite3 CDR records.

Author: Adapted by Alejandro Rios aleja.nosp@m.ndro.nosp@m..rios.nosp@m.@ava.nosp@m.tar.c.nosp@m.om.c.nosp@m.o and Russell Bryant russe.nosp@m.ll@d.nosp@m.igium.nosp@m..com from cdr_mysql_custom by Edward Eastman ed@dm.nosp@m.3.co.nosp@m..uk, and cdr_sqlite by Holger Schurig hs423.nosp@m.3@ma.nosp@m.il.mn.nosp@m.-sol.nosp@m.ution.nosp@m.s.de

See also CDR - Call Data Records and billing

Definition in file cdr_sqlite3_custom.c.

Function Documentation

◆ free_config()

static void free_config ( int reload )

static

Referenced by load_values_config().

◆ load_column_config()

static int load_column_config ( const char * tmp )

static

Definition at line 75 of file cdr_sqlite3_custom.c.

References ast_free, ast_log, ast_str_append(), ast_str_buffer(), ast_str_create, ast_str_strlen(), ast_strdup, ast_strip(), ast_strlen_zero, LOG_ERROR, LOG_WARNING, NULL, strsep(), and table.

Referenced by load_values_config().

 {
    char *col = NULL;
    char *cols = NULL, *save = NULL;
    char *escaped = NULL;
    struct ast_str *column_string = NULL;
 
    if (ast_strlen_zero(tmp)) {
       ast_log(LOG_WARNING, "Column names not specified. Module not loaded.\n");
       return -1;
    }
    if (!(column_string = ast_str_create(1024))) {
       ast_log(LOG_ERROR, "Out of memory creating temporary buffer for column list for table '%s.'\n", table);
       return -1;
    }
    if (!(save = cols = ast_strdup(tmp))) {
       ast_log(LOG_ERROR, "Out of memory creating temporary buffer for column list for table '%s.'\n", table);
       ast_free(column_string);
       return -1;
    }
    while ((col = strsep(&cols, ","))) {
       col = ast_strip(col);
       escaped = sqlite3_mprintf("%q", col);
       if (!escaped) {
          ast_log(LOG_ERROR, "Out of memory creating entry for column '%s' in table '%s.'\n", col, table);
          ast_free(column_string);
          ast_free(save);
          return -1;
       }
       ast_str_append(&column_string, 0, "%s%s", ast_str_strlen(column_string) ? "," : "", escaped);
       sqlite3_free(escaped);
    }
    if (!(columns = ast_strdup(ast_str_buffer(column_string)))) {
       ast_log(LOG_ERROR, "Out of memory copying columns string for table '%s.'\n", table);
       ast_free(column_string);
       ast_free(save);
       return -1;
    }
    ast_free(column_string);
    ast_free(save);
 
    return 0;
 }