commit 3cea669a2c7c69991272b8f0aef644014f280ffb
parent 7f1a9b8092454eba6ab91467a8f88bbdf307dd65
Author: Joris Vink <joris@coders.se>
Date: Tue, 11 Jul 2017 15:19:44 +0200
call pgsql_conn_cleanup() in case of an error in rollback.
Diffstat:
1 file changed, 4 insertions(+), 0 deletions(-)
diff --git a/src/pgsql.c b/src/pgsql.c
@@ -744,10 +744,14 @@ pgsql_cancel(struct kore_pgsql *pgsql)
static void
pgsql_rollback_state(struct kore_pgsql *pgsql, void *arg)
{
+ struct pgsql_conn *conn;
+
switch (pgsql->state) {
case KORE_PGSQL_STATE_ERROR:
+ conn = pgsql->conn;
kore_pgsql_logerror(pgsql);
kore_pgsql_cleanup(pgsql);
+ pgsql_conn_cleanup(conn);
break;
case KORE_PGSQL_STATE_COMPLETE:
kore_pgsql_cleanup(pgsql);