cel_pgsql.c File Reference

PostgreSQL CEL logger. More...

#include "asterisk.h"
#include <libpq-fe.h>
#include "asterisk/config.h"
#include "asterisk/options.h"
#include "asterisk/channel.h"
#include "asterisk/cel.h"
#include "asterisk/module.h"
#include "asterisk/logger.h"

Include dependency graph for cel_pgsql.c:

Go to the source code of this file.

Data Structures
struct	columns
struct	psql_columns

Macros
#define	CEL_SHOW_USERDEF_DEFAULT   0
	show_user_def is off by default More...
#define	DATE_FORMAT   "%Y-%m-%d %T.%6q"
#define	LENGTHEN_BUF(size, var_sql)
#define	LENGTHEN_BUF1(size)   LENGTHEN_BUF(size, sql);
#define	LENGTHEN_BUF2(size)   LENGTHEN_BUF(size, sql2);
#define	PGSQL_BACKEND_NAME   "CEL PGSQL backend"
#define	PGSQL_MIN_VERSION_SCHEMA   70300
#define	SEP   (first ? "" : ",")

Functions
static void	__reg_module (void)
static void	__unreg_module (void)
struct ast_module *	AST_MODULE_SELF_SYM (void)
static int	load_module (void)
static int	my_load_module (int reload)
static int	my_unload_module (void)
static void	pgsql_log (struct ast_event *event)
static void	pgsql_reconnect (void)
static int	process_my_load_module (struct ast_config *cfg)
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 = "PostgreSQL CEL 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 = "30ef0c93b36035ec78c9cfd712d36d9b" , .support_level = AST_MODULE_SUPPORT_EXTENDED, .load = load_module, .unload = unload_module, .reload = reload, .load_pri = AST_MODPRI_CDR_DRIVER, .requires = "cel", }
static const struct ast_module_info *	ast_module_info = &__mod_info
static unsigned char	cel_show_user_def
static char *	config = "cel_pgsql.conf"
static PGconn *	conn = NULL
static int	connected = 0
static int	maxsize = 512
static int	maxsize2 = 512
static char *	pgappname
static char *	pgdbname
static char *	pgdbport
static char *	pgdbuser
static char *	pghostname
static char *	pgpassword
static ast_mutex_t	pgsql_lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }
static struct psql_columns	psql_columns = { .first = NULL, .last = NULL, .lock = { PTHREAD_RWLOCK_INITIALIZER , NULL, {1, 0} } , }
static PGresult *	result = NULL
static char *	schema
static char *	table
static int	usegmtime = 0

Detailed Description

PostgreSQL CEL logger.

Author

Steve Murphy murf@.nosp@m.digi.nosp@m.um.co.nosp@m.m PostgreSQL http://www.postgresql.org/

See also

• Config_cel PostgreSQL http://www.postgresql.org/

Definition in file cel_pgsql.c.

Macro Definition Documentation

CEL_SHOW_USERDEF_DEFAULT

#define CEL_SHOW_USERDEF_DEFAULT   0

show_user_def is off by default

Definition at line 80 of file cel_pgsql.c.

Referenced by process_my_load_module().

DATE_FORMAT

#define DATE_FORMAT   "%Y-%m-%d %T.%6q"

Definition at line 57 of file cel_pgsql.c.

Referenced by pgsql_log().

LENGTHEN_BUF

#define LENGTHEN_BUF	(		size,
			var_sql
	)

Definition at line 101 of file cel_pgsql.c.

LENGTHEN_BUF1

#define LENGTHEN_BUF1

(

size

)

LENGTHEN_BUF(size, sql);

Definition at line 115 of file cel_pgsql.c.

Referenced by pgsql_log().

LENGTHEN_BUF2

#define LENGTHEN_BUF2

(

size

)

LENGTHEN_BUF(size, sql2);

Definition at line 117 of file cel_pgsql.c.

Referenced by pgsql_log().

PGSQL_BACKEND_NAME

#define PGSQL_BACKEND_NAME   "CEL PGSQL backend"

Definition at line 59 of file cel_pgsql.c.

Referenced by my_load_module(), and my_unload_module().

PGSQL_MIN_VERSION_SCHEMA

#define PGSQL_MIN_VERSION_SCHEMA   70300

Definition at line 61 of file cel_pgsql.c.

Referenced by process_my_load_module().

SEP

#define SEP   (first ? "" : ",")

Referenced by pgsql_log().

Function Documentation

__reg_module()

static void __reg_module ( void  )

static

Definition at line 713 of file cel_pgsql.c.

__unreg_module()

static void __unreg_module ( void  )

static

Definition at line 713 of file cel_pgsql.c.

AST_MODULE_SELF_SYM()

struct ast_module* AST_MODULE_SELF_SYM

(

void

)

Definition at line 713 of file cel_pgsql.c.

load_module()

static int load_module ( void  )

static

Definition at line 696 of file cel_pgsql.c.

References my_load_module().

Referenced by reload().

{
   return my_load_module(0);
}

my_load_module()

static int my_load_module ( int  reload )

static

Definition at line 669 of file cel_pgsql.c.

