cdrel.h File Reference

Private header for res_cdrel_custom. More...

#include <sqlite3.h>
#include "asterisk.h"
#include "asterisk/cdr.h"
#include "asterisk/cel.h"
#include "asterisk/event.h"
#include "asterisk/lock.h"
#include "asterisk/strings.h"
#include "asterisk/vector.h"
#include "asterisk/res_cdrel_custom.h"

Include dependency graph for cdrel.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures
struct	cdrel_config
struct	cdrel_field
struct	cdrel_value
struct	cdrel_values

Macros
#define	AST_EVENT_IE_CEL_EVENT_ENUM   (AST_EVENT_IE_TOTAL + 2)
#define	AST_EVENT_IE_CEL_LITERAL   (AST_EVENT_IE_TOTAL + 1)
#define	CDR_FIELD(__cdr, __offset)   (((void *)__cdr) + __offset - CDR_OFFSET_SHIFT)
#define	CDR_OFFSET_SHIFT   (LAST_CEL_ID + 1)
#define	CDR_OFFSETOF(_field)   (offsetof(struct ast_cdr, _field) + CDR_OFFSET_SHIFT)
#define	CDREL_FIELD_FLAG_FORMAT_SPEC   (5)
#define	CDREL_FIELD_FLAG_LAST   (6)
#define	CDREL_FIELD_FLAG_LITERAL   (4)
#define	CDREL_FIELD_FLAG_NOQUOTE   (1)
#define	CDREL_FIELD_FLAG_QUOTE   (0)
#define	CDREL_FIELD_FLAG_TYPE_FORCED   (2)
#define	CDREL_FIELD_FLAG_USERVAR   (3)
#define	DATA_TYPE_STR(_dt)   (_dt < cdrel_data_type_end ? cdrel_data_type_map[_dt] : NULL)
#define	LAST_CEL_ID   AST_EVENT_IE_CEL_EVENT_ENUM
#define	MODULE_TYPE_STR(_mt)   (cdrel_module_type_map[_mt])
#define	RECORD_TYPE_STR(_rt)   (cdrel_record_type_map[_rt])

Typedefs
typedef int(*	cdrel_backend_writer) (struct cdrel_config *config, struct cdrel_values *values)
typedef struct ast_channel *(*	cdrel_dummy_channel_alloc) (struct cdrel_config *config, void *record)
typedef int(*	cdrel_field_formatter) (struct cdrel_config *config, struct cdrel_field *field, struct cdrel_value *input_value, struct cdrel_value *output_value)
typedef int(*	cdrel_field_getter) (void *record, struct cdrel_config *config, struct cdrel_field *field, struct cdrel_value *value)

