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

Commit 2329b1c

Browse files
knizhnikkelvich
authored andcommitted
Use volkwagen more for OldestXmin adjustment
1 parent 13d2f71 commit 2329b1c

File tree

1 file changed

+3
-5
lines changed

1 file changed

+3
-5
lines changed

multimaster.c

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -579,10 +579,6 @@ MtmAdjustOldestXid(TransactionId xid)
579579
ts != NULL
580580
&& ts->csn < oldestSnapshot
581581
&& TransactionIdPrecedes(ts->xid, xid);
582-
/*
583-
&& (ts->status == TRANSACTION_STATUS_COMMITTED ||
584-
ts->status == TRANSACTION_STATUS_ABORTED);
585-
*/
586582
prev = ts, ts = ts->next)
587583
{
588584
if (prev != NULL) {
@@ -593,7 +589,7 @@ MtmAdjustOldestXid(TransactionId xid)
593589
}
594590
}
595591

596-
if (MtmUseDtm)
592+
if (MtmUseDtm && !MtmVolksWagenMode)
597593
{
598594
if (prev != NULL) {
599595
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",
@@ -605,6 +601,8 @@ MtmAdjustOldestXid(TransactionId xid)
605601
}
606602
} else {
607603
if (prev != NULL) {
604+
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",
605+
MyProcPid, xid, prev->xid, prev->status, prev->snapshot, (ts ? ts->xid : 0), (ts ? ts->status : -1), (ts ? ts->snapshot : -1), oldestSnapshot);
608606
Mtm->transListHead = prev;
609607
}
610608
}

0 commit comments

Comments
 (0)