References ast_cel_backend_register(), ast_config_destroy(), ast_config_load, ast_log, AST_MODULE_LOAD_DECLINE, AST_MODULE_LOAD_SUCCESS, config, CONFIG_FLAG_FILEUNCHANGED, CONFIG_STATUS_FILEINVALID, CONFIG_STATUS_FILEUNCHANGED, LOG_WARNING, my_unload_module(), NULL, PGSQL_BACKEND_NAME, pgsql_log(), and process_my_load_module().

Referenced by load_module(), and reload().

{
   struct ast_config *cfg;
   struct ast_flags config_flags = { reload ? CONFIG_FLAG_FILEUNCHANGED : 0 };

   if ((cfg = ast_config_load(config, config_flags)) == NULL || cfg == CONFIG_STATUS_FILEINVALID) {
      ast_log(LOG_WARNING, "Unable to load config for PostgreSQL CEL's: %s\n", config);
      return AST_MODULE_LOAD_DECLINE;
   } else if (cfg == CONFIG_STATUS_FILEUNCHANGED) {
      return AST_MODULE_LOAD_SUCCESS;
   }

   if (reload) {
      my_unload_module();
   }

   process_my_load_module(cfg);
   ast_config_destroy(cfg);

   if (ast_cel_backend_register(PGSQL_BACKEND_NAME, pgsql_log)) {
      ast_log(LOG_WARNING, "Unable to subscribe to CEL events for pgsql\n");
      return AST_MODULE_LOAD_DECLINE;
   }

   return AST_MODULE_LOAD_SUCCESS;
}

my_unload_module()

static int my_unload_module ( void  )

static

Definition at line 404 of file cel_pgsql.c.

References ast_cel_backend_unregister(), ast_free, AST_RWLIST_REMOVE_HEAD, AST_RWLIST_UNLOCK, AST_RWLIST_WRLOCK, conn, columns::list, NULL, pgappname, pgdbname, pgdbport, pgdbuser, pghostname, pgpassword, PGSQL_BACKEND_NAME, schema, and table.

Referenced by my_load_module(), and unload_module().

{
   struct columns *current;

   ast_cel_backend_unregister(PGSQL_BACKEND_NAME);
   AST_RWLIST_WRLOCK(&psql_columns);
   if (conn) {
      PQfinish(conn);
      conn = NULL;
   }
   if (pghostname) {
      ast_free(pghostname);
      pghostname = NULL;
   }
   if (pgdbname) {
      ast_free(pgdbname);
      pgdbname = NULL;
   }
   if (pgdbuser) {
      ast_free(pgdbuser);
      pgdbuser = NULL;
   }
   if (pgpassword) {
      ast_free(pgpassword);
      pgpassword = NULL;
   }
   if (pgappname) {
      ast_free(pgappname);
      pgappname = NULL;
   }
   if (pgdbport) {
      ast_free(pgdbport);
      pgdbport = NULL;
   }
   if (table) {
      ast_free(table);
      table = NULL;
   }
   if (schema) {
      ast_free(schema);
      schema = NULL;
   }
   while ((current = AST_RWLIST_REMOVE_HEAD(&psql_columns, list))) {
      ast_free(current);
   }
   AST_RWLIST_UNLOCK(&psql_columns);
   return 0;
}

pgsql_log()

static void pgsql_log ( struct ast_event *  event )

static

Definition at line 149 of file cel_pgsql.c.

References ast_cel_event_record::account_code, ast_cel_event_record::amaflag, ast_cel_event_record::application_data, ast_cel_event_record::application_name, AST_CEL_EVENT_RECORD_VERSION, ast_cel_fill_record(), AST_CEL_USER_DEFINED, ast_debug, ast_free, ast_localtime(), ast_log, ast_malloc, ast_mutex_lock, ast_mutex_unlock, ast_realloc, AST_RWLIST_RDLOCK, AST_RWLIST_TRAVERSE, AST_RWLIST_UNLOCK, ast_str_append(), ast_str_buffer(), ast_str_create, ast_str_set(), ast_str_strlen(), ast_strftime(), buf, ast_cel_event_record::caller_id_ani, ast_cel_event_record::caller_id_dnid, ast_cel_event_record::caller_id_name, ast_cel_event_record::caller_id_num, ast_cel_event_record::caller_id_rdnis, cel_show_user_def, ast_cel_event_record::channel_name, conn, connected, ast_cel_event_record::context, DATE_FORMAT, ast_cel_event_record::event_name, ast_cel_event_record::event_time, ast_cel_event_record::event_type, ast_cel_event_record::extension, ast_cel_event_record::extra, columns::first, LENGTHEN_BUF1, LENGTHEN_BUF2, ast_cel_event_record::linked_id, columns::list, LOG_ERROR, LOG_NOTICE, LOG_WARNING, maxsize, maxsize2, columns::name, NULL, ast_cel_event_record::peer, ast_cel_event_record::peer_account, pgdbname, pgdbuser, pghostname, pgpassword, pgsql_lock, pgsql_reconnect(), result, SEP, table, columns::type, ast_cel_event_record::unique_id, usegmtime, ast_cel_event_record::user_defined_name, ast_cel_event_record::user_field, value, and ast_cel_event_record::version.

Referenced by my_load_module().

