diff options
| author | Vadim B. Mikheev <vadim4o@yahoo.com> | 1999-04-12 16:57:27 +0000 |
|---|---|---|
| committer | Vadim B. Mikheev <vadim4o@yahoo.com> | 1999-04-12 16:57:27 +0000 |
| commit | c3b09c2237d56fbebbb8608bee891332675876fa (patch) | |
| tree | c57a441846459a72fa795a0069691758843e9d7d | |
| parent | 12a5aa4f1a39f069337d3883725410f007a8e959 (diff) | |
| download | postgresql-c3b09c2237d56fbebbb8608bee891332675876fa.tar.gz postgresql-c3b09c2237d56fbebbb8608bee891332675876fa.zip | |
Fix HEAP_MOVED_IN handling in HeapTupleSatisfiesDirty().
| -rw-r--r-- | src/backend/utils/time/tqual.c | 19 |
1 files changed, 12 insertions, 7 deletions
diff --git a/src/backend/utils/time/tqual.c b/src/backend/utils/time/tqual.c index 26c2d43c00c..bdcd1afdba8 100644 --- a/src/backend/utils/time/tqual.c +++ b/src/backend/utils/time/tqual.c @@ -7,7 +7,7 @@ * * * IDENTIFICATION - * $Header: /cvsroot/pgsql/src/backend/utils/time/tqual.c,v 1.27 1999/04/05 10:55:49 vadim Exp $ + * $Header: /cvsroot/pgsql/src/backend/utils/time/tqual.c,v 1.28 1999/04/12 16:57:27 vadim Exp $ * *------------------------------------------------------------------------- */ @@ -422,15 +422,19 @@ HeapTupleSatisfiesDirty(HeapTupleHeader tuple) tuple->t_infomask |= HEAP_XMIN_INVALID; return false; } + tuple->t_infomask |= HEAP_XMIN_COMMITTED; } else if (tuple->t_infomask & HEAP_MOVED_IN) { - if (TransactionIdIsCurrentTransactionId((TransactionId)tuple->t_cmin)) - return true; - if (!TransactionIdDidCommit((TransactionId)tuple->t_cmin)) + if (!TransactionIdIsCurrentTransactionId((TransactionId)tuple->t_cmin)) { - tuple->t_infomask |= HEAP_XMIN_INVALID; - return false; + if (TransactionIdDidCommit((TransactionId)tuple->t_cmin)) + tuple->t_infomask |= HEAP_XMIN_COMMITTED; + else + { + tuple->t_infomask |= HEAP_XMIN_INVALID; + return false; + } } } else if (TransactionIdIsCurrentTransactionId(tuple->t_xmin)) @@ -455,7 +459,8 @@ HeapTupleSatisfiesDirty(HeapTupleHeader tuple) SnapshotDirty->xmin = tuple->t_xmin; return true; /* in insertion by other */ } - tuple->t_infomask |= HEAP_XMIN_COMMITTED; + else + tuple->t_infomask |= HEAP_XMIN_COMMITTED; } /* by here, the inserting transaction has committed */ |