Location via proxy:   [ UP ]  
[Report a bug]   [Manage cookies]                
Skip to content

Commit 744e089

Browse files
committed
Use volkwagen more for OldestXmin adjustment
1 parent 395ac0c commit 744e089

File tree

1 file changed

+3
-5
lines changed

1 file changed

+3
-5
lines changed

contrib/mmts/multimaster.c

+3-5
Original file line numberDiff line numberDiff line change
@@ -580,10 +580,6 @@ MtmAdjustOldestXid(TransactionId xid)
580580
ts != NULL
581581
&& ts->csn < oldestSnapshot
582582
&& TransactionIdPrecedes(ts->xid, xid);
583-
/*
584-
&& (ts->status == TRANSACTION_STATUS_COMMITTED ||
585-
ts->status == TRANSACTION_STATUS_ABORTED);
586-
*/
587583
prev = ts, ts = ts->next)
588584
{
589585
if (prev != NULL) {
@@ -594,7 +590,7 @@ MtmAdjustOldestXid(TransactionId xid)
594590
}
595591
}
596592

597-
if (MtmUseDtm)
593+
if (MtmUseDtm && !MtmVolksWagenMode)
598594
{
599595
if (prev != NULL) {
600596
MTM_LOG2("%d: MtmAdjustOldestXid: oldestXid=%d, prev->xid=%d, prev->status=%d, prev->snapshot=%ld, ts->xid=%d, ts->status=%d, ts->snapshot=%ld, oldestSnapshot=%ld",
@@ -606,6 +602,8 @@ MtmAdjustOldestXid(TransactionId xid)
606602
}
607603
} else {
608604
if (prev != NULL) {
605+
MTM_LOG2("%d: MtmAdjustOldestXid: oldestXid=%d, prev->xid=%d, prev->status=%d, prev->snapshot=%ld, ts->xid=%d, ts->status=%d, ts->snapshot=%ld, oldestSnapshot=%ld",
606+
MyProcPid, xid, prev->xid, prev->status, prev->snapshot, (ts ? ts->xid : 0), (ts ? ts->status : -1), (ts ? ts->snapshot : -1), oldestSnapshot);
609607
Mtm->transListHead = prev;
610608
}
611609
}

0 commit comments

Comments
 (0)