{
   struct ast_tm tm;
   char timestr[128];
   char *pgerror;
   struct ast_cel_event_record record = {
      .version = AST_CEL_EVENT_RECORD_VERSION,
   };

   if (ast_cel_fill_record(event, &record)) {
      return;
   }

   ast_mutex_lock(&pgsql_lock);

   ast_localtime(&record.event_time, &tm, usegmtime ? "GMT" : NULL);
   ast_strftime(timestr, sizeof(timestr), DATE_FORMAT, &tm);

   if ((!connected) && pghostname && pgdbuser && pgpassword && pgdbname) {
      pgsql_reconnect();
      if (PQstatus(conn) != CONNECTION_BAD) {
         connected = 1;
      } else {
         pgerror = PQerrorMessage(conn);
         ast_log(LOG_ERROR, "cel_pgsql: Unable to connect to database server %s.  Calls will not be logged!\n", pghostname);
         ast_log(LOG_ERROR, "cel_pgsql: Reason: %s\n", pgerror);
         PQfinish(conn);
         conn = NULL;
      }
   }
   if (connected) {
      struct columns *cur;
      struct ast_str *sql = ast_str_create(maxsize), *sql2 = ast_str_create(maxsize2);
      char buf[257];
      char *escapebuf = NULL;
      const char *value;
      int first = 1;
      size_t bufsize = 513;

      escapebuf = ast_malloc(bufsize);
      if (!escapebuf || !sql || !sql2) {
         goto ast_log_cleanup;
      }

      ast_str_set(&sql, 0, "INSERT INTO %s (", table);
      ast_str_set(&sql2, 0, " VALUES (");

#define SEP (first ? "" : ",")

      AST_RWLIST_RDLOCK(&psql_columns);
      AST_RWLIST_TRAVERSE(&psql_columns, cur, list) {
         LENGTHEN_BUF1(strlen(cur->name) + 2);
         ast_str_append(&sql, 0, "%s\"%s\"", SEP, cur->name);

         if (strcmp(cur->name, "eventtime") == 0) {
            if (strncmp(cur->type, "int", 3) == 0) {
               LENGTHEN_BUF2(13);
               ast_str_append(&sql2, 0, "%s%ld", SEP, (long) record.event_time.tv_sec);
            } else if (strncmp(cur->type, "float", 5) == 0) {
               LENGTHEN_BUF2(31);
               ast_str_append(&sql2, 0, "%s%f",
                  SEP,
                  (double) record.event_time.tv_sec +
                  (double) record.event_time.tv_usec / 1000000.0);
            } else {
               /* char, hopefully */
               LENGTHEN_BUF2(31);
               ast_localtime(&record.event_time, &tm, usegmtime ? "GMT" : NULL);
               ast_strftime(buf, sizeof(buf), DATE_FORMAT, &tm);
               ast_str_append(&sql2, 0, "%s'%s'", SEP, buf);
            }
         } else if (strcmp(cur->name, "eventtype") == 0) {
            if (cur->type[0] == 'i') {
               /* Get integer, no need to escape anything */
               LENGTHEN_BUF2(5);
               ast_str_append(&sql2, 0, "%s%d", SEP, (int) record.event_type);
            } else if (strncmp(cur->type, "float", 5) == 0) {
               LENGTHEN_BUF2(31);
               ast_str_append(&sql2, 0, "%s%f", SEP, (double) record.event_type);
            } else {
               /* Char field, probably */
               const char *event_name;

               event_name = (!cel_show_user_def
                  && record.event_type == AST_CEL_USER_DEFINED)
                  ? record.user_defined_name : record.event_name;
               LENGTHEN_BUF2(strlen(event_name) + 1);
               ast_str_append(&sql2, 0, "%s'%s'", SEP, event_name);
            }
         } else if (strcmp(cur->name, "amaflags") == 0) {
            if (strncmp(cur->type, "int", 3) == 0) {
               /* Integer, no need to escape anything */
               LENGTHEN_BUF2(13);
               ast_str_append(&sql2, 0, "%s%u", SEP, record.amaflag);
            } else {
               /* Although this is a char field, there are no special characters in the values for these fields */
               LENGTHEN_BUF2(31);
               ast_str_append(&sql2, 0, "%s'%u'", SEP, record.amaflag);
            }
         } else {
            /* Arbitrary field, could be anything */
            if (strcmp(cur->name, "userdeftype") == 0) {
               value = record.user_defined_name;
            } else if (strcmp(cur->name, "cid_name") == 0) {
               value = record.caller_id_name;
            } else if (strcmp(cur->name, "cid_num") == 0) {
               value = record.caller_id_num;
            } else if (strcmp(cur->name, "cid_ani") == 0) {
               value = record.caller_id_ani;
            } else if (strcmp(cur->name, "cid_rdnis") == 0) {
               value = record.caller_id_rdnis;
            } else if (strcmp(cur->name, "cid_dnid") == 0) {
               value = record.caller_id_dnid;
            } else if (strcmp(cur->name, "exten") == 0) {
               value = record.extension;
            } else if (strcmp(cur->name, "context") == 0) {
               value = record.context;
            } else if (strcmp(cur->name, "channame") == 0) {
               value = record.channel_name;
            } else if (strcmp(cur->name, "appname") == 0) {
               value = record.application_name;
            } else if (strcmp(cur->name, "appdata") == 0) {
               value = record.application_data;
            } else if (strcmp(cur->name, "accountcode") == 0) {
               value = record.account_code;
            } else if (strcmp(cur->name, "peeraccount") == 0) {
               value = record.peer_account;
            } else if (strcmp(cur->name, "uniqueid") == 0) {
               value = record.unique_id;
            } else if (strcmp(cur->name, "linkedid") == 0) {
               value = record.linked_id;
            } else if (strcmp(cur->name, "userfield") == 0) {
               value = record.user_field;
            } else if (strcmp(cur->name, "peer") == 0) {
               value = record.peer;
            } else if (strcmp(cur->name, "extra") == 0) {
               value = record.extra;
            } else {
               value = NULL;
            }

            if (value == NULL) {
               ast_str_append(&sql2, 0, "%sDEFAULT", SEP);
            } else if (strncmp(cur->type, "int", 3) == 0) {
               long long whatever;
               if (value && sscanf(value, "%30lld", &whatever) == 1) {
                  LENGTHEN_BUF2(26);
                  ast_str_append(&sql2, 0, "%s%lld", SEP, whatever);
               } else {
                  LENGTHEN_BUF2(2);
                  ast_str_append(&sql2, 0, "%s0", SEP);
               }
            } else if (strncmp(cur->type, "float", 5) == 0) {
               long double whatever;
               if (value && sscanf(value, "%30Lf", &whatever) == 1) {
                  LENGTHEN_BUF2(51);
                  ast_str_append(&sql2, 0, "%s%30Lf", SEP, whatever);
               } else {
                  LENGTHEN_BUF2(2);
                  ast_str_append(&sql2, 0, "%s0", SEP);
               }
               /* XXX Might want to handle dates, times, and other misc fields here XXX */
            } else {
               if (value) {
                  size_t required_size = strlen(value) * 2 + 1;

                  /* If our argument size exceeds our buffer, grow it,
                   * as PQescapeStringConn() expects the buffer to be
                   * adequitely sized and does *NOT* do size checking.
                   */
                  if (required_size > bufsize) {
                     char *tmpbuf = ast_realloc(escapebuf, required_size);

                     if (!tmpbuf) {
                        AST_RWLIST_UNLOCK(&psql_columns);
                        goto ast_log_cleanup;
                     }

                     escapebuf = tmpbuf;
                     bufsize = required_size;
                  }
                  PQescapeStringConn(conn, escapebuf, value, strlen(value), NULL);
               } else {
                  escapebuf[0] = '\0';
               }
               LENGTHEN_BUF2(strlen(escapebuf) + 3);
               ast_str_append(&sql2, 0, "%s'%s'", SEP, escapebuf);
            }
         }
         first = 0;
      }
      AST_RWLIST_UNLOCK(&psql_columns);
      LENGTHEN_BUF1(ast_str_strlen(sql2) + 2);
      ast_str_append(&sql, 0, ")%s)", ast_str_buffer(sql2));

      ast_debug(3, "Inserting a CEL record: [%s].\n", ast_str_buffer(sql));
      /* Test to be sure we're still connected... */
      /* If we're connected, and connection is working, good. */
      /* Otherwise, attempt reconnect.  If it fails... sorry... */
      if (PQstatus(conn) == CONNECTION_OK) {
         connected = 1;
      } else {
         ast_log(LOG_WARNING, "Connection was lost... attempting to reconnect.\n");
         PQreset(conn);
         if (PQstatus(conn) == CONNECTION_OK) {
            ast_log(LOG_NOTICE, "Connection reestablished.\n");
            connected = 1;
         } else {
            pgerror = PQerrorMessage(conn);
            ast_log(LOG_ERROR, "Unable to reconnect to database server %s. Calls will not be logged!\n", pghostname);
            ast_log(LOG_ERROR, "Reason: %s\n", pgerror);
            PQfinish(conn);
            conn = NULL;
            connected = 0;
            goto ast_log_cleanup;
         }
      }
      result = PQexec(conn, ast_str_buffer(sql));
      if (PQresultStatus(result) != PGRES_COMMAND_OK) {
         pgerror = PQresultErrorMessage(result);
         ast_log(LOG_WARNING, "Failed to insert call detail record into database!\n");
         ast_log(LOG_WARNING, "Reason: %s\n", pgerror);
         ast_log(LOG_WARNING, "Connection may have been lost... attempting to reconnect.\n");
         PQreset(conn);
         if (PQstatus(conn) == CONNECTION_OK) {
            ast_log(LOG_NOTICE, "Connection reestablished.\n");
            connected = 1;
            PQclear(result);
            result = PQexec(conn, ast_str_buffer(sql));
            if (PQresultStatus(result) != PGRES_COMMAND_OK) {
               pgerror = PQresultErrorMessage(result);
               ast_log(LOG_ERROR, "HARD ERROR!  Attempted reconnection failed.  DROPPING CALL RECORD!\n");
               ast_log(LOG_ERROR, "Reason: %s\n", pgerror);
            }
         }
      }
      PQclear(result);

      /* Next time, just allocate buffers that are that big to start with. */
      if (ast_str_strlen(sql) > maxsize) {
         maxsize = ast_str_strlen(sql);
      }
      if (ast_str_strlen(sql2) > maxsize2) {
         maxsize2 = ast_str_strlen(sql2);
      }

ast_log_cleanup:
      ast_free(sql);
      ast_free(sql2);
      ast_free(escapebuf);
   }

   ast_mutex_unlock(&pgsql_lock);
}

