diff options
| -rw-r--r-- | src/bin/scripts/reindexdb.c | 11 |
1 files changed, 10 insertions, 1 deletions
diff --git a/src/bin/scripts/reindexdb.c b/src/bin/scripts/reindexdb.c index 665864fd22b..b00c8112869 100644 --- a/src/bin/scripts/reindexdb.c +++ b/src/bin/scripts/reindexdb.c @@ -339,7 +339,10 @@ reindex_one_database(ConnParams *cparams, ReindexType type, /* Bail out if nothing to process */ if (process_list == NULL) + { + PQfinish(conn); return; + } break; case REINDEX_SCHEMA: @@ -352,7 +355,10 @@ reindex_one_database(ConnParams *cparams, ReindexType type, /* Bail out if nothing to process */ if (process_list == NULL) + { + PQfinish(conn); return; + } break; case REINDEX_INDEX: @@ -370,7 +376,10 @@ reindex_one_database(ConnParams *cparams, ReindexType type, * in-place, so check if it has at least one cell. */ if (user_list->head == NULL) + { + PQfinish(conn); return; + } /* * Assuming 'user_list' is not empty, 'indices_tables_list' @@ -416,6 +425,7 @@ reindex_one_database(ConnParams *cparams, ReindexType type, sa = ParallelSlotsSetup(concurrentCons, cparams, progname, echo, NULL); ParallelSlotsAdoptConn(sa, conn); + conn = NULL; cell = process_list->head; do @@ -765,7 +775,6 @@ get_parallel_object_list(PGconn *conn, ReindexType type, if (ntups == 0) { PQclear(res); - PQfinish(conn); return NULL; } |