Enumerations
enum	cdr_field_id {   cdr_field_literal = -1 , cdr_field_clid = CDR_OFFSETOF(clid) , cdr_field_src = CDR_OFFSETOF(src) , cdr_field_dst = CDR_OFFSETOF(dst) ,   cdr_field_dcontext = CDR_OFFSETOF(dcontext) , cdr_field_channel = CDR_OFFSETOF(channel) , cdr_field_dstchannel = CDR_OFFSETOF(dstchannel) , cdr_field_lastapp = CDR_OFFSETOF(lastapp) ,   cdr_field_lastdata = CDR_OFFSETOF(lastdata) , cdr_field_start = CDR_OFFSETOF(start) , cdr_field_answer = CDR_OFFSETOF(answer) , cdr_field_end = CDR_OFFSETOF(end) ,   cdr_field_duration = CDR_OFFSETOF(duration) , cdr_field_billsec = CDR_OFFSETOF(billsec) , cdr_field_disposition = CDR_OFFSETOF(disposition) , cdr_field_amaflags = CDR_OFFSETOF(amaflags) ,   cdr_field_accountcode = CDR_OFFSETOF(accountcode) , cdr_field_peeraccount = CDR_OFFSETOF(peeraccount) , cdr_field_flags = CDR_OFFSETOF(flags) , cdr_field_uniqueid = CDR_OFFSETOF(uniqueid) ,   cdr_field_linkedid = CDR_OFFSETOF(linkedid) , cdr_field_tenantid = CDR_OFFSETOF(tenantid) , cdr_field_peertenantid = CDR_OFFSETOF(peertenantid) , cdr_field_userfield = CDR_OFFSETOF(userfield) ,   cdr_field_sequence = CDR_OFFSETOF(sequence) , cdr_field_varshead = CDR_OFFSETOF(varshead) }
enum	cdrel_config_type { cdrel_config_legacy = 0 , cdrel_config_advanced , cdrel_config_type_end }
enum	cdrel_data_type {   cdrel_type_string = 0 , cdrel_type_timeval , cdrel_type_literal , cdrel_type_amaflags ,   cdrel_type_disposition , cdrel_type_uservar , cdrel_type_event_type , cdrel_type_event_enum ,   cdrel_type_cel_timefmt , cdrel_data_type_strings_end , cdrel_type_int32 , cdrel_type_uint32 ,   cdrel_type_int64 , cdrel_type_uint64 , cdrel_type_double , cdrel_data_type_end }
enum	cdrel_field_flags {   cdrel_flag_quote = (1 << CDREL_FIELD_FLAG_QUOTE) , cdrel_flag_noquote = (1 << CDREL_FIELD_FLAG_NOQUOTE) , cdrel_flag_type_forced = (1 << CDREL_FIELD_FLAG_TYPE_FORCED) , cdrel_flag_uservar = (1 << CDREL_FIELD_FLAG_USERVAR) ,   cdrel_flag_literal = (1 << CDREL_FIELD_FLAG_LITERAL) , cdrel_flag_format_spec = (1 << CDREL_FIELD_FLAG_FORMAT_SPEC) , cdrel_field_flags_end = (1 << CDREL_FIELD_FLAG_LAST) }
enum	cdrel_quoting_method {   cdrel_quoting_method_none = 0 , cdrel_quoting_method_all , cdrel_quoting_method_minimal , cdrel_quoting_method_non_numeric ,   cdrel_quoting_method_end }
enum	cdrel_text_format_type { cdrel_format_dsv = 0 , cdrel_format_json , cdrel_format_sql , cdrel_format_type_end }

Functions
const char *	cdrel_basename (const char *path)
enum cdrel_data_type	cdrel_data_type_from_str (const char *str)
const char *	cdrel_get_field_flags (struct ast_flags *flags, struct ast_str **str)
const struct cdrel_field *	get_registered_field_by_name (enum cdrel_record_type record_type, const char *name)
int	load_cdr (void)
int	load_cel (void)
int	load_formatters (void)
int	load_writers (void)
int	write_record_to_database (struct cdrel_config *config, struct cdrel_values *values)
int	write_record_to_file (struct cdrel_config *config, struct ast_str *record)

Variables
cdrel_backend_writer	cdrel_backend_writers [cdrel_format_type_end]
const char *	cdrel_data_type_map []
cdrel_dummy_channel_alloc	cdrel_dummy_channel_allocators [cdrel_format_type_end]
cdrel_field_formatter	cdrel_field_formatters [cdrel_data_type_end]
cdrel_field_getter	cdrel_field_getters [cdrel_record_type_end][cdrel_data_type_end]
const char *	cdrel_module_type_map []
const char *	cdrel_record_type_map []

Detailed Description

Private header for res_cdrel_custom.

Author

George Joseph gjose.nosp@m.ph@s.nosp@m.angom.nosp@m.a.co.nosp@m.m

Definition in file cdrel.h.

Macro Definition Documentation

AST_EVENT_IE_CEL_EVENT_ENUM

#define AST_EVENT_IE_CEL_EVENT_ENUM   (AST_EVENT_IE_TOTAL + 2)

Definition at line 119 of file cdrel.h.