pgsql_reconnect()

static void pgsql_reconnect ( void  )

static

Definition at line 120 of file cel_pgsql.c.

References ast_free, ast_log, ast_str_append(), ast_str_buffer(), ast_str_create, ast_str_set(), ast_strlen_zero, conn, LOG_ERROR, NULL, pgappname, pgdbname, pgdbport, pgdbuser, pghostname, and pgpassword.

Referenced by pgsql_log(), and process_my_load_module().

{
   struct ast_str *conn_info = ast_str_create(128);
   if (!conn_info) {
      ast_log(LOG_ERROR, "Failed to allocate memory for connection string.\n");
      return;
   }

   if (conn) {
      PQfinish(conn);
      conn = NULL;
   }

   ast_str_set(&conn_info, 0, "host=%s port=%s dbname=%s user=%s",
      pghostname, pgdbport, pgdbname, pgdbuser);

   if (!ast_strlen_zero(pgappname)) {
      ast_str_append(&conn_info, 0, " application_name=%s", pgappname);
   }

   if (!ast_strlen_zero(pgpassword)) {
      ast_str_append(&conn_info, 0, " password=%s", pgpassword);
   }

   conn = PQconnectdb(ast_str_buffer(conn_info));
   ast_free(conn_info);
}

process_my_load_module()

