kenmirrors/asterisk
1
0
Fork 0
mirror of https://github.com/asterisk/asterisk.git synced 2025-10-12 15:45:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

various fixes (bug #3340)

Browse Source 
git-svn-id: https://origsvn.digium.com/svn/asterisk/branches/v1-0@4819 65c4cc65-6c06-0410-ace0-fbb531ad65f3
This commit is contained in:
Russell Bryant
2005-01-17 01:43:33 +00:00
parent a87fb09763
commit 4f5f53706d
1 changed files with 27 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files

59
cdr/cdr_odbc.c
View File

@@ -3,13 +3,12 @@
* *
* ODBC CDR Backend * ODBC CDR Backend
* *
* Copyright (C) 2003-2005, Digium, Inc.
*
* Brian K. West <brian@bkw.org> * Brian K. West <brian@bkw.org>
* *
* This program is free software, distributed under the terms of * This program is free software, distributed under the terms of
* the GNU General Public License. * the GNU General Public License
*
* Copyright (c) 2003 Digium, Inc.
*
*/ */
#include <sys/types.h> #include <sys/types.h>
@@ -37,8 +36,9 @@
static char *desc = "ODBC CDR Backend"; static char *desc = "ODBC CDR Backend";
static char *name = "ODBC"; static char *name = "ODBC";
static char *config = "cdr_odbc.conf"; static char *config = "cdr_odbc.conf";
static char *dsn = NULL, *username = NULL, *password = NULL, *loguniqueid = NULL; static char *dsn = NULL, *username = NULL, *password = NULL;
static int dsn_alloc = 0, username_alloc = 0, password_alloc = 0, loguniqueid_alloc = 0; static int dsn_alloc = 0, username_alloc = 0, password_alloc = 0;
static int loguniqueid = 0;
static int connected = 0; static int connected = 0;
AST_MUTEX_DEFINE_STATIC(odbc_lock); AST_MUTEX_DEFINE_STATIC(odbc_lock);
@@ -65,7 +65,7 @@ static int odbc_log(struct ast_cdr *cdr)
ast_mutex_lock(&odbc_lock); ast_mutex_lock(&odbc_lock);
strftime(timestr, sizeof(timestr), DATE_FORMAT, &tm); strftime(timestr, sizeof(timestr), DATE_FORMAT, &tm);
memset(sqlcmd,0,2048); memset(sqlcmd,0,2048);
if ((loguniqueid != NULL) && (ast_true(loguniqueid))) { if (loguniqueid) {
snprintf(sqlcmd,sizeof(sqlcmd),"INSERT INTO cdr " snprintf(sqlcmd,sizeof(sqlcmd),"INSERT INTO cdr "
"(calldate,clid,src,dst,dcontext,channel,dstchannel,lastapp," "(calldate,clid,src,dst,dcontext,channel,dstchannel,lastapp,"
"lastdata,duration,billsec,disposition,amaflags,accountcode,uniqueid,userfield) " "lastdata,duration,billsec,disposition,amaflags,accountcode,uniqueid,userfield) "
@@ -78,13 +78,12 @@ static int odbc_log(struct ast_cdr *cdr)
} }
if (!connected) { if (!connected) {
res = odbc_init(); res = odbc_init();
if (res < 0) { if (res < 0) {
connected = 0; connected = 0;
ast_mutex_unlock(&odbc_lock); ast_mutex_unlock(&odbc_lock);
return 0; return 0;
} }
} }
ODBC_res = SQLAllocHandle(SQL_HANDLE_STMT, ODBC_con, &ODBC_stmt); ODBC_res = SQLAllocHandle(SQL_HANDLE_STMT, ODBC_con, &ODBC_stmt);
@@ -130,7 +129,7 @@ static int odbc_log(struct ast_cdr *cdr)
SQLBindParameter(ODBC_stmt, 13, SQL_PARAM_INPUT, SQL_C_SLONG, SQL_INTEGER, 0, 0, &cdr->amaflags, 0, NULL); SQLBindParameter(ODBC_stmt, 13, SQL_PARAM_INPUT, SQL_C_SLONG, SQL_INTEGER, 0, 0, &cdr->amaflags, 0, NULL);
SQLBindParameter(ODBC_stmt, 14, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, sizeof(cdr->accountcode), 0, cdr->accountcode, 0, NULL); SQLBindParameter(ODBC_stmt, 14, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, sizeof(cdr->accountcode), 0, cdr->accountcode, 0, NULL);
if ((loguniqueid != NULL) && (ast_true(loguniqueid))) { if (loguniqueid) {
SQLBindParameter(ODBC_stmt, 15, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, sizeof(cdr->uniqueid), 0, cdr->uniqueid, 0, NULL); SQLBindParameter(ODBC_stmt, 15, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, sizeof(cdr->uniqueid), 0, cdr->uniqueid, 0, NULL);
SQLBindParameter(ODBC_stmt, 16, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, sizeof(cdr->userfield), 0, cdr->userfield, 0, NULL); SQLBindParameter(ODBC_stmt, 16, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, sizeof(cdr->userfield), 0, cdr->userfield, 0, NULL);
} }
@@ -204,13 +203,8 @@ static int odbc_unload_module(void)
password = NULL; password = NULL;
password_alloc = 0; password_alloc = 0;
} }
if (loguniqueid && loguniqueid_alloc) { loguniqueid = 0;
if (option_verbose > 10)
ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: free loguniqueid\n");
free(loguniqueid);
loguniqueid = NULL;
loguniqueid_alloc = 0;
}
ast_cdr_unregister(name); ast_cdr_unregister(name);
ast_mutex_unlock(&odbc_lock); ast_mutex_unlock(&odbc_lock);
return 0; return 0;
@@ -246,7 +240,8 @@ static int odbc_load_module(void)
strncpy(dsn, tmp, strlen(tmp)); strncpy(dsn, tmp, strlen(tmp));
} else { } else {
ast_log(LOG_ERROR,"cdr_odbc: Out of memory error.\n"); ast_log(LOG_ERROR,"cdr_odbc: Out of memory error.\n");
return -1; res = -1;
goto out;
} }
} else { } else {
ast_log(LOG_WARNING,"cdr_odbc: dsn not specified. Assuming asteriskdb\n"); ast_log(LOG_WARNING,"cdr_odbc: dsn not specified. Assuming asteriskdb\n");
@@ -262,7 +257,8 @@ static int odbc_load_module(void)
strncpy(username, tmp, strlen(tmp)); strncpy(username, tmp, strlen(tmp));
} else { } else {
ast_log(LOG_ERROR,"cdr_odbc: Out of memory error.\n"); ast_log(LOG_ERROR,"cdr_odbc: Out of memory error.\n");
return -1; res = -1;
goto out;
} }
} else { } else {
ast_log(LOG_WARNING,"cdr_odbc: username not specified. Assuming root\n"); ast_log(LOG_WARNING,"cdr_odbc: username not specified. Assuming root\n");
@@ -278,7 +274,8 @@ static int odbc_load_module(void)
strncpy(password, tmp, strlen(tmp)); strncpy(password, tmp, strlen(tmp));
} else { } else {
ast_log(LOG_ERROR,"cdr_odbc: Out of memory error.\n"); ast_log(LOG_ERROR,"cdr_odbc: Out of memory error.\n");
return -1; res = -1;
goto out;
} }
} else { } else {
ast_log(LOG_WARNING,"cdr_odbc: database password not specified. Assuming blank\n"); ast_log(LOG_WARNING,"cdr_odbc: database password not specified. Assuming blank\n");
@@ -287,32 +284,30 @@ static int odbc_load_module(void)
tmp = ast_variable_retrieve(cfg,"global","loguniqueid"); tmp = ast_variable_retrieve(cfg,"global","loguniqueid");
if (tmp) { if (tmp) {
loguniqueid = malloc(strlen(tmp) + 1); loguniqueid = ast_true(tmp);
if (loguniqueid != NULL) { if (loguniqueid) {
strcpy(loguniqueid,tmp);
loguniqueid_alloc = 1;
ast_log(LOG_NOTICE,"cdr_odbc: Logging uniqueid\n"); ast_log(LOG_NOTICE,"cdr_odbc: Logging uniqueid\n");
} else { } else {
ast_log(LOG_ERROR,"cdr_odbc: Not logging uniqueid\n"); ast_log(LOG_ERROR,"cdr_odbc: Not logging uniqueid\n");
loguniqueid_alloc = 1;
loguniqueid = NULL;
} }
} else { } else {
ast_log(LOG_WARNING,"cdr_odbc: Not logging uniqueid\n"); ast_log(LOG_WARNING,"cdr_odbc: Not logging uniqueid\n");
loguniqueid = NULL; loguniqueid = 0;
} }
ast_destroy(cfg); ast_destroy(cfg);
if (option_verbose > 3) { if (option_verbose > 2) {
ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: dsn is %s\n",dsn); ast_verbose( VERBOSE_PREFIX_3 "cdr_odbc: dsn is %s\n",dsn);
ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: username is %s\n",username); ast_verbose( VERBOSE_PREFIX_3 "cdr_odbc: username is %s\n",username);
ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: password is [secret]\n"); ast_verbose( VERBOSE_PREFIX_3 "cdr_odbc: password is [secret]\n");
} }
res = odbc_init(); res = odbc_init();
if (res < 0) { if (res < 0) {
ast_log(LOG_ERROR, "cdr_odbc: Unable to connect to datasource: %s\n", dsn); ast_log(LOG_ERROR, "cdr_odbc: Unable to connect to datasource: %s\n", dsn);
ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Unable to connect to datasource: %s\n", dsn); if (option_verbose > 2) {
ast_verbose( VERBOSE_PREFIX_3 "cdr_odbc: Unable to connect to datasource: %s\n", dsn);
}
} }
res = ast_cdr_register(name, desc, odbc_log); res = ast_cdr_register(name, desc, odbc_log);
if (res) { if (res) {