Allow skipping transactions for ReorderBufferAbortOld()

Transactions need to be marked as RBTXN_DISTR_SKIP_CLEANUP to be skipped in
ReorderBufferAbortOld().

Author: akorotkov

src/backend/replication/logical/reorderbuffer.c

@@ -2992,7 +2992,8 @@ ReorderBufferAbortOld(ReorderBuffer *rb, TransactionId oldestRunningXid)
 
 		txn = dlist_container(ReorderBufferTXN, node, it.cur);
 
-		if (TransactionIdPrecedes(txn->xid, oldestRunningXid))
+		if (!(txn->txn_flags & RBTXN_DISTR_SKIP_CLEANUP) &&
+			TransactionIdPrecedes(txn->xid, oldestRunningXid))
 		{
 			elog(DEBUG2, "aborting old transaction %u", txn->xid);
 

src/include/replication/reorderbuffer.h

@@ -187,6 +187,7 @@ typedef struct ReorderBufferChange
 #define RBTXN_SKIPPED_PREPARE	  		0x0080
 #define RBTXN_HAS_STREAMABLE_CHANGE		0x0100
 #define RBTXN_DISTR_INVAL_OVERFLOWED	0x0200
+#define RBTXN_DISTR_SKIP_CLEANUP		0x0400
 
 /* Does the transaction have catalog changes? */
 #define rbtxn_has_catalog_changes(txn) \