static int process_my_load_module ( struct ast_config *  cfg )

static

Definition at line 458 of file cel_pgsql.c.

References ast_alloca, ast_calloc, ast_debug, ast_free, ast_log, AST_MODULE_LOAD_DECLINE, AST_MODULE_LOAD_SUCCESS, AST_RWLIST_INSERT_TAIL, ast_strdup, ast_strlen_zero, ast_true(), ast_variable_browse(), ast_variable_retrieve(), ast_verb, cel_show_user_def, CEL_SHOW_USERDEF_DEFAULT, conn, connected, DEBUG_ATLEAST, columns::hasdefault, columns::len, columns::list, LOG_DEBUG, LOG_ERROR, LOG_WARNING, columns::name, columns::notnull, NULL, pgappname, pgdbname, pgdbport, pgdbuser, pghostname, pgpassword, PGSQL_MIN_VERSION_SCHEMA, pgsql_reconnect(), result, schema, table, tmp(), columns::type, unload_module(), usegmtime, var, and version.

Referenced by my_load_module().

{
   struct ast_variable *var;
   char *pgerror;
   const char *tmp;
   PGresult *result;
   struct columns *cur;

   if (!(var = ast_variable_browse(cfg, "global"))) {
      ast_log(LOG_WARNING,"CEL pgsql config file missing global section.\n");
      return AST_MODULE_LOAD_DECLINE;
   }
   if (!(tmp = ast_variable_retrieve(cfg,"global","hostname"))) {
      ast_log(LOG_WARNING,"PostgreSQL server hostname not specified.  Assuming unix socket connection\n");
      tmp = "";   /* connect via UNIX-socket by default */
   }
   if (pghostname)
      ast_free(pghostname);
   if (!(pghostname = ast_strdup(tmp))) {
      ast_log(LOG_WARNING,"PostgreSQL Ran out of memory copying host info\n");
      return AST_MODULE_LOAD_DECLINE;
   }
   if (!(tmp = ast_variable_retrieve(cfg, "global", "dbname"))) {
      ast_log(LOG_WARNING,"PostgreSQL database not specified.  Assuming asterisk\n");
      tmp = "asteriskceldb";
   }
   if (pgdbname)
      ast_free(pgdbname);
   if (!(pgdbname = ast_strdup(tmp))) {
      ast_log(LOG_WARNING,"PostgreSQL Ran out of memory copying dbname info\n");
      return AST_MODULE_LOAD_DECLINE;
   }
   if (!(tmp = ast_variable_retrieve(cfg, "global", "user"))) {
      ast_log(LOG_WARNING,"PostgreSQL database user not specified.  Assuming asterisk\n");
      tmp = "asterisk";
   }
   if (pgdbuser)
      ast_free(pgdbuser);
   if (!(pgdbuser = ast_strdup(tmp))) {
      ast_log(LOG_WARNING,"PostgreSQL Ran out of memory copying user info\n");
      return AST_MODULE_LOAD_DECLINE;
   }
   if (!(tmp = ast_variable_retrieve(cfg, "global", "password"))) {
      ast_log(LOG_WARNING, "PostgreSQL database password not specified.  Assuming blank\n");
      tmp = "";
   }
   if (pgpassword)
      ast_free(pgpassword);
   if (!(pgpassword = ast_strdup(tmp))) {
      ast_log(LOG_WARNING,"PostgreSQL Ran out of memory copying password info\n");
      return AST_MODULE_LOAD_DECLINE;
   }
   if (!(tmp = ast_variable_retrieve(cfg, "global", "appname"))) {
      tmp = "";
   }
   if (pgappname) {
      ast_free(pgappname);
   }
   if (!(pgappname = ast_strdup(tmp))) {
      ast_log(LOG_WARNING,"PostgreSQL Ran out of memory copying appname info\n");
      return AST_MODULE_LOAD_DECLINE;
   }

   if (!(tmp = ast_variable_retrieve(cfg,"global","port"))) {
      ast_log(LOG_WARNING,"PostgreSQL database port not specified.  Using default 5432.\n");
      tmp = "5432";
   }
   if (pgdbport)
      ast_free(pgdbport);
   if (!(pgdbport = ast_strdup(tmp))) {
      ast_log(LOG_WARNING,"PostgreSQL Ran out of memory copying port info\n");
      return AST_MODULE_LOAD_DECLINE;
   }
   if (!(tmp = ast_variable_retrieve(cfg, "global", "table"))) {
      ast_log(LOG_WARNING,"CEL table not specified.  Assuming cel\n");
      tmp = "cel";
   }
   if (table)
      ast_free(table);
   if (!(table = ast_strdup(tmp))) {
      return AST_MODULE_LOAD_DECLINE;
   }
   cel_show_user_def = CEL_SHOW_USERDEF_DEFAULT;
   if ((tmp = ast_variable_retrieve(cfg, "global", "show_user_defined"))) {
      cel_show_user_def = ast_true(tmp) ? 1 : 0;
   }
   if ((tmp = ast_variable_retrieve(cfg, "global", "usegmtime"))) {
      usegmtime = ast_true(tmp);
   } else {
      usegmtime = 0;
   }
   if (!(tmp = ast_variable_retrieve(cfg, "global", "schema"))) {
      tmp = "";
   }
   if (schema) {
      ast_free(schema);
   }
   if (!(schema = ast_strdup(tmp))) {
      ast_log(LOG_WARNING,"PostgreSQL Ran out of memory copying schema info\n");
      return AST_MODULE_LOAD_DECLINE;
   }
   if (DEBUG_ATLEAST(3)) {
      if (ast_strlen_zero(pghostname)) {
         ast_log(LOG_DEBUG, "cel_pgsql: using default unix socket\n");
      } else {
         ast_log(LOG_DEBUG, "cel_pgsql: got hostname of %s\n", pghostname);
      }
      ast_log(LOG_DEBUG, "cel_pgsql: got port of %s\n", pgdbport);
      ast_log(LOG_DEBUG, "cel_pgsql: got user of %s\n", pgdbuser);
      ast_log(LOG_DEBUG, "cel_pgsql: got dbname of %s\n", pgdbname);
      ast_log(LOG_DEBUG, "cel_pgsql: got password of %s\n", pgpassword);
      ast_log(LOG_DEBUG, "cel_pgsql: got sql table name of %s\n", table);
      ast_log(LOG_DEBUG, "cel_pgsql: got show_user_defined of %s\n",
         cel_show_user_def ? "Yes" : "No");
   }

   pgsql_reconnect();
   if (PQstatus(conn) != CONNECTION_BAD) {
      char sqlcmd[768];
      char *fname, *ftype, *flen, *fnotnull, *fdef, *tablename, *tmp_tablename;
      int i, rows, version;

      ast_debug(1, "Successfully connected to PostgreSQL database.\n");
      connected = 1;

      version = PQserverVersion(conn);
      /* Remove any schema name from the table */
      if ((tmp_tablename = strrchr(table, '.'))) {
         tmp_tablename++;
      } else {
         tmp_tablename = table;
      }
      tablename = ast_alloca(strlen(tmp_tablename) * 2 + 1);
      PQescapeStringConn(conn, tablename, tmp_tablename, strlen(tmp_tablename), NULL);
      if (version >= PGSQL_MIN_VERSION_SCHEMA) {
         char *schemaname;
         int lenschema;
         lenschema = strlen(schema);
         schemaname = ast_alloca(lenschema * 2 + 1);
         PQescapeStringConn(conn, schemaname, schema, lenschema, NULL);

         snprintf(sqlcmd, sizeof(sqlcmd),
         "SELECT a.attname, t.typname, a.attlen, a.attnotnull, pg_catalog.pg_get_expr(d.adbin, d.adrelid) adsrc, a.atttypmod "
         "FROM (((pg_catalog.pg_class c INNER JOIN pg_catalog.pg_namespace n ON n.oid = c.relnamespace "
                  "AND c.relname = '%s' AND n.nspname = %s%s%s) "
                "INNER JOIN pg_catalog.pg_attribute a ON ("
                    "NOT a.attisdropped) AND a.attnum > 0 AND a.attrelid = c.oid) "
             "INNER JOIN pg_catalog.pg_type t ON t.oid = a.atttypid) "
         "LEFT OUTER JOIN pg_attrdef d ON a.atthasdef AND d.adrelid = a.attrelid "
           "AND d.adnum = a.attnum "
         "ORDER BY n.nspname, c.relname, attnum",
            tablename,
            lenschema == 0 ? "" : "'", lenschema == 0 ? "current_schema()" : schemaname, lenschema == 0 ? "" : "'");
      } else {
         snprintf(sqlcmd, sizeof(sqlcmd),
         "SELECT a.attname, t.typname, a.attlen, a.attnotnull, d.adsrc, a.atttypmod "
         "FROM pg_class c, pg_type t, pg_attribute a "
         "LEFT OUTER JOIN pg_attrdef d ON a.atthasdef AND d.adrelid = a.attrelid "
         "AND d.adnum = a.attnum WHERE c.oid = a.attrelid AND a.atttypid = t.oid "
         "AND (a.attnum > 0) AND c.relname = '%s' ORDER BY c.relname, attnum", tablename);
      }
      /* Query the columns */
      result = PQexec(conn, sqlcmd);
      if (PQresultStatus(result) != PGRES_TUPLES_OK) {
         pgerror = PQresultErrorMessage(result);
         ast_log(LOG_ERROR, "Failed to query database columns: %s\n", pgerror);
         PQclear(result);
         unload_module();
         return AST_MODULE_LOAD_DECLINE;
      }

      rows = PQntuples(result);
      for (i = 0; i < rows; i++) {
         fname = PQgetvalue(result, i, 0);
         ftype = PQgetvalue(result, i, 1);
         flen = PQgetvalue(result, i, 2);
         fnotnull = PQgetvalue(result, i, 3);
         fdef = PQgetvalue(result, i, 4);
         ast_verb(4, "Found column '%s' of type '%s'\n", fname, ftype);
         cur = ast_calloc(1, sizeof(*cur) + strlen(fname) + strlen(ftype) + 2);
         if (cur) {
            sscanf(flen, "%30d", &cur->len);
            cur->name = (char *)cur + sizeof(*cur);
            cur->type = (char *)cur + sizeof(*cur) + strlen(fname) + 1;
            strcpy(cur->name, fname);
            strcpy(cur->type, ftype);
            if (*fnotnull == 't') {
               cur->notnull = 1;
            } else {
               cur->notnull = 0;
            }
            if (!ast_strlen_zero(fdef)) {
               cur->hasdefault = 1;
            } else {
               cur->hasdefault = 0;
            }
            AST_RWLIST_INSERT_TAIL(&psql_columns, cur, list);
         }
      }
      PQclear(result);
   } else {
      pgerror = PQerrorMessage(conn);
      ast_log(LOG_ERROR, "cel_pgsql: Unable to connect to database server %s.  CALLS WILL NOT BE LOGGED!!\n", pghostname);
      ast_log(LOG_ERROR, "cel_pgsql: Reason: %s\n", pgerror);
      connected = 0;
      PQfinish(conn);
      conn = NULL;
   }
   return AST_MODULE_LOAD_SUCCESS;
}

