replorigin = (replorigin_session_origin != InvalidRepOriginId &&
replorigin_session_origin != DoNotReplicateId);
- /*
- * Begin commit critical section and insert the commit XLOG record.
- */
- /* Tell bufmgr and smgr to prepare for commit */
- BufmgrCommit();
-
/*
* Mark ourselves as within our "commit critical section". This
* forces any concurrent checkpoint to wait until we've updated
START_CRIT_SECTION();
MyProc->delayChkptFlags |= DELAY_CHKPT_START;
+ /*
+ * Insert the commit XLOG record.
+ */
XactLogCommitRecord(GetCurrentTransactionStopTimestamp(),
nchildren, children, nrels, rels,
ndroppedstats, droppedstats,
prepared_at = GetCurrentTimestamp();
- /* Tell bufmgr and smgr to prepare for commit */
- BufmgrCommit();
-
/*
* Reserve the GID for this transaction. This could fail if the requested
* GID is invalid or already in use.
BufferSync(flags);
}
-
-/*
- * Do whatever is needed to prepare for commit at the bufmgr and smgr levels
- */
-void
-BufmgrCommit(void)
-{
- /* Nothing to do in bufmgr anymore... */
-}
-
/*
* BufferGetBlockNumber
* Returns the block number associated with a buffer.
extern void AbortBufferIO(void);
-extern void BufmgrCommit(void);
extern bool BgBufferSync(struct WritebackContext *wb_context);
extern void TestForOldSnapshot_impl(Snapshot snapshot, Relation relation);