AST_EVENT_IE_CEL_LITERAL

#define AST_EVENT_IE_CEL_LITERAL   (AST_EVENT_IE_TOTAL + 1)

Definition at line 118 of file cdrel.h.

CDR_FIELD

#define CDR_FIELD	(		__cdr,
			__offset
	)		(((void *)__cdr) + __offset - CDR_OFFSET_SHIFT)

Definition at line 135 of file cdrel.h.

CDR_OFFSET_SHIFT

#define CDR_OFFSET_SHIFT   (LAST_CEL_ID + 1)

While CEL event fields are published as a generic AST_EVENT with a field id assigned to each field, CDRs are published as a fixed ast_cdr structure. To make it easier to share lower level code, we assign pseudo-field-ids to each CDR field that are really the offset of the field in the structure. This allows us to generically get any field using its id just like we do for CEL.

To avoid conflicts with the existing CEL field ids, we'll start these after the last one.

Definition at line 133 of file cdrel.h.

CDR_OFFSETOF

#define CDR_OFFSETOF

(

_field

)

(offsetof(struct ast_cdr, _field) + CDR_OFFSET_SHIFT)

Definition at line 134 of file cdrel.h.

CDREL_FIELD_FLAG_FORMAT_SPEC

#define CDREL_FIELD_FLAG_FORMAT_SPEC   (5)

Definition at line 100 of file cdrel.h.

CDREL_FIELD_FLAG_LAST

#define CDREL_FIELD_FLAG_LAST   (6)

Definition at line 101 of file cdrel.h.

CDREL_FIELD_FLAG_LITERAL

#define CDREL_FIELD_FLAG_LITERAL   (4)

Definition at line 99 of file cdrel.h.

CDREL_FIELD_FLAG_NOQUOTE

#define CDREL_FIELD_FLAG_NOQUOTE   (1)

Definition at line 96 of file cdrel.h.

CDREL_FIELD_FLAG_QUOTE

#define CDREL_FIELD_FLAG_QUOTE   (0)

Definition at line 95 of file cdrel.h.

CDREL_FIELD_FLAG_TYPE_FORCED

#define CDREL_FIELD_FLAG_TYPE_FORCED   (2)

Definition at line 97 of file cdrel.h.

CDREL_FIELD_FLAG_USERVAR

#define CDREL_FIELD_FLAG_USERVAR   (3)

Definition at line 98 of file cdrel.h.

DATA_TYPE_STR

#define DATA_TYPE_STR

(

_dt

)

(_dt < cdrel_data_type_end ? cdrel_data_type_map[_dt] : NULL)

Definition at line 92 of file cdrel.h.

LAST_CEL_ID

#define LAST_CEL_ID   AST_EVENT_IE_CEL_EVENT_ENUM

Definition at line 120 of file cdrel.h.

MODULE_TYPE_STR

#define MODULE_TYPE_STR

(

_mt

)

(cdrel_module_type_map[_mt])

Definition at line 45 of file cdrel.h.

RECORD_TYPE_STR

#define RECORD_TYPE_STR

(

_rt

)

(cdrel_record_type_map[_rt])

Definition at line 42 of file cdrel.h.

Typedef Documentation

cdrel_backend_writer

typedef int(* cdrel_backend_writer) (struct cdrel_config *config, struct cdrel_values *values)

Definition at line 245 of file cdrel.h.

cdrel_dummy_channel_alloc

typedef struct ast_channel *(* cdrel_dummy_channel_alloc) (struct cdrel_config *config, void *record)

Definition at line 252 of file cdrel.h.

cdrel_field_formatter

typedef int(* cdrel_field_formatter) (struct cdrel_config *config, struct cdrel_field *field, struct cdrel_value *input_value, struct cdrel_value *output_value)

Definition at line 226 of file cdrel.h.

cdrel_field_getter

typedef int(* cdrel_field_getter) (void *record, struct cdrel_config *config, struct cdrel_field *field, struct cdrel_value *value)