reload()

static int reload ( void  )

static

Definition at line 701 of file cel_pgsql.c.

References AST_MODFLAG_LOAD_ORDER, AST_MODPRI_CDR_DRIVER, AST_MODULE_INFO(), AST_MODULE_SUPPORT_EXTENDED, ASTERISK_GPL_KEY, load_module(), my_load_module(), and unload_module().

{
   return my_load_module(1);
}

unload_module()

static int unload_module ( void  )

static

Definition at line 453 of file cel_pgsql.c.

References my_unload_module().

Referenced by process_my_load_module(), and reload().

{
   return my_unload_module();
}

Variable Documentation

__mod_info

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "PostgreSQL CEL 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 = "30ef0c93b36035ec78c9cfd712d36d9b" , .support_level = AST_MODULE_SUPPORT_EXTENDED, .load = load_module, .unload = unload_module, .reload = reload, .load_pri = AST_MODPRI_CDR_DRIVER, .requires = "cel", }

static

Definition at line 713 of file cel_pgsql.c.

ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info

static

Definition at line 713 of file cel_pgsql.c.

cel_show_user_def

unsigned char cel_show_user_def

static

TRUE if we should set the eventtype field to USER_DEFINED on user events.

Definition at line 83 of file cel_pgsql.c.

Referenced by pgsql_log(), and process_my_load_module().

