src/backend/replication/logical/reorderbuffer.c
void
ReorderBufferAddNewCommandId(ReorderBuffer *rb, TransactionId xid,
							 XLogRecPtr lsn, CommandId cid)
{
	ReorderBufferChange *change = ReorderBufferGetChange(rb);

	change->data.command_id = cid;
	change->action = REORDER_BUFFER_CHANGE_INTERNAL_COMMAND_ID;

	ReorderBufferQueueChange(rb, xid, lsn, change);
}
/*
 * Access the catalog with this CommandId at this point in the changestream.
 *
 * May only be called for command ids > 1
 */
Access the catalog with this CommandId at this point in the changestream.
May only be called for command ids > 1
Access the catalog with this CommandId at this point in the changestream . May only be called for command ids > 1
void
ReorderBufferAddNewCommandId(ReorderBuffer *rb, TransactionId xid,
							 XLogRecPtr lsn, CommandId cid)
{
	ReorderBufferChange *change = ReorderBufferGetChange(rb);
	change->data.command_id = cid;
	change->action = REORDER_BUFFER_CHANGE_INTERNAL_COMMAND_ID;
	ReorderBufferQueueChange(rb, xid, lsn, change);
}
void ReorderBufferAddNewCommandId ( ReorderBuffer * rb , TransactionId xid , XLogRecPtr lsn , CommandId cid ) { ReorderBufferChange * change = ReorderBufferGetChange ( rb ) ; change -> data . command_id = cid ; change -> action = REORDER_BUFFER_CHANGE_INTERNAL_COMMAND_ID ; ReorderBufferQueueChange ( rb , xid , lsn , change ) ; }
Access the catalog with this CommandId at this point in the changestream.
Access the catalog with this CommandId at this point in the changestream .