writers.c File Reference

Backend output functions. More...

#include "cdrel.h"

Include dependency graph for writers.c:

Go to the source code of this file.

Functions
	AST_THREADSTORAGE_CUSTOM_SCOPE (custom_buf, NULL, ast_free_ptr, static)
static int	database_writer (struct cdrel_config *config, struct cdrel_values *values)
static int	dsv_appender (struct cdrel_config *config, struct cdrel_values *values, struct ast_str **str)
static int	dsv_writer (struct cdrel_config *config, struct cdrel_values *values)
static int	json_writer (struct cdrel_config *config, struct cdrel_values *values)
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)

Detailed Description

Backend output functions.

Author

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

The writers all take a vector of cdrel_value objects and write them to the output file or database.

Definition in file writers.c.

Function Documentation

AST_THREADSTORAGE_CUSTOM_SCOPE()

AST_THREADSTORAGE_CUSTOM_SCOPE	(	custom_buf	,
		NULL	,
		ast_free_ptr	,
		static
	)

database_writer()

static int database_writer ( struct cdrel_config *  config, struct cdrel_values *  values  )

static

Definition at line 216 of file writers.c.

{
    return write_record_to_database(config, values);
}

References config, cdrel_value::values, and write_record_to_database().

Referenced by load_writers().

dsv_appender()

static int dsv_appender ( struct cdrel_config *  config, struct cdrel_values *  values, struct ast_str **  str  )

static

Definition at line 81 of file writers.c.

{
    int ix = 0;
    int res = 0;
 
    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);
 
        res = ast_str_append(str, -1, "%s%s", ix == 0 ? "" : config->separator, value->values.string);
        if (res < 0) {
            return -1;
        }
    }
 
    return res;
}

References ast_assert, ast_str_append(), AST_VECTOR_GET, AST_VECTOR_SIZE, cdrel_type_string, config, str, value, and cdrel_value::values.

Referenced by dsv_writer().

dsv_writer()

static int dsv_writer ( struct cdrel_config *  config, struct cdrel_values *  values  )

static

Definition at line 108 of file writers.c.

{
    int res = 0;
    struct ast_str *str = ast_str_thread_get(&custom_buf, 1024);
 
    ast_str_reset(str);
 
    res = dsv_appender(config, values, &str);
    if (res < 0) {
        return -1;
    }
 
    return write_record_to_file(config, str);
}

References ast_str_reset(), ast_str_thread_get(), config, dsv_appender(), str, and write_record_to_file().

Referenced by load_writers().

json_writer()

static int json_writer ( struct cdrel_config *  config, struct cdrel_values *  values  )

static

Definition at line 135 of file writers.c.

{
    int ix = 0;
    int res = 0;
    struct ast_str *str = ast_str_thread_get(&custom_buf, 1024);
 
    ast_str_set(&str, -1, "%s", "{");
 
    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);
 
        res = ast_str_append(&str, -1, "%s\"%s\":%s", ix == 0 ? "" : config->separator, value->field_name, value->values.string);
        if (res < 0) {
            return -1;
        }
    }
    ast_str_append(&str, -1, "%s", "}");
 
    return write_record_to_file(config, str);
}

References ast_assert, ast_str_append(), ast_str_set(), ast_str_thread_get(), AST_VECTOR_GET, AST_VECTOR_SIZE, cdrel_type_string, config, str, value, cdrel_value::values, and write_record_to_file().

Referenced by load_writers().

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().