config

char* config = "cel_pgsql.conf"

static

Definition at line 63 of file cel_pgsql.c.

Referenced by my_load_module().

conn

PGconn* conn = NULL

static

Definition at line 87 of file cel_pgsql.c.

Referenced by my_unload_module(), pgsql_log(), pgsql_reconnect(), and process_my_load_module().

connected

int connected = 0

static

Definition at line 74 of file cel_pgsql.c.

Referenced by pgsql_log(), and process_my_load_module().

maxsize

int maxsize = 512

static

Definition at line 76 of file cel_pgsql.c.

Referenced by pgsql_log().

maxsize2

int maxsize2 = 512

static

Definition at line 76 of file cel_pgsql.c.

Referenced by pgsql_log().

pgappname

char* pgappname

static

Definition at line 69 of file cel_pgsql.c.

Referenced by my_unload_module(), pgsql_reconnect(), and process_my_load_module().

pgdbname

char* pgdbname

static

Definition at line 66 of file cel_pgsql.c.

Referenced by my_unload_module(), pgsql_log(), pgsql_reconnect(), and process_my_load_module().

pgdbport

char* pgdbport

static

Definition at line 70 of file cel_pgsql.c.

Referenced by my_unload_module(), pgsql_reconnect(), and process_my_load_module().

pgdbuser

