File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -342,14 +342,14 @@ csn_t MtmTransactionSnapshot(TransactionId xid)
342
342
Snapshot MtmGetSnapshot (Snapshot snapshot )
343
343
{
344
344
snapshot = PgGetSnapshotData (snapshot );
345
- RecentGlobalDataXmin = RecentGlobalXmin = MtmAdjustOldestXid (RecentGlobalDataXmin );
345
+ RecentGlobalDataXmin = RecentGlobalXmin = Mtm -> oldestXid ; // MtmAdjustOldestXid(RecentGlobalDataXmin);
346
346
return snapshot ;
347
347
}
348
348
349
349
350
350
TransactionId MtmGetOldestXmin (Relation rel , bool ignoreVacuum )
351
351
{
352
- TransactionId xmin = PgGetOldestXmin (NULL , ignoreVacuum ); /* consider all backends */
352
+ TransactionId xmin = PgGetOldestXmin (NULL , false ); /* consider all backends */
353
353
xmin = MtmAdjustOldestXid (xmin );
354
354
return xmin ;
355
355
}
@@ -540,7 +540,8 @@ MtmAdjustOldestXid(TransactionId xid)
540
540
if (prev != NULL ) {
541
541
Mtm -> transListHead = prev ;
542
542
Mtm -> oldestXid = xid = prev -> xid ;
543
- } else if (TransactionIdPrecedes (Mtm -> oldestXid , xid )) {
543
+ } else {
544
+ Assert (TransactionIdPrecedesOrEqual (Mtm -> oldestXid , xid ));
544
545
xid = Mtm -> oldestXid ;
545
546
}
546
547
} else {
You can’t perform that action at this time.
0 commit comments