res_config_pgsql.c File Reference

load

00460 {
00461    PGresult *result = NULL;
00462    long num_rows;
00463    struct ast_variable *new_v;
00464    struct ast_category *cur_cat = NULL;
00465    char sql[250] = "";
00466    char last[80] = "";
00467    int last_cat_metric = 0;
00468 
00469    last[0] = '\0';
00470 
00471    if (!file || !strcmp(file, RES_CONFIG_PGSQL_CONF)) {
00472       ast_log(LOG_WARNING, "Postgresql RealTime: Cannot configure myself.\n");
00473       return NULL;
00474    }
00475 
00476    snprintf(sql, sizeof(sql),
00477           "SELECT category, var_name, var_val, cat_metric FROM %s WHERE filename='%s' and commented=0 ORDER BY filename, cat_metric desc, var_metric asc, category, var_name, var_val, id",
00478           table, file);
00479 
00480    if (option_debug)
00481       ast_log(LOG_DEBUG, "Postgresql RealTime: Static SQL: %s\n", sql);
00482 
00483    /* We now have our complete statement; Lets connect to the server and execute it. */
00484    ast_mutex_lock(&pgsql_lock);
00485    if (!pgsql_reconnect(database)) {
00486       ast_mutex_unlock(&pgsql_lock);
00487       return NULL;
00488    }
00489 
00490    if (!(result = PQexec(pgsqlConn, sql))) {
00491       ast_log(LOG_WARNING,
00492             "Postgresql RealTime: Failed to query database. Check debug for more info.\n");
00493       if (option_debug) {
00494          ast_log(LOG_DEBUG, "Postgresql RealTime: Query: %s\n", sql);
00495          ast_log(LOG_DEBUG, "Postgresql RealTime: Query Failed because: %s\n",
00496                PQerrorMessage(pgsqlConn));
00497       }
00498       ast_mutex_unlock(&pgsql_lock);
00499       return NULL;
00500    } else {
00501       ExecStatusType result_status = PQresultStatus(result);
00502       if (result_status != PGRES_COMMAND_OK
00503          && result_status != PGRES_TUPLES_OK
00504          && result_status != PGRES_NONFATAL_ERROR) {
00505          ast_log(LOG_WARNING,
00506                "Postgresql RealTime: Failed to query database. Check debug for more info.\n");
00507          if (option_debug) {
00508             ast_log(LOG_DEBUG, "Postgresql RealTime: Query: %s\n", sql);
00509             ast_log(LOG_DEBUG, "Postgresql RealTime: Query Failed because: %s (%s)\n",
00510                   PQresultErrorMessage(result), PQresStatus(result_status));
00511          }
00512          ast_mutex_unlock(&pgsql_lock);
00513          return NULL;
00514       }
00515    }
00516 
00517    if ((num_rows = PQntuples(result)) > 0) {
00518       int numFields = PQnfields(result);
00519       int i = 0;
00520       int rowIndex = 0;
00521       char **fieldnames = NULL;
00522 
00523       if (option_debug)
00524          ast_log(LOG_DEBUG, "Postgresql RealTime: Found %ld rows.\n", num_rows);
00525 
00526       if (!(fieldnames = ast_calloc(1, numFields * sizeof(char *)))) {
00527          ast_mutex_unlock(&pgsql_lock);
00528          PQclear(result);
00529          return NULL;
00530       }
00531       for (i = 0; i < numFields; i++)
00532          fieldnames[i] = PQfname(result, i);
00533 
00534       for (rowIndex = 0; rowIndex < num_rows; rowIndex++) {
00535          char *field_category = PQgetvalue(result, rowIndex, 0);
00536          char *field_var_name = PQgetvalue(result, rowIndex, 1);
00537          char *field_var_val = PQgetvalue(result, rowIndex, 2);
00538          char *field_cat_metric = PQgetvalue(result, rowIndex, 3);
00539          if (!strcmp(field_var_name, "#include")) {
00540             if (!ast_config_internal_load(field_var_val, cfg, 0)) {
00541                PQclear(result);
00542                ast_mutex_unlock(&pgsql_lock);
00543                return NULL;
00544             }
00545             continue;
00546          }
00547 
00548          if (strcmp(last, field_category) || last_cat_metric != atoi(field_cat_metric)) {
00549             cur_cat = ast_category_new(field_category);
00550             if (!cur_cat)
00551                break;
00552             strcpy(last, field_category);
00553             last_cat_metric = atoi(field_cat_metric);
00554             ast_category_append(cfg, cur_cat);
00555          }
00556          new_v = ast_variable_new(field_var_name, field_var_val);
00557          ast_variable_append(cur_cat, new_v);
00558       }
00559    } else {
00560       ast_log(LOG_WARNING,
00561             "Postgresql RealTime: Could not find config '%s' in database.\n", file);
00562    }
00563 
00564    PQclear(result);
00565    ast_mutex_unlock(&pgsql_lock);
00566 
00567    return cfg;
00568 }


Defines
#define	MAX_DB_OPTION_SIZE 64
#define	RES_CONFIG_PGSQL_CONF "res_pgsql.conf"
Functions
	AST_MODULE_INFO (ASTERISK_GPL_KEY, AST_MODFLAG_GLOBAL_SYMBOLS,"PostgreSQL RealTime Configuration Driver",.load=load_module,.unload=unload_module,.reload=reload)
	AST_MUTEX_DEFINE_STATIC (pgsql_lock)
static struct ast_config *	config_pgsql (const char database, const char table, const char file, struct ast_config cfg, int withcomments)
static int	load_module (void)
static int	parse_config (void)
static int	pgsql_reconnect (const char *database)
static struct ast_config *	realtime_multi_pgsql (const char database, const char table, va_list ap)
static struct ast_variable *	realtime_pgsql (const char database, const char table, va_list ap)
static int	realtime_pgsql_status (int fd, int argc, char **argv)
static int	reload (void)
static int	unload_module (void)
static int	update_pgsql (const char database, const char table, const char keyfield, const char lookup, va_list ap)
Variables
static struct ast_cli_entry	cli_realtime []
static const char	cli_realtime_pgsql_status_usage []
static time_t	connect_time = 0
static char	dbhost [MAX_DB_OPTION_SIZE] = ""
static char	dbname [MAX_DB_OPTION_SIZE] = ""
static char	dbpass [MAX_DB_OPTION_SIZE] = ""
static int	dbport = 5432
static char	dbsock [MAX_DB_OPTION_SIZE] = ""
static char	dbuser [MAX_DB_OPTION_SIZE] = ""
static struct ast_config_engine	pgsql_engine
PGconn *	pgsqlConn = NULL

Asterisk developer's documentation :: Codename Pineapple

res_config_pgsql.c File Reference

Detailed Description

Defines

Functions

Variables

Define Documentation

Function Documentation

Variable Documentation