With no parameter, VACUUM processes every table in the
- current database. It also detects any extraneous files in the
- database directory. With a parameter, VACUUM processes
+ current database. With a parameter, VACUUM processes
only that table.
* Copyright (c) 2000, PostgreSQL Global Development Group
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/access/transam/varsup.c,v 1.39 2001/05/25 15:34:49 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/access/transam/varsup.c,v 1.40 2001/05/25 15:45:32 momjian Exp $
*
*-------------------------------------------------------------------------
*/
#include "access/transam.h"
#include "access/xlog.h"
#include "storage/proc.h"
-#include "storage/sinval.h"
-#include "storage/sinvaladt.h"
-extern SISeg *shmInvalBuffer;
/* Number of XIDs and OIDs to prefetch (preallocate) per XLOG write */
#define VAR_XID_PREFETCH 1024
SpinRelease(OidGenLockId);
}
-
-/*
- * GetMinBackendOid -- returns lowest oid stored on startup of
- * each backend.
- */
-Oid
-GetMinStartupOid(void)
-{
- SISeg *segP = shmInvalBuffer;
- ProcState *stateP = segP->procState;
- int index;
- Oid min_oid;
-
- /* prime with current oid, no need for lock */
- min_oid = ShmemVariableCache->nextOid;
-
- SpinAcquire(SInvalLock);
-
- for (index = 0; index < segP->lastBackend; index++)
- {
- SHMEM_OFFSET pOffset = stateP[index].procStruct;
-
- if (pOffset != INVALID_OFFSET)
- {
- PROC *proc = (PROC *) MAKE_PTR(pOffset);
- Oid proc_oid;
-
- proc_oid = proc->startOid; /* we don't use spin-locking in
- * AbortTransaction() ! */
- if (proc == MyProc || proc_oid <= BootstrapObjectIdData)
- continue;
- if (proc_oid < min_oid)
- min_oid = proc_oid;
- }
- }
-
- SpinRelease(SInvalLock);
- return min_oid;
-}
-
-
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/commands/vacuum.c,v 1.194 2001/05/25 15:34:49 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/commands/vacuum.c,v 1.195 2001/05/25 15:45:32 momjian Exp $
*
*-------------------------------------------------------------------------
*/
#include
#include
-#include
-#include
#include
#include
#include
-#include
#include
#include
#include "access/genam.h"
#include "access/heapam.h"
-#include "access/transam.h"
#include "access/xlog.h"
#include "catalog/catalog.h"
#include "catalog/catname.h"
static bool enough_space(VacPage vacpage, Size len);
static void init_rusage(VacRUsage *ru0);
static char *show_rusage(VacRUsage *ru0);
-static void report_orphans(void);
/*
/* clean up */
vacuum_shutdown();
-
- if (VacRelName == NULL)
- report_orphans();
-
}
/*
return result;
}
-
-/*
- * report_orphans
- *
- * Report files that are not referenced by any pg_class.relfilenode.
- * Could be caused by backend crash no cleaning up.
- */
-static void
-report_orphans(void)
-{
- DIR *db_dir;
- struct dirent *db_de;
- Relation rel;
- TupleDesc tupdesc;
- HeapScanDesc scan;
- HeapTuple tuple;
- Oid dir_file_oid;
- Oid rel_file_oid;
- Datum d;
- bool n;
- bool match_found;
- char cwd[MAXPGPATH];
-
- getcwd(cwd,MAXPGPATH);
- db_dir = opendir(".");
- rel = heap_openr(RelationRelationName, AccessShareLock);
- Assert(db_dir);
-
- /*
- * Cycle through directory and check each file against
- * pg_class.relfilenode.
- * XXX This is O(n^2). Is it too slow? bjm
- */
- while ((db_de = readdir(db_dir)) != NULL)
- {
- if (strspn(db_de->d_name, "0123456789") ==
- strlen(db_de->d_name))
- {
- dir_file_oid = (Oid) strtoul((db_de->d_name), NULL, 10);
-
- if (dir_file_oid >= GetMinStartupOid() ||
- dir_file_oid <= BootstrapObjectIdData)
- continue;
-
- tupdesc = RelationGetDescr(rel);
-
- match_found = false;
- scan = heap_beginscan(rel, false, SnapshotNow, 0, (ScanKey) NULL);
- while (HeapTupleIsValid(tuple = heap_getnext(scan, 0)))
- {
- d = heap_getattr(tuple, Anum_pg_class_relfilenode, tupdesc, &n);
- rel_file_oid = DatumGetObjectId(d);
- if (dir_file_oid == rel_file_oid)
- {
- match_found = true;
- break;
- }
- }
- heap_endscan(scan);
- /* make sure there was no oid wrap-around during the scan */
- if (!match_found && dir_file_oid <= ShmemVariableCache->nextOid)
- elog(NOTICE,
- "Unreferenced file found in database directory:\n\t%s/%s",
- cwd, db_de->d_name);
- /* Maybe one day we can unlink too. bjm 2001-05-24 */
- }
- }
-
- heap_close(rel, AccessShareLock);
- closedir(db_dir);
-}
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/postmaster/postmaster.c,v 1.213 2001/05/25 15:34:50 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/postmaster/postmaster.c,v 1.214 2001/05/25 15:45:33 momjian Exp $
*
* NOTES
*
#include
#include
#include
-#include
#include
#include
#include
static void SignalChildren(int signal);
static int CountChildren(void);
static bool CreateOptsFile(int argc, char *argv[]);
-static void RemovePgSorttemp(void);
static pid_t SSDataBase(int xlop);
if (!CreateDataDirLockFile(DataDir, true))
ExitPostmaster(1);
- /* Remove old sort files */
- RemovePgSorttemp();
-
/*
* Establish input sockets.
*/
fclose(fp);
return true;
}
-
-
-/*
- * Remove old sort files
- */
-static void
-RemovePgSorttemp(void)
-{
- char db_path[MAXPGPATH];
- char temp_path[MAXPGPATH];
- char rm_path[MAXPGPATH];
- DIR *db_dir;
- DIR *temp_dir;
- struct dirent *db_de;
- struct dirent *temp_de;
-
- /*
- * Cycle through pg_tempsort for all databases and
- * and remove old sort files.
- */
- /* trailing slash forces symlink following */
- snprintf(db_path, sizeof(db_path), "%s/base/", DataDir);
- if ((db_dir = opendir(db_path)) != NULL)
- {
- while ((db_de = readdir(db_dir)) != NULL)
- {
- snprintf(temp_path, sizeof(temp_path),
- "%s/%s/%s/", db_path, db_de->d_name, SORT_TEMP_DIR);
- if ((temp_dir = opendir(temp_path)) != NULL)
- {
- while ((temp_de = readdir(temp_dir)) != NULL)
- {
- if (strspn(temp_de->d_name, "0123456789.") ==
- strlen(temp_de->d_name))
- {
- snprintf(rm_path, sizeof(temp_path),
- "%s/%s/%s/%s",
- db_path, db_de->d_name,
- SORT_TEMP_DIR, temp_de->d_name);
- unlink(rm_path);
- }
- }
- closedir(temp_dir);
- }
- }
- closedir(db_dir);
- }
-}
* Portions Copyright (c) 1994, Regents of the University of California
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/storage/file/fd.c,v 1.77 2001/05/25 15:34:50 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/storage/file/fd.c,v 1.78 2001/05/25 15:45:33 momjian Exp $
*
* NOTES:
*
File
OpenTemporaryFile(void)
{
- char tempfilepath[128];
+ char tempfilename[64];
File file;
/*
* Generate a tempfile name that's unique within the current
* transaction
*/
- snprintf(tempfilepath, sizeof(tempfilepath),
- "%s%c%d.%ld", SORT_TEMP_DIR, SEP_CHAR, MyProcPid,
- tempFileCounter++);
+ snprintf(tempfilename, sizeof(tempfilename),
+ "pg_sorttemp%d.%ld", MyProcPid, tempFileCounter++);
/* Open the file */
- file = FileNameOpenFile(tempfilepath,
+ file = FileNameOpenFile(tempfilename,
O_RDWR | O_CREAT | O_TRUNC | PG_BINARY, 0600);
if (file <= 0)
- {
- /* mkdir could fail if some one else already created it */
- mkdir(SORT_TEMP_DIR, S_IRWXU);
- file = FileNameOpenFile(tempfilepath,
- O_RDWR | O_CREAT | O_TRUNC | PG_BINARY, 0600);
- if (file <= 0)
- elog(ERROR, "Failed to create temporary file %s", tempfilepath);
- }
+ elog(ERROR, "Failed to create temporary file %s", tempfilename);
/* Mark it for deletion at close or EOXact */
VfdCache[file].fdstate |= FD_TEMPORARY;
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/storage/lmgr/proc.c,v 1.101 2001/05/25 15:34:50 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/storage/lmgr/proc.c,v 1.102 2001/05/25 15:45:33 momjian Exp $
*
*-------------------------------------------------------------------------
*/
MyProc->databaseId = MyDatabaseId;
MyProc->xid = InvalidTransactionId;
MyProc->xmin = InvalidTransactionId;
- MyProc->startOid = ShmemVariableCache->nextOid;
MyProc->waitLock = NULL;
MyProc->waitHolder = NULL;
SHMQueueInit(&(MyProc->procHolders));
* Portions Copyright (c) 1996-2001, PostgreSQL Global Development Group
* Portions Copyright (c) 1994, Regents of the University of California
*
- * $Id: transam.h,v 1.34 2001/05/25 15:34:50 momjian Exp $
+ * $Id: transam.h,v 1.35 2001/05/25 15:45:33 momjian Exp $
*
* NOTES
* Transaction System Version 101 now support proper oid
extern void ReadNewTransactionId(TransactionId *xid);
extern void GetNewObjectId(Oid *oid_return);
extern void CheckMaxObjectId(Oid assigned_oid);
-extern Oid GetMinStartupOid(void);
/* ----------------
* global variable extern declarations
* Portions Copyright (c) 1996-2001, PostgreSQL Global Development Group
* Portions Copyright (c) 1994, Regents of the University of California
*
- * $Id: fd.h,v 1.28 2001/05/25 15:34:50 momjian Exp $
+ * $Id: fd.h,v 1.29 2001/05/25 15:45:34 momjian Exp $
*
*-------------------------------------------------------------------------
*/
* FileSeek uses the standard UNIX lseek(2) flags.
*/
-#define SORT_TEMP_DIR "pg_sorttemp"
-
typedef char *FileName;
typedef int File;
* Portions Copyright (c) 1996-2001, PostgreSQL Global Development Group
* Portions Copyright (c) 1994, Regents of the University of California
*
- * $Id: proc.h,v 1.42 2001/05/25 15:34:50 momjian Exp $
+ * $Id: proc.h,v 1.43 2001/05/25 15:45:34 momjian Exp $
*
*-------------------------------------------------------------------------
*/
* were starting our xact: vacuum must not
* remove tuples deleted by xid >= xmin ! */
- Oid startOid; /* oid at startup, used by vacuum to find
- * orphaned files.
- */
/*
* XLOG location of first XLOG record written by this backend's
* current transaction. If backend is not in a transaction or hasn't
projects / postgresql.git / commitdiff