summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorTom Lane <tgl@sss.pgh.pa.us>2004-10-13 22:22:22 +0000
committerTom Lane <tgl@sss.pgh.pa.us>2004-10-13 22:22:22 +0000
commit78c0692b159dccf56853107fb4513225decbbd85 (patch)
tree491c86799f5f2ec09637c98a94e1000851a95cb7 /src
parent8a9b331c323c6b6dfe97d7e05939f2518b98f5b0 (diff)
Repair possible failure to update hint bits back to disk, per
http://archives.postgresql.org/pgsql-hackers/2004-10/msg00464.php. I plan a more permanent fix in HEAD, but for the back branches it seems best to just touch the places that actually have a problem.
Diffstat (limited to 'src')
-rw-r--r--src/backend/access/heap/heapam.c20
-rw-r--r--src/backend/utils/adt/ri_triggers.c5
2 files changed, 20 insertions, 5 deletions
diff --git a/src/backend/access/heap/heapam.c b/src/backend/access/heap/heapam.c
index e5e509f92ca..b4b20c679b3 100644
--- a/src/backend/access/heap/heapam.c
+++ b/src/backend/access/heap/heapam.c
@@ -8,7 +8,7 @@
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/access/heap/heapam.c,v 1.149 2002/09/26 22:46:29 tgl Exp $
+ * $Header: /cvsroot/pgsql/src/backend/access/heap/heapam.c,v 1.149.2.1 2004/10/13 22:22:21 tgl Exp $
*
*
* INTERFACE ROUTINES
@@ -1271,6 +1271,7 @@ heap_delete(Relation relation, ItemPointer tid,
PageHeader dp;
Buffer buffer;
int result;
+ uint16 sv_infomask;
/* increment access statistics */
IncrHeapAccessStat(local_delete);
@@ -1294,7 +1295,10 @@ heap_delete(Relation relation, ItemPointer tid,
tp.t_tableOid = relation->rd_id;
l1:
+ sv_infomask = tp.t_data->t_infomask;
result = HeapTupleSatisfiesUpdate(&tp, cid);
+ if (sv_infomask != tp.t_data->t_infomask)
+ SetBufferCommitInfoNeedsSave(buffer);
if (result == HeapTupleInvisible)
{
@@ -1311,7 +1315,7 @@ l1:
XactLockTableWait(xwait);
LockBuffer(buffer, BUFFER_LOCK_EXCLUSIVE);
- if (TransactionIdDidAbort(xwait))
+ if (!TransactionIdDidCommit(xwait))
goto l1;
/*
@@ -1470,6 +1474,7 @@ heap_update(Relation relation, ItemPointer otid, HeapTuple newtup,
Size newtupsize,
pagefree;
int result;
+ uint16 sv_infomask;
/* increment access statistics */
IncrHeapAccessStat(local_replace);
@@ -1498,7 +1503,10 @@ heap_update(Relation relation, ItemPointer otid, HeapTuple newtup,
*/
l2:
+ sv_infomask = oldtup.t_data->t_infomask;
result = HeapTupleSatisfiesUpdate(&oldtup, cid);
+ if (sv_infomask != oldtup.t_data->t_infomask)
+ SetBufferCommitInfoNeedsSave(buffer);
if (result == HeapTupleInvisible)
{
@@ -1515,7 +1523,7 @@ l2:
XactLockTableWait(xwait);
LockBuffer(buffer, BUFFER_LOCK_EXCLUSIVE);
- if (TransactionIdDidAbort(xwait))
+ if (!TransactionIdDidCommit(xwait))
goto l2;
/*
@@ -1795,6 +1803,7 @@ heap_mark4update(Relation relation, HeapTuple tuple, Buffer *buffer,
ItemId lp;
PageHeader dp;
int result;
+ uint16 sv_infomask;
/* increment access statistics */
IncrHeapAccessStat(local_mark4update);
@@ -1814,7 +1823,10 @@ heap_mark4update(Relation relation, HeapTuple tuple, Buffer *buffer,
tuple->t_len = ItemIdGetLength(lp);
l3:
+ sv_infomask = tuple->t_data->t_infomask;
result = HeapTupleSatisfiesUpdate(tuple, cid);
+ if (sv_infomask != tuple->t_data->t_infomask)
+ SetBufferCommitInfoNeedsSave(*buffer);
if (result == HeapTupleInvisible)
{
@@ -1831,7 +1843,7 @@ l3:
XactLockTableWait(xwait);
LockBuffer(*buffer, BUFFER_LOCK_EXCLUSIVE);
- if (TransactionIdDidAbort(xwait))
+ if (!TransactionIdDidCommit(xwait))
goto l3;
/*
diff --git a/src/backend/utils/adt/ri_triggers.c b/src/backend/utils/adt/ri_triggers.c
index 0b47b614ea7..6f85e6fc4a5 100644
--- a/src/backend/utils/adt/ri_triggers.c
+++ b/src/backend/utils/adt/ri_triggers.c
@@ -17,7 +17,7 @@
*
* Portions Copyright (c) 1996-2002, PostgreSQL Global Development Group
*
- * $Header: /cvsroot/pgsql/src/backend/utils/adt/ri_triggers.c,v 1.43.2.4 2003/10/31 03:57:41 wieck Exp $
+ * $Header: /cvsroot/pgsql/src/backend/utils/adt/ri_triggers.c,v 1.43.2.5 2004/10/13 22:22:22 tgl Exp $
*
* ----------
*/
@@ -241,6 +241,9 @@ RI_FKey_check(PG_FUNCTION_ARGS)
* We should not even consider checking the row if it is no longer
* valid since it was either deleted (doesn't matter) or updated (in
* which case it'll be checked with its final values).
+ *
+ * Note: we need not SetBufferCommitInfoNeedsSave() here since the
+ * new tuple's commit state can't possibly change.
*/
if (new_row)
{