File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -312,7 +312,7 @@ Snapshot MtmGetSnapshot(Snapshot snapshot)
312312
313313TransactionId MtmGetOldestXmin (Relation rel , bool ignoreVacuum )
314314{
315- TransactionId xmin = PgGetOldestXmin (rel , ignoreVacuum );
315+ TransactionId xmin = PgGetOldestXmin (NULL , ignoreVacuum ); /* consider all backends */
316316 xmin = MtmAdjustOldestXid (xmin );
317317 return xmin ;
318318}
@@ -410,7 +410,7 @@ MtmAdjustOldestXid(TransactionId xid)
410410
411411 MtmLock (LW_EXCLUSIVE );
412412 ts = (MtmTransState * )hash_search (MtmXid2State , & xid , HASH_FIND , NULL );
413- if (ts != NULL && ts -> status == TRANSACTION_STATUS_COMMITTED ) {
413+ if (ts != NULL && ts -> status == TRANSACTION_STATUS_COMMITTED ) { /* committed transactions have same CSNs at all nodes */
414414 csn_t oldestSnapshot ;
415415 int i ;
416416
You can’t perform that action at this time.
0 commit comments