char* pgdbuser

static

Definition at line 67 of file cel_pgsql.c.

Referenced by my_unload_module(), pgsql_log(), pgsql_reconnect(), and process_my_load_module().

pghostname

char* pghostname

static

Definition at line 65 of file cel_pgsql.c.

Referenced by my_unload_module(), pgsql_log(), pgsql_reconnect(), and process_my_load_module().

pgpassword

char* pgpassword

static

Definition at line 68 of file cel_pgsql.c.

Referenced by my_unload_module(), pgsql_log(), pgsql_reconnect(), and process_my_load_module().

pgsql_lock

ast_mutex_t pgsql_lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }

static

Definition at line 85 of file cel_pgsql.c.

Referenced by pgsql_log().

psql_columns

struct psql_columns psql_columns = { .first = NULL, .last = NULL, .lock = { PTHREAD_RWLOCK_INITIALIZER , NULL, {1, 0} } , }

static

result

PGresult* result = NULL

static

Examples:

/usr/src/asterisk-18.5.0/main/app.c.

Definition at line 88 of file cel_pgsql.c.

Referenced by __ast_channel_alloc(), __ast_string_field_alloc_space(), __astman_get_header(), acf_meetme_info(), action_updateconfig(), ast_build_string(), ast_build_string_va(), ast_config_internal_load(), ast_config_load2(), ast_format_cap_get_compatible_format(), ast_format_cap_get_format_framing(), ast_get_encoded_str(), ast_msg_has_destination(), ast_parse_arg(), ast_privacy_check(), ast_sip_str_to_dtmf(), ast_sip_will_uri_survive_restart(), ast_sockaddr_stringify_port(), ast_speech_results_free(), ast_stir_shaken_add_verification(), AST_TEST_DEFINE(), ast_websocket_client_create(), ast_xml_query(), astman_verify_session_readpermissions(), astman_verify_session_writepermissions(), async_callback(), blackfilter_cmp_fn(), chat(), check_eval(), check_sip_domain(), cli_complete_registration(), complete_sip_peer(), complete_sip_registered_peer(), complete_sip_user(), conf_find_bridge_profile(), conf_find_user_profile(), config_module(), config_mysql(), config_pgsql(), cops_connect(), db_get_common(), destroy_pgsql(), detect_callback(), detzcode(), detzcode64(), dial_exec_full(), dns_query_recurring_resolution_callback(), dtmf_to_str(), dundi_lookup_internal(), error(), evaluate_history_entry(), evaluate_like(), fax_detect_framehook(), fax_gateway_attach(), fax_gateway_detect_t38(), fax_gateway_framehook(), fax_gateway_start(), find_result(), find_table(), gen_match_to_pattern(), generic_fax_exec(), gmtsub(), handle_msg_cb(), handle_request_invite(), handle_skinny_set_debug(), handle_speechrecognize(), handle_standard_bridge_enter_message(), handle_updates(), iax2_codec_pref_index(), inform(), invalid_record_test(), launch_ha_netscript(), ldap_loadentry(), lintocodec2_frameout(), lintogsm_frameout(), lintoilbc_frameout(), lintolpc10_frameout(), lintospeex_frameout(), listfilter(), localized_config_load(), localized_config_load_with_comments(), localsub(), mallocconcat(), malloccopy(), match_filter(), mgcpsock_read(), mwi_thread(), my_connect_db(), MYSQL_exec(), nominal_sync_run(), nominal_test(), odbc_datastore_free(), off_nominal_async_callback(), off_nominal_sync_run(), off_nominal_test(), ogg_speex_open(), ogg_vorbis_open(), op_func(), P3(), parsefilearg(), pgsql_log(), process_my_load_module(), radius_log(), read_credentials(), read_mf_digits(), read_packet(), read_sf_digits(), realtime_ldap_base_ap(), realtime_multi_mysql(), realtime_multi_pgsql(), realtime_mysql(), realtime_pgsql(), receivefax_exec(), require_pgsql(), rtp_address_is_ice_blacklisted(), say(), sdp_crypto_alloc(), sendfax_exec(), sip_report_security_event(), sip_resolve_callback(), sorcery_memory_cache_complete_name(), sorcery_memory_cache_complete_object_name(), speech_grammar(), speech_read(), speech_score(), speech_text(), store_pgsql(), str2tech(), stun_address_is_blacklisted(), subscription_statistics_complete_name(), t30_phase_e_handler(), test_dtmf_amplitude_sweep(), test_dtmf_twist_sweep(), test_execute(), test_results(), test_tone_amplitude_sweep(), test_tone_freq_sweep(), testtime_write(), tmcomp(), topic_statistics_complete_name(), tzload(), update2_pgsql(), update_pgsql(), wait_exec(), and whitefilter_cmp_fn().

schema

char* schema

static

Definition at line 72 of file cel_pgsql.c.

Referenced by load_config(), my_unload_module(), and process_my_load_module().

table

char* table

static

Definition at line 71 of file cel_pgsql.c.

Referenced by my_unload_module(), pgsql_log(), and process_my_load_module().

usegmtime

int usegmtime = 0

static

Definition at line 77 of file cel_pgsql.c.

Referenced by pgsql_log(), and process_my_load_module().