src/backend/replication/logical/reorderbuffer.c
void
ReorderBufferAbort(ReorderBuffer *rb, TransactionId xid, XLogRecPtr lsn)
{
	ReorderBufferTXN *txn;

	txn = ReorderBufferTXNByXid(rb, xid, false, NULL, InvalidXLogRecPtr,
								false);

	/* unknown, nothing to remove */
	if (txn == NULL)
		return;

	/* cosmetic... */
	txn->final_lsn = lsn;

	/* remove potential on-disk data, and deallocate */
	ReorderBufferCleanupTXN(rb, txn);
}
/*
 * Abort a transaction that possibly has previous changes. Needs to be first
 * called for subtransactions and then for the toplevel xid.
 *
 * NB: Transactions handled here have to have actively aborted (i.e. have
 * produced an abort record). Implicitly aborted transactions are handled via
 * ReorderBufferAbortOld(); transactions we're just not interesteded in, but
 * which have committed are handled in ReorderBufferForget().
 *
 * This function purges this transaction and its contents from memory and
 * disk.
 */
Abort a transaction that possibly has previous changes. Needs to be first
called for subtransactions and then for the toplevel xid.

Transactions handled here have to have actively aborted . Implicitly aborted transactions are handled via
ReorderBufferAbortOld(); transactions we're just not interesteded in, but
which have committed are handled in ReorderBufferForget().

This function purges this transaction and its contents from memory and
disk.
Abort a transaction that possibly has previous changes . Needs to be first called for subtransactions and then for the toplevel xid . Transactions handled here have to have actively aborted . Implicitly aborted transactions are handled via ReorderBufferAbortOld () ; transactions we ' re just not interesteded in but which have committed are handled in ReorderBufferForget () . This function purges this transaction and its contents from memory and disk .
void
ReorderBufferAbort(ReorderBuffer *rb, TransactionId xid, XLogRecPtr lsn)
{
	ReorderBufferTXN *txn;
	txn = ReorderBufferTXNByXid(rb, xid, false, NULL, InvalidXLogRecPtr,
								false);
	if (txn == NULL)
		return;
	txn->final_lsn = lsn;
	ReorderBufferCleanupTXN(rb, txn);
}
void ReorderBufferAbort ( ReorderBuffer * rb , TransactionId xid , XLogRecPtr lsn ) { ReorderBufferTXN * txn ; txn = ReorderBufferTXNByXid ( rb , xid , false , NULL , InvalidXLogRecPtr , false ) ; if ( txn == NULL ) return ; txn -> final_lsn = lsn ; ReorderBufferCleanupTXN ( rb , txn ) ; }
Abort a transaction that possibly has previous changes.
Abort a transaction that possibly has previous changes .
/* unknown, nothing to remove */ /* cosmetic... */ /* remove potential on-disk data, and deallocate */