database/postgres
database/postgres
1
0
Fork 0
mirror of https://github.com/postgres/postgres.git synced 2025-04-25 21:42:33 +03:00
Code

Change LockClassinfoForUpdate() to retry mark4update() in case

Browse Source 
the tuple is already uodated. (If LockClassinfoForUpdate() is
thought to be useful).
This commit is contained in:
Hiroshi Inoue 2001-01-18 04:01:42 +00:00
parent 5322bf46e3
commit 53ebb2286d
1 changed files with 21 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/backend/catalog/index.c
View File

@ -8,7 +8,7 @@
* *
* *
* IDENTIFICATION * IDENTIFICATION
* $Header: /cvsroot/pgsql/src/backend/catalog/index.c,v 1.133 2000/12/22 23:12:03 tgl Exp $ * $Header: /cvsroot/pgsql/src/backend/catalog/index.c,v 1.134 2001/01/18 04:01:42 inoue Exp $
* *
* *
* INTERFACE ROUTINES * INTERFACE ROUTINES
@ -1348,16 +1348,27 @@ LockClassinfoForUpdate(Oid relid, HeapTuple rtup,
rtup->t_self = classTuple->t_self; rtup->t_self = classTuple->t_self;
ReleaseSysCache(classTuple); ReleaseSysCache(classTuple);
while (1)
{
ItemPointerData tidsave;
ItemPointerCopy(&(rtup->t_self), &tidsave);
test = heap_mark4update(relationRelation, rtup, buffer); test = heap_mark4update(relationRelation, rtup, buffer);
switch (test) switch (test)
{ {
case HeapTupleSelfUpdated: case HeapTupleSelfUpdated:
case HeapTupleMayBeUpdated: case HeapTupleMayBeUpdated:
break; break;
case HeapTupleUpdated:
ReleaseBuffer(*buffer);
if (!ItemPointerEquals(&(rtup->t_self), &tidsave))
continue;
default: default:
elog(ERROR, "LockStatsForUpdate couldn't lock relid %u", relid); elog(ERROR, "LockClassinfoForUpdate couldn't lock relid %u", relid);
return false; return false;
} }
break;
}
RelationInvalidateHeapTuple(relationRelation, rtup); RelationInvalidateHeapTuple(relationRelation, rtup);
if (confirmCommitted) if (confirmCommitted)
{ {
@ -1634,8 +1645,7 @@ UpdateStats(Oid relid, long reltuples)
#ifdef OLD_FILE_NAMING #ifdef OLD_FILE_NAMING
in_place_upd = (IsReindexProcessing() || IsBootstrapProcessingMode()); in_place_upd = (IsReindexProcessing() || IsBootstrapProcessingMode());
#else #else
in_place_upd = (IsIgnoringSystemIndexes() || (IsReindexProcessing() && in_place_upd = (IsIgnoringSystemIndexes() || IsReindexProcessing());
relid == RelOid_pg_class));
#endif /* OLD_FILE_NAMING */ #endif /* OLD_FILE_NAMING */
if (!in_place_upd) if (!in_place_upd)