@@ -341,14 +341,14 @@ csn_t MtmTransactionSnapshot(TransactionId xid)
341341Snapshot MtmGetSnapshot (Snapshot snapshot )
342342{
343343snapshot = PgGetSnapshotData (snapshot );
344- RecentGlobalDataXmin = RecentGlobalXmin = MtmAdjustOldestXid (RecentGlobalDataXmin );
344+ RecentGlobalDataXmin = RecentGlobalXmin = Mtm -> oldestXid ; // MtmAdjustOldestXid(RecentGlobalDataXmin);
345345return snapshot ;
346346}
347347
348348
349349TransactionId MtmGetOldestXmin (Relation rel ,bool ignoreVacuum )
350350{
351- TransactionId xmin = PgGetOldestXmin (NULL ,ignoreVacuum );/* consider all backends */
351+ TransactionId xmin = PgGetOldestXmin (NULL ,false );/* consider all backends */
352352xmin = MtmAdjustOldestXid (xmin );
353353return xmin ;
354354}
@@ -539,7 +539,8 @@ MtmAdjustOldestXid(TransactionId xid)
539539if (prev != NULL ) {
540540Mtm -> transListHead = prev ;
541541Mtm -> oldestXid = xid = prev -> xid ;
542- }else if (TransactionIdPrecedes (Mtm -> oldestXid ,xid )) {
542+ }else {
543+ Assert (TransactionIdPrecedesOrEqual (Mtm -> oldestXid ,xid ));
543544xid = Mtm -> oldestXid ;
544545}
545546}else {