Definition at line 205 of file cdrel.h.

Enumeration Type Documentation

cdr_field_id

enum cdr_field_id

Enumerator
cdr_field_literal
cdr_field_clid
cdr_field_src
cdr_field_dst
cdr_field_dcontext
cdr_field_channel
cdr_field_dstchannel
cdr_field_lastapp
cdr_field_lastdata
cdr_field_start
cdr_field_answer
cdr_field_end
cdr_field_duration
cdr_field_billsec
cdr_field_disposition
cdr_field_amaflags
cdr_field_accountcode
cdr_field_peeraccount
cdr_field_flags
cdr_field_uniqueid
cdr_field_linkedid
cdr_field_tenantid
cdr_field_peertenantid
cdr_field_userfield
cdr_field_sequence
cdr_field_varshead

Definition at line 137 of file cdrel.h.

                  {
    cdr_field_literal = -1,
    cdr_field_clid = CDR_OFFSETOF(clid),
    cdr_field_src = CDR_OFFSETOF(src),
    cdr_field_dst = CDR_OFFSETOF(dst),
    cdr_field_dcontext = CDR_OFFSETOF(dcontext),
    cdr_field_channel = CDR_OFFSETOF(channel),
    cdr_field_dstchannel = CDR_OFFSETOF(dstchannel),
    cdr_field_lastapp = CDR_OFFSETOF(lastapp),
    cdr_field_lastdata = CDR_OFFSETOF(lastdata),
    cdr_field_start = CDR_OFFSETOF(start),
    cdr_field_answer = CDR_OFFSETOF(answer),
    cdr_field_end = CDR_OFFSETOF(end),
    cdr_field_duration = CDR_OFFSETOF(duration),
    cdr_field_billsec = CDR_OFFSETOF(billsec),
    cdr_field_disposition = CDR_OFFSETOF(disposition),
    cdr_field_amaflags = CDR_OFFSETOF(amaflags),
    cdr_field_accountcode = CDR_OFFSETOF(accountcode),
    cdr_field_peeraccount = CDR_OFFSETOF(peeraccount),
    cdr_field_flags = CDR_OFFSETOF(flags),
    cdr_field_uniqueid = CDR_OFFSETOF(uniqueid),
    cdr_field_linkedid = CDR_OFFSETOF(linkedid),
    cdr_field_tenantid = CDR_OFFSETOF(tenantid),
    cdr_field_peertenantid = CDR_OFFSETOF(peertenantid),
    cdr_field_userfield = CDR_OFFSETOF(userfield),
    cdr_field_sequence = CDR_OFFSETOF(sequence),
    cdr_field_varshead = CDR_OFFSETOF(varshead),
};

cdrel_config_type

enum cdrel_config_type

Enumerator
cdrel_config_legacy
cdrel_config_advanced
cdrel_config_type_end

Definition at line 54 of file cdrel.h.

                       {
    cdrel_config_legacy = 0,
    cdrel_config_advanced,
    cdrel_config_type_end,
};

cdrel_data_type

enum cdrel_data_type

Enumerator
cdrel_type_string
cdrel_type_timeval
cdrel_type_literal
cdrel_type_amaflags
cdrel_type_disposition
cdrel_type_uservar
cdrel_type_event_type
cdrel_type_event_enum
cdrel_type_cel_timefmt
cdrel_data_type_strings_end
cdrel_type_int32
cdrel_type_uint32
cdrel_type_int64
cdrel_type_uint64
cdrel_type_double
cdrel_data_type_end

Definition at line 72 of file cdrel.h.

                     {
    cdrel_type_string = 0,
    cdrel_type_timeval,
    cdrel_type_literal,
    cdrel_type_amaflags,
    cdrel_type_disposition,
    cdrel_type_uservar,
    cdrel_type_event_type,
    cdrel_type_event_enum,
    cdrel_type_cel_timefmt,
    cdrel_data_type_strings_end,
    cdrel_type_int32,
    cdrel_type_uint32,
    cdrel_type_int64,
    cdrel_type_uint64,
    cdrel_type_double,
    cdrel_data_type_end
};

