]> git.ipfire.org Git - thirdparty/asterisk.git/commitdiff
Fix a memory leak pointed out by prashant_jois in #asterisk-bugs. PQclear() was
authorRussell Bryant <russell@russellbryant.com>
Tue, 12 Jun 2007 19:40:17 +0000 (19:40 +0000)
committerRussell Bryant <russell@russellbryant.com>
Tue, 12 Jun 2007 19:40:17 +0000 (19:40 +0000)
not called on the result structure after doing a PQexec().  Also, fix up some
formatting in passing.

git-svn-id: https://origsvn.digium.com/svn/asterisk/branches/1.4@69016 65c4cc65-6c06-0410-ace0-fbb531ad65f3

cdr/cdr_pgsql.c

index e8f5b73c1681444dec7b89dffcd5cbb196d9e3b6..dd43b45ba36531761f535f1a8ce0ef3b5dd613a5 100644 (file)
@@ -67,13 +67,13 @@ static int connected = 0;
 AST_MUTEX_DEFINE_STATIC(pgsql_lock);
 
 static PGconn  *conn = NULL;
-static PGresult        *result = NULL;
 
 static int pgsql_log(struct ast_cdr *cdr)
 {
        struct tm tm;
        char sqlcmd[2048] = "", timestr[128];
        char *pgerror;
+       PGresult *result;
 
        ast_mutex_lock(&pgsql_lock);
 
@@ -153,26 +153,27 @@ static int pgsql_log(struct ast_cdr *cdr)
                        }
                }
                result = PQexec(conn, sqlcmd);
-               if ( PQresultStatus(result) != PGRES_COMMAND_OK) {
-                        pgerror = PQresultErrorMessage(result);
+               if (PQresultStatus(result) != PGRES_COMMAND_OK) {
+                       pgerror = PQresultErrorMessage(result);
                        ast_log(LOG_ERROR,"cdr_pgsql: Failed to insert call detail record into database!\n");
-                        ast_log(LOG_ERROR,"cdr_pgsql: Reason: %s\n", pgerror);
+                       ast_log(LOG_ERROR,"cdr_pgsql: Reason: %s\n", pgerror);
                        ast_log(LOG_ERROR,"cdr_pgsql: Connection may have been lost... attempting to reconnect.\n");
                        PQreset(conn);
                        if (PQstatus(conn) == CONNECTION_OK) {
                                ast_log(LOG_ERROR, "cdr_pgsql: Connection reestablished.\n");
                                connected = 1;
                                result = PQexec(conn, sqlcmd);
-                               if ( PQresultStatus(result) != PGRES_COMMAND_OK)
-                               {
+                               if (PQresultStatus(result) != PGRES_COMMAND_OK) {
                                        pgerror = PQresultErrorMessage(result);
                                        ast_log(LOG_ERROR,"cdr_pgsql: HARD ERROR!  Attempted reconnection failed.  DROPPING CALL RECORD!\n");
                                        ast_log(LOG_ERROR,"cdr_pgsql: Reason: %s\n", pgerror);
                                }
                        }
                        ast_mutex_unlock(&pgsql_lock);
+                       PQclear(result);
                        return -1;
                }
+               PQclear(result);
        }
        ast_mutex_unlock(&pgsql_lock);
        return 0;