@@ -342,14 +342,14 @@ csn_t MtmTransactionSnapshot(TransactionId xid)
342342Snapshot MtmGetSnapshot (Snapshot snapshot )
343343{
344344snapshot = PgGetSnapshotData (snapshot );
345- RecentGlobalDataXmin = RecentGlobalXmin = MtmAdjustOldestXid (RecentGlobalDataXmin );
345+ RecentGlobalDataXmin = RecentGlobalXmin = Mtm -> oldestXid ; // MtmAdjustOldestXid(RecentGlobalDataXmin);
346346return snapshot ;
347347}
348348
349349
350350TransactionId MtmGetOldestXmin (Relation rel ,bool ignoreVacuum )
351351{
352- TransactionId xmin = PgGetOldestXmin (NULL ,ignoreVacuum );/* consider all backends */
352+ TransactionId xmin = PgGetOldestXmin (NULL ,false );/* consider all backends */
353353xmin = MtmAdjustOldestXid (xmin );
354354return xmin ;
355355}
@@ -540,7 +540,8 @@ MtmAdjustOldestXid(TransactionId xid)
540540if (prev != NULL ) {
541541Mtm -> transListHead = prev ;
542542Mtm -> oldestXid = xid = prev -> xid ;
543- }else if (TransactionIdPrecedes (Mtm -> oldestXid ,xid )) {
543+ }else {
544+ Assert (TransactionIdPrecedesOrEqual (Mtm -> oldestXid ,xid ));
544545xid = Mtm -> oldestXid ;
545546}
546547}else {