cdrel_field_flags

enum cdrel_field_flags

Enumerator
cdrel_flag_quote
cdrel_flag_noquote
cdrel_flag_type_forced
cdrel_flag_uservar
cdrel_flag_literal
cdrel_flag_format_spec
cdrel_field_flags_end

Definition at line 103 of file cdrel.h.

                       {
    cdrel_flag_quote = (1 << CDREL_FIELD_FLAG_QUOTE),
    cdrel_flag_noquote = (1 << CDREL_FIELD_FLAG_NOQUOTE),
    cdrel_flag_type_forced = (1 << CDREL_FIELD_FLAG_TYPE_FORCED),
    cdrel_flag_uservar = (1 << CDREL_FIELD_FLAG_USERVAR),
    cdrel_flag_literal = (1 << CDREL_FIELD_FLAG_LITERAL),
    cdrel_flag_format_spec = (1 << CDREL_FIELD_FLAG_FORMAT_SPEC),
    cdrel_field_flags_end = (1 << CDREL_FIELD_FLAG_LAST),
};

cdrel_quoting_method

enum cdrel_quoting_method

Enumerator
cdrel_quoting_method_none
cdrel_quoting_method_all
cdrel_quoting_method_minimal
cdrel_quoting_method_non_numeric
cdrel_quoting_method_end

Definition at line 60 of file cdrel.h.

                          {
    cdrel_quoting_method_none = 0,
    cdrel_quoting_method_all,
    cdrel_quoting_method_minimal,
    cdrel_quoting_method_non_numeric,
    cdrel_quoting_method_end,
};

cdrel_text_format_type

enum cdrel_text_format_type

Enumerator
cdrel_format_dsv
cdrel_format_json
cdrel_format_sql
cdrel_format_type_end

Definition at line 47 of file cdrel.h.

                            {
    cdrel_format_dsv = 0,
    cdrel_format_json,
    cdrel_format_sql,
    cdrel_format_type_end,
};

Function Documentation

cdrel_basename()

const char * cdrel_basename

(

const char *

path

)

Definition at line 219 of file res_cdrel_custom.c.

{
    int i = 0;
    const char *basename = path;
 
    if (ast_strlen_zero(path)) {
        return path;
    }
    i = strlen(path) - 1;
    while(i >= 0) {
        if (path[i] == '/') {
            basename = &path[i + 1];
            break;
        }
        i--;
    }
    return basename;
}

References ast_strlen_zero().

Referenced by config_alloc(), field_alloc(), format_string(), load_database_columns(), load_database_config(), load_fields(), load_text_file_advanced_config(), load_text_file_legacy_config(), load_text_file_legacy_mappings(), open_database(), and parse_legacy_template().

cdrel_data_type_from_str()

enum cdrel_data_type cdrel_data_type_from_str

(

const char *

str

)

Definition at line 179 of file res_cdrel_custom.c.

{
    enum cdrel_data_type data_type = 0;
    for (data_type = 0; data_type < cdrel_data_type_end; data_type++) {
        if (strcasecmp(cdrel_data_type_map[data_type], str) == 0) {
            return data_type;
        }
 
    }
    return cdrel_data_type_end;
}

References cdrel_data_type_end, cdrel_data_type_map, and str.

Referenced by field_alloc().

cdrel_get_field_flags()

const char * cdrel_get_field_flags	(	struct ast_flags *	flags,
		struct ast_str **	str
	)

Definition at line 201 of file res_cdrel_custom.c.

{
    int ix = 0;
    int res = 0;
    int trues = 0;
 
    for (ix = 0; ix < CDREL_FIELD_FLAG_LAST; ix++) {
        if (ast_test_flag(flags, (1 << ix))) {
            res = ast_str_append(str, -1, "%s%s", trues++ ? "," : "", cdrel_field_flags_map[ix]);
            if (res < 0) {
                return "";
            }
        }
    }
    return ast_str_buffer(*str);
}

