diff --git a/mbuni/extras/pgsql-queue/mms_pgsql_queue.c b/mbuni/extras/pgsql-queue/mms_pgsql_queue.c index 845b3d8..e983a56 100644 --- a/mbuni/extras/pgsql-queue/mms_pgsql_queue.c +++ b/mbuni/extras/pgsql-queue/mms_pgsql_queue.c @@ -174,7 +174,7 @@ static void return_conn_real(PGconn *c, const char *function, const char *file, /* debug("pg_cp", 0, "pg_release_conn> %s:%d, %s => %d", file, line, function, (int)c); */ - if (free_conns == NULL) return; + if (free_conns == NULL || c == NULL) return; /* commit or destroy transaction. */ if (PQtransactionStatus(c) == PQTRANS_INERROR)