|
|
@ -87,8 +87,9 @@ static int pgsql_log(struct ast_cdr *cdr)
|
|
|
|
connected = 1;
|
|
|
|
connected = 1;
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
pgerror = PQerrorMessage(conn);
|
|
|
|
pgerror = PQerrorMessage(conn);
|
|
|
|
|
|
|
|
PQfinish(conn);
|
|
|
|
ast_log(LOG_ERROR, "cdr_pgsql: Unable to connect to database server %s. Calls will not be logged!\n", pghostname);
|
|
|
|
ast_log(LOG_ERROR, "cdr_pgsql: Unable to connect to database server %s. Calls will not be logged!\n", pghostname);
|
|
|
|
ast_log(LOG_ERROR, "cdr_pgsql: Reason: %s\n", pgerror);
|
|
|
|
ast_log(LOG_ERROR, "cdr_pgsql: Reason: %s\n", pgerror);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
@ -144,6 +145,7 @@ static int pgsql_log(struct ast_cdr *cdr)
|
|
|
|
connected = 1;
|
|
|
|
connected = 1;
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
pgerror = PQerrorMessage(conn);
|
|
|
|
pgerror = PQerrorMessage(conn);
|
|
|
|
|
|
|
|
PQfinish(conn);
|
|
|
|
ast_log(LOG_ERROR, "cdr_pgsql: Unable to reconnect to database server %s. Calls will not be logged!\n", pghostname);
|
|
|
|
ast_log(LOG_ERROR, "cdr_pgsql: Unable to reconnect to database server %s. Calls will not be logged!\n", pghostname);
|
|
|
|
ast_log(LOG_ERROR, "cdr_pgsql: Reason: %s\n", pgerror);
|
|
|
|
ast_log(LOG_ERROR, "cdr_pgsql: Reason: %s\n", pgerror);
|
|
|
|
connected = 0;
|
|
|
|
connected = 0;
|
|
|
@ -161,6 +163,7 @@ static int pgsql_log(struct ast_cdr *cdr)
|
|
|
|
if (PQstatus(conn) == CONNECTION_OK) {
|
|
|
|
if (PQstatus(conn) == CONNECTION_OK) {
|
|
|
|
ast_log(LOG_ERROR, "cdr_pgsql: Connection reestablished.\n");
|
|
|
|
ast_log(LOG_ERROR, "cdr_pgsql: Connection reestablished.\n");
|
|
|
|
connected = 1;
|
|
|
|
connected = 1;
|
|
|
|
|
|
|
|
PQclear(result);
|
|
|
|
result = PQexec(conn, sqlcmd);
|
|
|
|
result = PQexec(conn, sqlcmd);
|
|
|
|
if (PQresultStatus(result) != PGRES_COMMAND_OK) {
|
|
|
|
if (PQresultStatus(result) != PGRES_COMMAND_OK) {
|
|
|
|
pgerror = PQresultErrorMessage(result);
|
|
|
|
pgerror = PQresultErrorMessage(result);
|
|
|
|