References ast_str_append(), ast_str_buffer(), ast_test_flag, CDREL_FIELD_FLAG_LAST, cdrel_field_flags_map, and str.

Referenced by field_alloc(), and format_string().

get_registered_field_by_name()

const struct cdrel_field * get_registered_field_by_name	(	enum cdrel_record_type	record_type,
		const char *	name
	)

Definition at line 113 of file registry.c.

{
    int ix = 0;
 
    for (ix = 0; ix < ARRAY_LEN(cdrel_field_registry); ix++) {
        if (cdrel_field_registry[ix].record_type == type && strcasecmp(cdrel_field_registry[ix].name, name) == 0) {
            return &cdrel_field_registry[ix];
        }
    }
    return NULL;
}

References ARRAY_LEN, cdrel_field_registry, name, NULL, cdrel_field::record_type, and type.

Referenced by field_alloc(), and parse_legacy_template().

load_cdr()

int load_cdr

(

void

)

Definition at line 101 of file getters_cdr.c.

{
    ast_debug(1, "Loading CDR getters\n");
    cdrel_field_getters[cdrel_record_cdr][cdrel_type_string] = cdr_get_string;
    cdrel_field_getters[cdrel_record_cdr][cdrel_type_literal] = cdr_get_literal;
    cdrel_field_getters[cdrel_record_cdr][cdrel_type_int32] = cdr_get_int32;
    cdrel_field_getters[cdrel_record_cdr][cdrel_type_uint32] = cdr_get_uint32;
    cdrel_field_getters[cdrel_record_cdr][cdrel_type_int64] = cdr_get_int64;
    cdrel_field_getters[cdrel_record_cdr][cdrel_type_uint64] = cdr_get_uint64;
    cdrel_field_getters[cdrel_record_cdr][cdrel_type_timeval] = cdr_get_timeval;
    cdrel_field_getters[cdrel_record_cdr][cdrel_type_double] = cdr_get_double;
    cdrel_field_getters[cdrel_record_cdr][cdrel_type_uservar] = cdr_get_uservar;
    cdrel_dummy_channel_allocators[cdrel_record_cdr] = dummy_chan_alloc_cdr;
 
    return 0;
}

References ast_debug, cdr_get_literal(), cdr_get_string(), cdr_get_uservar(), cdrel_dummy_channel_allocators, cdrel_field_getters, cdrel_record_cdr, cdrel_type_double, cdrel_type_int32, cdrel_type_int64, cdrel_type_literal, cdrel_type_string, cdrel_type_timeval, cdrel_type_uint32, cdrel_type_uint64, cdrel_type_uservar, and dummy_chan_alloc_cdr().

Referenced by load_module().

load_cel()

int load_cel

(

void

)

Definition at line 104 of file getters_cel.c.

{
    ast_debug(1, "Loading CEL getters\n");
    cdrel_field_getters[cdrel_record_cel][cdrel_type_string] = cel_get_string;
    cdrel_field_getters[cdrel_record_cel][cdrel_type_literal] = cel_get_literal;
    cdrel_field_getters[cdrel_record_cel][cdrel_type_uint32] = cel_get_uint32;
    cdrel_field_getters[cdrel_record_cel][cdrel_type_timeval] = cel_get_timeval;
    cdrel_field_getters[cdrel_record_cel][cdrel_type_event_type] = cel_get_event_type;
    cdrel_field_getters[cdrel_record_cel][cdrel_type_event_enum] = cel_get_event_enum;
    cdrel_dummy_channel_allocators[cdrel_record_cel] = dummy_chan_alloc_cel;
 
    return 0;
}

