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

	txn = ReorderBufferTXNByXid(rb, xid, true, NULL, lsn, true);

	change->lsn = lsn;
	Assert(InvalidXLogRecPtr != lsn);
	dlist_push_tail(&txn->changes, &change->node);
	txn->nentries++;
	txn->nentries_mem++;

	ReorderBufferCheckSerializeTXN(rb, txn);
}
/*
 * Queue a change into a transaction so it can be replayed upon commit.
 */
Queue a change into a transaction so it can be replayed upon commit.
Queue a change into a transaction so it can be replayed upon commit .
void
ReorderBufferQueueChange(ReorderBuffer *rb, TransactionId xid, XLogRecPtr lsn,
						 ReorderBufferChange *change)
{
	ReorderBufferTXN *txn;
	txn = ReorderBufferTXNByXid(rb, xid, true, NULL, lsn, true);
	change->lsn = lsn;
	Assert(InvalidXLogRecPtr != lsn);
	dlist_push_tail(&txn->changes, &change->node);
	txn->nentries++;
	txn->nentries_mem++;
	ReorderBufferCheckSerializeTXN(rb, txn);
}
void ReorderBufferQueueChange ( ReorderBuffer * rb , TransactionId xid , XLogRecPtr lsn , ReorderBufferChange * change ) { ReorderBufferTXN * txn ; txn = ReorderBufferTXNByXid ( rb , xid , true , NULL , lsn , true ) ; change -> lsn = lsn ; Assert ( InvalidXLogRecPtr != lsn ) ; dlist_push_tail ( & txn -> changes , & change -> node ) ; txn -> nentries ++ ; txn -> nentries_mem ++ ; ReorderBufferCheckSerializeTXN ( rb , txn ) ; }
Queue a change into a transaction so it can be replayed upon commit.
Queue a change into a transaction so it can be replayed upon commit .