diff options
Diffstat (limited to 'src/backend/access/heap/heapam.c')
| -rw-r--r-- | src/backend/access/heap/heapam.c | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/src/backend/access/heap/heapam.c b/src/backend/access/heap/heapam.c index 05c790f3c7..a771ccb772 100644 --- a/src/backend/access/heap/heapam.c +++ b/src/backend/access/heap/heapam.c @@ -5456,6 +5456,7 @@ FreezeMultiXactId(MultiXactId multi, uint16 t_infomask, bool has_lockers; TransactionId update_xid; bool update_committed; + bool allow_old; *flags = 0; @@ -5517,7 +5518,9 @@ FreezeMultiXactId(MultiXactId multi, uint16 t_infomask, * anything. */ - nmembers = GetMultiXactIdMembers(multi, &members, false); + allow_old = !(t_infomask & HEAP_LOCK_MASK) && + HEAP_XMAX_IS_LOCKED_ONLY(t_infomask); + nmembers = GetMultiXactIdMembers(multi, &members, allow_old); if (nmembers <= 0) { /* Nothing worth keeping */ @@ -6219,10 +6222,13 @@ heap_tuple_needs_freeze(HeapTupleHeader tuple, TransactionId cutoff_xid, MultiXactMember *members; int nmembers; int i; + bool allow_old; /* need to check whether any member of the mxact is too old */ - nmembers = GetMultiXactIdMembers(multi, &members, false); + allow_old = !(tuple->t_infomask & HEAP_LOCK_MASK) && + HEAP_XMAX_IS_LOCKED_ONLY(tuple->t_infomask); + nmembers = GetMultiXactIdMembers(multi, &members, allow_old); for (i = 0; i < nmembers; i++) { |