References ast_debug, cdrel_dummy_channel_allocators, cdrel_field_getters, cdrel_record_cel, cdrel_type_event_enum, cdrel_type_event_type, cdrel_type_literal, cdrel_type_string, cdrel_type_timeval, cdrel_type_uint32, cel_get_event_enum(), cel_get_event_type(), cel_get_literal(), cel_get_string(), cel_get_timeval(), cel_get_uint32(), and dummy_chan_alloc_cel().

Referenced by load_module().

load_formatters()

int load_formatters

(

void

)

Definition at line 189 of file formatters.c.

{
    ast_debug(1, "Loading Formatters\n");
    cdrel_field_formatters[cdrel_type_string] = format_string;
    cdrel_field_formatters[cdrel_type_int32] = format_int32;
    cdrel_field_formatters[cdrel_type_uint32] = format_uint32;
    cdrel_field_formatters[cdrel_type_int64] = format_int64;
    cdrel_field_formatters[cdrel_type_uint64] = format_uint64;
    cdrel_field_formatters[cdrel_type_timeval] = format_timeval;
    cdrel_field_formatters[cdrel_type_double] = format_double;
    cdrel_field_formatters[cdrel_type_amaflags] = format_amaflags;
    cdrel_field_formatters[cdrel_type_disposition] = format_disposition;
 
    return 0;
}

References ast_debug, cdrel_field_formatters, cdrel_type_amaflags, cdrel_type_disposition, cdrel_type_double, cdrel_type_int32, cdrel_type_int64, cdrel_type_string, cdrel_type_timeval, cdrel_type_uint32, cdrel_type_uint64, format_amaflags(), format_disposition(), format_string(), and format_timeval().

Referenced by load_module().

load_writers()

int load_writers

(

void

)

Definition at line 221 of file writers.c.

{
    ast_debug(1, "Loading Writers\n");
    cdrel_backend_writers[cdrel_format_dsv] = dsv_writer;
    cdrel_backend_writers[cdrel_format_json] = json_writer;
    cdrel_backend_writers[cdrel_format_sql] = database_writer;
 
    return 0;
}

References ast_debug, cdrel_backend_writers, cdrel_format_dsv, cdrel_format_json, cdrel_format_sql, database_writer(), dsv_writer(), and json_writer().

Referenced by load_module().

write_record_to_database()

int write_record_to_database	(	struct cdrel_config *	config,
		struct cdrel_values *	values
	)

Definition at line 169 of file writers.c.

{
    int res = 0;
    int ix;
 
    ast_mutex_lock(&config->lock);
    for (ix = 0; ix < AST_VECTOR_SIZE(values); ix++) {
        struct cdrel_value *value = AST_VECTOR_GET(values, ix);
        ast_assert(value->data_type == cdrel_type_string);
        ast_debug(6, "%s '%s'\n", value->field_name, value->values.string);
        res = sqlite3_bind_text(config->insert, ix + 1, value->values.string, -1, SQLITE_STATIC);
        if (res != SQLITE_OK) {
            ast_log(LOG_ERROR, "Unable to write %s to database %s.  SQL bind for field %s:'%s'. Error: %s\n",
                RECORD_TYPE_STR(config->record_type), config->output_filename,
                value->field_name, value->values.string,
                sqlite3_errmsg(config->db));
            sqlite3_reset(config->insert);
            ast_mutex_unlock(&config->lock);
            return -1;
        }
    }
 
    res = sqlite3_step(config->insert);
    if (res != SQLITE_DONE) {
        ast_log(LOG_ERROR, "Unable to write %s to database %s. Error: %s\n",
            RECORD_TYPE_STR(config->record_type), config->output_filename,
            sqlite3_errmsg(config->db));
        sqlite3_reset(config->insert);
        ast_mutex_unlock(&config->lock);
        return -1;
    }
 
    sqlite3_reset(config->insert);
    ast_mutex_unlock(&config->lock);
 
    return res;
}

