File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -1253,6 +1253,10 @@ repack_one_table(const repack_table *table, const char *orderby)
1253
1253
if (vxid )
1254
1254
free (vxid );
1255
1255
1256
+ /* Rollback current transactions */
1257
+ pgut_rollback (connection );
1258
+ pgut_rollback (conn2 );
1259
+
1256
1260
/* XXX: distinguish between fatal and non-fatal errors via the first
1257
1261
* arg to repack_cleanup().
1258
1262
*/
@@ -1491,10 +1495,6 @@ repack_cleanup(bool fatal, const repack_table *table)
1491
1495
char buffer [12 ];
1492
1496
const char * params [1 ];
1493
1497
1494
- /* Rollback current transactions */
1495
- pgut_rollback (connection );
1496
- pgut_rollback (conn2 );
1497
-
1498
1498
/* Try reconnection if not available. */
1499
1499
if (PQstatus (connection ) != CONNECTION_OK ||
1500
1500
PQstatus (conn2 ) != CONNECTION_OK )
You can’t perform that action at this time.
0 commit comments