database/postgres
database/postgres
1
0
Fork 0
mirror of https://github.com/postgres/postgres.git synced 2025-05-06 19:59:18 +03:00
Code

vacuum cleanups

Browse Source
This commit is contained in:
Bruce Momjian 1998-10-07 22:31:50 +00:00
parent 9549a8cd7d
commit cb4292ea64
1 changed files with 9 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
src/backend/commands/vacuum.c
View File

@ -7,7 +7,7 @@
* *
* *
* IDENTIFICATION * IDENTIFICATION
* $Header: /cvsroot/pgsql/src/backend/commands/vacuum.c,v 1.83 1998/10/07 17:12:50 momjian Exp $ * $Header: /cvsroot/pgsql/src/backend/commands/vacuum.c,v 1.84 1998/10/07 22:31:50 momjian Exp $
* *
*------------------------------------------------------------------------- *-------------------------------------------------------------------------
*/ */
@ -306,26 +306,11 @@ vc_getrels(NameData *VacRelP)
d = heap_getattr(tuple, Anum_pg_class_relname, tupdesc, &n); d = heap_getattr(tuple, Anum_pg_class_relname, tupdesc, &n);
rname = (char *) d; rname = (char *) d;
/*
* don't vacuum large objects for now - something breaks when we
* do
*/
if ((strlen(rname) >= 5) && rname[0] == 'x' &&
rname[1] == 'i' && rname[2] == 'n' &&
(rname[3] == 'v' || rname[3] == 'x') &&
rname[4] >= '0' && rname[4] <= '9')
{
elog(NOTICE, "Rel %s: can't vacuum LargeObjects now",
rname);
continue;
}
d = heap_getattr(tuple, Anum_pg_class_relkind, tupdesc, &n); d = heap_getattr(tuple, Anum_pg_class_relkind, tupdesc, &n);
rkind = DatumGetChar(d); rkind = DatumGetChar(d);
/* skip system relations */ if (rkind != RELKIND_RELATION)
if (rkind != 'r')
{ {
elog(NOTICE, "Vacuum: can not process index and certain system tables"); elog(NOTICE, "Vacuum: can not process index and certain system tables");
continue; continue;
@ -372,8 +357,6 @@ vc_getrels(NameData *VacRelP)
static void static void
vc_vacone(Oid relid, bool analyze, List *va_cols) vc_vacone(Oid relid, bool analyze, List *va_cols)
{ {
Relation rel;
TupleDesc tupdesc;
HeapTuple tuple, HeapTuple tuple,
typetuple; typetuple;
Relation onerel; Relation onerel;
@ -389,9 +372,6 @@ vc_vacone(Oid relid, bool analyze, List *va_cols)
StartTransactionCommand(); StartTransactionCommand();
rel = heap_openr(RelationRelationName);
tupdesc = RelationGetDescr(rel);
/* /*
* Race condition -- if the pg_class tuple has gone away since the * Race condition -- if the pg_class tuple has gone away since the
* last time we saw it, we don't need to vacuum it. * last time we saw it, we don't need to vacuum it.
@ -401,7 +381,6 @@ vc_vacone(Oid relid, bool analyze, List *va_cols)
0, 0, 0); 0, 0, 0);
if (!HeapTupleIsValid(tuple)) if (!HeapTupleIsValid(tuple))
{ {
heap_close(rel);
CommitTransactionCommand(); CommitTransactionCommand();
return; return;
} }
@ -573,7 +552,6 @@ vc_vacone(Oid relid, bool analyze, List *va_cols)
/* all done with this class */ /* all done with this class */
heap_close(onerel); heap_close(onerel);
heap_close(rel);
/* update statistics in pg_class */ /* update statistics in pg_class */
vc_updstats(vacrelstats->relid, vacrelstats->num_pages, vc_updstats(vacrelstats->relid, vacrelstats->num_pages,
@ -1744,6 +1722,7 @@ vc_updstats(Oid relid, int num_pages, int num_tuples, bool hasindex, VRelStats *
sd; sd;
HeapScanDesc scan; HeapScanDesc scan;
HeapTuple rtup, HeapTuple rtup,
ctup,
atup, atup,
stup; stup;
Form_pg_class pgcform; Form_pg_class pgcform;
@ -1754,18 +1733,19 @@ vc_updstats(Oid relid, int num_pages, int num_tuples, bool hasindex, VRelStats *
/* /*
* update number of tuples and number of pages in pg_class * update number of tuples and number of pages in pg_class
*/ */
rtup = SearchSysCacheTuple(RELOID, ctup = SearchSysCacheTupleCopy(RELOID,
ObjectIdGetDatum(relid), ObjectIdGetDatum(relid),
0, 0, 0); 0, 0, 0);
if (!HeapTupleIsValid(rtup)) if (!HeapTupleIsValid(ctup))
elog(ERROR, "pg_class entry for relid %d vanished during vacuuming", elog(ERROR, "pg_class entry for relid %d vanished during vacuuming",
relid); relid);
rd = heap_openr(RelationRelationName); rd = heap_openr(RelationRelationName);
/* get the buffer cache tuple */ /* get the buffer cache tuple */
rtup = heap_fetch(rd, SnapshotNow, &rtup->t_ctid, &buffer); rtup = heap_fetch(rd, SnapshotNow, &ctup->t_ctid, &buffer);
pfree(ctup);
/* overwrite the existing statistics in the tuple */ /* overwrite the existing statistics in the tuple */
vc_setpagelock(rd, ItemPointerGetBlockNumber(&rtup->t_ctid)); vc_setpagelock(rd, ItemPointerGetBlockNumber(&rtup->t_ctid));
pgcform = (Form_pg_class) GETSTRUCT(rtup); pgcform = (Form_pg_class) GETSTRUCT(rtup);
@ -2175,7 +2155,7 @@ vc_getindices(Oid relid, int *nindices, Relation **Irel)
k++; k++;
} }
else else
elog(NOTICE, "CAN't OPEN INDEX %u - SKIP IT", ioid[i]); elog(NOTICE, "CAN'T OPEN INDEX %u - SKIP IT", ioid[i]);
} }
*nindices = k; *nindices = k;
pfree(ioid); pfree(ioid);