References ast_assert, ast_debug, ast_log, ast_mutex_lock, ast_mutex_unlock, AST_VECTOR_GET, AST_VECTOR_SIZE, cdrel_type_string, config, LOG_ERROR, RECORD_TYPE_STR, value, and cdrel_value::values.

Referenced by database_writer(), and log_legacy_database_record().

write_record_to_file()

int write_record_to_file	(	struct cdrel_config *	config,
		struct ast_str *	record
	)

Definition at line 50 of file writers.c.

{
    FILE *out;
    int res = 0;
 
    ast_mutex_lock(&config->lock);
    if ((out = fopen(config->output_filename, "a"))) {
        res = fputs(ast_str_buffer(record), out);
        fputs("\n", out);
        fclose(out);
    }
    ast_mutex_unlock(&config->lock);
 
    if (!out || res < 0) {
        ast_log(LOG_ERROR, "Unable to write %s to file %s : %s\n",
            RECORD_TYPE_STR(config->record_type), config->output_filename, strerror(errno));
        return -1;
    }
    return 0;
}

References ast_log, ast_mutex_lock, ast_mutex_unlock, ast_str_buffer(), config, errno, LOG_ERROR, out, and RECORD_TYPE_STR.

Referenced by dsv_writer(), json_writer(), and log_legacy_dsv_record().

Variable Documentation

cdrel_backend_writers

cdrel_backend_writer cdrel_backend_writers[cdrel_format_type_end]

extern

Definition at line 137 of file res_cdrel_custom.c.

Referenced by load_writers(), and log_advanced_record().

cdrel_data_type_map

const char* cdrel_data_type_map[]

extern

Definition at line 160 of file res_cdrel_custom.c.

                                    {
    [cdrel_type_string] = "string",
    [cdrel_type_timeval] = "timeval",
    [cdrel_type_literal] = "literal",
    [cdrel_type_amaflags] = "amaflags",
    [cdrel_type_disposition] = "disposition",
    [cdrel_type_uservar] = "uservar",
    [cdrel_type_event_type] = "event_type",
    [cdrel_type_event_enum] = "event_enum",
    [cdrel_type_cel_timefmt] = "cel_timefmt",
    [cdrel_data_type_strings_end] = "!!STRINGS END!!",
    [cdrel_type_int32] = "int32",
    [cdrel_type_uint32] = "uint32",
    [cdrel_type_int64] = "int64",
    [cdrel_type_uint64] = "uint64",
    [cdrel_type_double] = "double",
    [cdrel_data_type_end] = "!!END!!",
};

Referenced by cdrel_data_type_from_str().

cdrel_dummy_channel_allocators

cdrel_dummy_channel_alloc cdrel_dummy_channel_allocators[cdrel_format_type_end]

extern

Definition at line 142 of file res_cdrel_custom.c.

Referenced by config_alloc(), load_cdr(), and load_cel().

cdrel_field_formatters

cdrel_field_formatter cdrel_field_formatters[cdrel_data_type_end]

extern

Definition at line 132 of file res_cdrel_custom.c.

Referenced by load_formatters(), and log_advanced_record().

cdrel_field_getters

cdrel_field_getter cdrel_field_getters[cdrel_record_type_end][cdrel_data_type_end]

extern

Definition at line 127 of file res_cdrel_custom.c.

Referenced by load_cdr(), load_cel(), and log_advanced_record().

cdrel_module_type_map

const char* cdrel_module_type_map[]

extern

Definition at line 154 of file res_cdrel_custom.c.

                                      {
    [cdrel_backend_text] = "Custom ",
    [cdrel_backend_db] = "SQLITE3 Custom",
    [cdrel_backend_type_end] = "!!END!!",
};

cdrel_record_type_map

const char* cdrel_record_type_map[]

extern

Definition at line 148 of file res_cdrel_custom.c.

                                      {
    [cdrel_record_cdr] = "CDR",
    [cdrel_record_cel] = "CEL",
    [cdrel_record_type_end] = "!!END!!",
};