@@ -148,9 +148,11 @@ static void MtmAbortPreparedTransaction(MtmCurrentTrans* x);
148
148
static void MtmPreCommitPreparedTransaction (MtmCurrentTrans * x );
149
149
static void MtmEndTransaction (MtmCurrentTrans * x , bool commit );
150
150
static bool MtmTwoPhaseCommit (MtmCurrentTrans * x );
151
- static TransactionId MtmGetOldestXmin (Relation rel , bool ignoreVacuum );
152
- // static bool MtmXidInMVCCSnapshot(TransactionId xid, Snapshot snapshot);
151
+
152
+ static TransactionId MtmGetOldestXmin (Relation rel , int flags );
153
+ //static bool MtmXidInMVCCSnapshot(TransactionId xid, Snapshot snapshot);
153
154
static void MtmAdjustOldestXid (void );
155
+
154
156
static bool MtmDetectGlobalDeadLock (PGPROC * proc );
155
157
static void MtmAddSubtransactions (MtmTransState * ts , TransactionId * subxids , int nSubxids );
156
158
static char const * MtmGetName (void );
@@ -609,9 +611,9 @@ Snapshot MtmGetSnapshot(Snapshot snapshot)
609
611
}
610
612
611
613
612
- TransactionId MtmGetOldestXmin (Relation rel , bool ignoreVacuum )
614
+ TransactionId MtmGetOldestXmin (Relation rel , int flags )
613
615
{
614
- TransactionId xmin = PgGetOldestXmin (rel , ignoreVacuum ); /* consider all backends */
616
+ TransactionId xmin = PgGetOldestXmin (rel , flags ); /* consider all backends */
615
617
// if (TransactionIdIsValid(xmin)) {
616
618
// MtmLock(LW_EXCLUSIVE);
617
619
// xmin = MtmAdjustOldestXid(xmin);
0 commit comments