aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/backend/Makefile8
-rw-r--r--src/backend/postmaster/postmaster.c24
-rw-r--r--src/backend/utils/init/Makefile4
-rw-r--r--src/backend/utils/init/postinit.c603
-rw-r--r--src/bin/pg_version/Makefile32
-rw-r--r--src/bin/pg_version/pg_version.c34
-rw-r--r--src/include/miscadmin.h19
7 files changed, 370 insertions, 354 deletions
diff --git a/src/backend/Makefile b/src/backend/Makefile
index 5fe2088a90b..38b7af42433 100644
--- a/src/backend/Makefile
+++ b/src/backend/Makefile
@@ -34,7 +34,7 @@
#
#
# IDENTIFICATION
-# $Header: /cvsroot/pgsql/src/backend/Makefile,v 1.14 1996/11/03 09:05:30 bryanh Exp $
+# $Header: /cvsroot/pgsql/src/backend/Makefile,v 1.15 1996/11/12 06:46:04 bryanh Exp $
#
#-------------------------------------------------------------------------
@@ -131,7 +131,8 @@ OBJS = access/SUBSYS.o bootstrap/SUBSYS.o catalog/SUBSYS.o \
lib/SUBSYS.o libpq/SUBSYS.o main/SUBSYS.o nodes/SUBSYS.o \
optimizer/SUBSYS.o parser/SUBSYS.o port/SUBSYS.o \
postmaster/SUBSYS.o regex/SUBSYS.o rewrite/SUBSYS.o \
- storage/SUBSYS.o tcop/SUBSYS.o utils/SUBSYS.o
+ storage/SUBSYS.o tcop/SUBSYS.o utils/SUBSYS.o \
+ ../utils/version.o
ifdef TIOGA
OBJS += tioga/SUBSYS.o
@@ -139,7 +140,7 @@ endif
all: postgres global1.bki.source local1_template1.bki.source
-postgres: postgres_group1 postgres_group2 postgres_group3 postgres_group4
+postgres: postgres_group1 postgres_group2 postgres_group3 postgres_group4
$(CC) $(LDFLAGS) -o postgres $(OBJS) $(LDADD)
postgres_group1:
@@ -167,6 +168,7 @@ postgres_group4:
ifdef TIOGA
$(MAKE) -C tioga all
endif
+ $(MAKE) -C ../utils version.o
global1.bki.source local1_template1.bki.source:
$(MAKE) -C catalog $@
diff --git a/src/backend/postmaster/postmaster.c b/src/backend/postmaster/postmaster.c
index b9f5ca1ad4f..7ef3ea4bd71 100644
--- a/src/backend/postmaster/postmaster.c
+++ b/src/backend/postmaster/postmaster.c
@@ -10,7 +10,7 @@
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/postmaster/postmaster.c,v 1.23 1996/11/10 03:01:41 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/postmaster/postmaster.c,v 1.24 1996/11/12 06:46:36 bryanh Exp $
*
* NOTES
*
@@ -75,6 +75,7 @@
#include "libpq/auth.h"
#include "libpq/pqcomm.h"
#include "miscadmin.h"
+#include "version.h"
#include "lib/dllist.h"
#include "nodes/nodes.h"
#include "utils/mcxt.h"
@@ -1186,18 +1187,27 @@ checkDataDir(void)
SEP_CHAR);
if ((fp=fopen(path, "r")) == NULL) {
fprintf(stderr, "%s does not find the database. Expected to find it "
- "in the PGDATA directory \"%s\", but unable to open directory "
+ "in the PGDATA directory \"%s\", but unable to open file "
"with pathname \"%s\".\n",
progname, DataDir, path);
exit(2);
}
fclose(fp);
-#ifndef WIN32
- if (!ValidPgVersion(DataDir)) {
- fprintf(stderr, "%s: data base in \"%s\" is of a different version.\n",
- progname, DataDir);
- exit(2);
+#ifndef WIN32
+ {
+ char *reason; /* reason ValidatePgVersion failed. NULL if didn't */
+ ValidatePgVersion(DataDir, &reason);
+ if (reason) {
+ fprintf(stderr,
+ "Database system in directory %s "
+ "is not compatible with this version of "
+ "Postgres, or we are unable to read the PG_VERSION file. "
+ "Explanation from ValidatePgVersion: %s\n",
+ DataDir, reason);
+ free(reason);
+ exit(2);
+ }
}
#endif /* WIN32 */
}
diff --git a/src/backend/utils/init/Makefile b/src/backend/utils/init/Makefile
index ea6e8f8493d..ccbc145d7b1 100644
--- a/src/backend/utils/init/Makefile
+++ b/src/backend/utils/init/Makefile
@@ -4,7 +4,7 @@
# Makefile for utils/init
#
# IDENTIFICATION
-# $Header: /cvsroot/pgsql/src/backend/utils/init/Makefile,v 1.2 1996/11/09 06:23:41 momjian Exp $
+# $Header: /cvsroot/pgsql/src/backend/utils/init/Makefile,v 1.3 1996/11/12 06:46:40 bryanh Exp $
#
#-------------------------------------------------------------------------
@@ -20,7 +20,7 @@ CFLAGS += $(INCLUDE_OPT)
CFLAGS += -DPOSTGRESDIR='"$(POSTGRESDIR)"' -DPGDATADIR='"$(DATADIR)"' \
-DPOSTPORT='"$(POSTPORT)"'
-OBJS = enbl.o findbe.o globals.o magic.o miscinit.o postinit.o
+OBJS = enbl.o findbe.o globals.o miscinit.o postinit.o
all: SUBSYS.o
diff --git a/src/backend/utils/init/postinit.c b/src/backend/utils/init/postinit.c
index c4fdbd87250..de2768d8da6 100644
--- a/src/backend/utils/init/postinit.c
+++ b/src/backend/utils/init/postinit.c
@@ -7,22 +7,22 @@
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/utils/init/postinit.c,v 1.5 1996/11/08 06:00:33 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/utils/init/postinit.c,v 1.6 1996/11/12 06:46:42 bryanh Exp $
*
* NOTES
- * InitPostgres() is the function called from PostgresMain
- * which does all non-trival initialization, mainly by calling
- * all the other initialization functions. InitPostgres()
- * is only used within the "postgres" backend and so that routine
- * is in tcop/postgres.c InitPostgres() is needed in cinterface.a
- * because things like the bootstrap backend program need it. Hence
- * you find that in this file...
+ * InitPostgres() is the function called from PostgresMain
+ * which does all non-trival initialization, mainly by calling
+ * all the other initialization functions. InitPostgres()
+ * is only used within the "postgres" backend and so that routine
+ * is in tcop/postgres.c InitPostgres() is needed in cinterface.a
+ * because things like the bootstrap backend program need it. Hence
+ * you find that in this file...
*
- * If you feel the need to add more initialization code, it should be
- * done in InitPostgres() or someplace lower. Do not start
- * putting stuff in PostgresMain - if you do then someone
- * will have to clean it up later, and it's not going to be me!
- * -cim 10/3/90
+ * If you feel the need to add more initialization code, it should be
+ * done in InitPostgres() or someplace lower. Do not start
+ * putting stuff in PostgresMain - if you do then someone
+ * will have to clean it up later, and it's not going to be me!
+ * -cim 10/3/90
*
*-------------------------------------------------------------------------
*/
@@ -30,12 +30,14 @@
#include <stdio.h>
#include <string.h>
#include <sys/file.h>
+#include <sys/stat.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <math.h>
#include <unistd.h>
#include "postgres.h"
+#include "version.h"
#include <storage/backendid.h>
#include <storage/buf_internals.h>
@@ -46,22 +48,22 @@
#include "access/heapam.h"
#include "access/xact.h"
#include "storage/bufmgr.h"
-#include "access/transam.h" /* XXX dependency problem */
+#include "access/transam.h" /* XXX dependency problem */
#include "utils/tqual.h"
#include "utils/syscache.h"
-#include "storage/bufpage.h" /* for page layout, for InitMyDatabaseId() */
+#include "storage/bufpage.h" /* for page layout, for InitMyDatabaseId() */
#include "storage/sinval.h"
#include "storage/sinvaladt.h"
#include "storage/lmgr.h"
#include "miscadmin.h" /* for global decls */
-#include "utils/portal.h" /* for EnablePortalManager, etc. */
+#include "utils/portal.h" /* for EnablePortalManager, etc. */
-#include "utils/exc.h" /* for EnableExceptionHandling, etc. */
-#include "fmgr.h" /* for EnableDynamicFunctionManager, etc. */
+#include "utils/exc.h" /* for EnableExceptionHandling, etc. */
+#include "fmgr.h" /* for EnableDynamicFunctionManager, etc. */
#include "utils/elog.h"
#include "utils/palloc.h"
-#include "utils/mcxt.h" /* for EnableMemoryContext, etc. */
+#include "utils/mcxt.h" /* for EnableMemoryContext, etc. */
#include "catalog/catname.h"
#include "catalog/pg_database.h"
@@ -70,54 +72,54 @@
#include "libpq/libpq-be.h"
-static IPCKey PostgresIpcKey;
+static IPCKey PostgresIpcKey;
-#ifndef private
-#ifndef EBUG
-#define private static
-#else /* !defined(EBUG) */
+#ifndef private
+#ifndef EBUG
+#define private static
+#else /* !defined(EBUG) */
#define private
-#endif /* !defined(EBUG) */
-#endif /* !defined(private) */
+#endif /* !defined(EBUG) */
+#endif /* !defined(private) */
/* ----------------------------------------------------------------
- * InitPostgres support
+ * InitPostgres support
* ----------------------------------------------------------------
*/
/* --------------------------------
* InitMyDatabaseId() -- Find and record the OID of the database we are
- * to open.
+ * to open.
*
- * The database's oid forms half of the unique key for the system
- * caches and lock tables. We therefore want it initialized before
- * we open any relations, since opening relations puts things in the
- * cache. To get around this problem, this code opens and scans the
- * pg_database relation by hand.
+ * The database's oid forms half of the unique key for the system
+ * caches and lock tables. We therefore want it initialized before
+ * we open any relations, since opening relations puts things in the
+ * cache. To get around this problem, this code opens and scans the
+ * pg_database relation by hand.
*
- * This algorithm relies on the fact that first attribute in the
- * pg_database relation schema is the database name. It also knows
- * about the internal format of tuples on disk and the length of
- * the datname attribute. It knows the location of the pg_database
- * file.
+ * This algorithm relies on the fact that first attribute in the
+ * pg_database relation schema is the database name. It also knows
+ * about the internal format of tuples on disk and the length of
+ * the datname attribute. It knows the location of the pg_database
+ * file.
*
- * This code is called from InitDatabase(), after we chdir() to the
- * database directory but before we open any relations.
+ * This code is called from InitDatabase(), after we chdir() to the
+ * database directory but before we open any relations.
* --------------------------------
*/
void
InitMyDatabaseId()
{
- int dbfd;
- int fileflags;
- int nbytes;
- int max, i;
- HeapTuple tup;
- Page pg;
- PageHeader ph;
- char *dbfname;
- Form_pg_database tup_db;
+ int dbfd;
+ int fileflags;
+ int nbytes;
+ int max, i;
+ HeapTuple tup;
+ Page pg;
+ PageHeader ph;
+ char *dbfname;
+ Form_pg_database tup_db;
/*
* At bootstrap time, we don't need to check the oid of the database
@@ -126,8 +128,8 @@ InitMyDatabaseId()
*/
if (IsBootstrapProcessingMode()) {
- LockDisable(true);
- return;
+ LockDisable(true);
+ return;
}
dbfname = (char *) palloc(strlen(DataDir) + strlen("pg_database") + 2);
@@ -138,14 +140,14 @@ InitMyDatabaseId()
#endif /* WIN32 */
if ((dbfd = open(dbfname, O_RDONLY, 0666)) < 0)
- elog(FATAL, "Cannot open %s", dbfname);
+ elog(FATAL, "Cannot open %s", dbfname);
pfree(dbfname);
/* ----------------
- * read and examine every page in pg_database
+ * read and examine every page in pg_database
*
- * Raw I/O! Read those tuples the hard way! Yow!
+ * Raw I/O! Read those tuples the hard way! Yow!
*
* Why don't we use the access methods or move this code
* someplace else? This is really pg_database schema dependent
@@ -163,58 +165,58 @@ InitMyDatabaseId()
ph = (PageHeader) pg;
while ((nbytes = read(dbfd, pg, BLCKSZ)) == BLCKSZ) {
- max = PageGetMaxOffsetNumber(pg);
-
- /* look at each tuple on the page */
- for (i = 0; i <= max; i++) {
- int offset;
-
- /* if it's a freed tuple, ignore it */
- if (!(ph->pd_linp[i].lp_flags & LP_USED))
- continue;
-
- /* get a pointer to the tuple itself */
- offset = (int) ph->pd_linp[i].lp_off;
- tup = (HeapTuple) (((char *) pg) + offset);
-
- /*
- * if the tuple has been deleted (the database was destroyed),
- * skip this tuple. XXX warning, will robinson: violation of
- * transaction semantics happens right here. we should check
- * to be sure that the xact that deleted this tuple actually
- * committed. only way to do this at init time is to paw over
- * the log relation by hand, too. let's be optimistic.
- *
- * XXX This is an evil type cast. tup->t_xmax is char[5] while
- * TransactionId is struct * { char data[5] }. It works but
- * if data is ever moved and no longer the first field this
- * will be broken!! -mer 11 Nov 1991.
- */
- if (TransactionIdIsValid((TransactionId)tup->t_xmax))
- continue;
-
- /*
- * Okay, see if this is the one we want.
- * XXX 1 july 91: mao and mer discover that tuples now squash
- * t_bits. Why is this?
- *
- * 24 july 92: mer realizes that the t_bits field is only
- * used in the event of null values. If no
- * fields are null we reduce the header size
- * by doing the squash. t_hoff tells you exactly
- * how big the header actually is. use the PC
- * means of getting at sys cat attrs.
- */
- tup_db = (Form_pg_database)GETSTRUCT(tup);
-
- if (strncmp(GetDatabaseName(),
- &(tup_db->datname.data[0]),
- 16) == 0)
- {
- MyDatabaseId = tup->t_oid;
- goto done;
- }
- }
+ max = PageGetMaxOffsetNumber(pg);
+
+ /* look at each tuple on the page */
+ for (i = 0; i <= max; i++) {
+ int offset;
+
+ /* if it's a freed tuple, ignore it */
+ if (!(ph->pd_linp[i].lp_flags & LP_USED))
+ continue;
+
+ /* get a pointer to the tuple itself */
+ offset = (int) ph->pd_linp[i].lp_off;
+ tup = (HeapTuple) (((char *) pg) + offset);
+
+ /*
+ * if the tuple has been deleted (the database was destroyed),
+ * skip this tuple. XXX warning, will robinson: violation of
+ * transaction semantics happens right here. we should check
+ * to be sure that the xact that deleted this tuple actually
+ * committed. only way to do this at init time is to paw over
+ * the log relation by hand, too. let's be optimistic.
+ *
+ * XXX This is an evil type cast. tup->t_xmax is char[5] while
+ * TransactionId is struct * { char data[5] }. It works but
+ * if data is ever moved and no longer the first field this
+ * will be broken!! -mer 11 Nov 1991.
+ */
+ if (TransactionIdIsValid((TransactionId)tup->t_xmax))
+ continue;
+
+ /*
+ * Okay, see if this is the one we want.
+ * XXX 1 july 91: mao and mer discover that tuples now squash
+ * t_bits. Why is this?
+ *
+ * 24 july 92: mer realizes that the t_bits field is only
+ * used in the event of null values. If no
+ * fields are null we reduce the header size
+ * by doing the squash. t_hoff tells you exactly
+ * how big the header actually is. use the PC
+ * means of getting at sys cat attrs.
+ */
+ tup_db = (Form_pg_database)GETSTRUCT(tup);
+
+ if (strncmp(GetDatabaseName(),
+ &(tup_db->datname.data[0]),
+ 16) == 0)
+ {
+ MyDatabaseId = tup->t_oid;
+ goto done;
+ }
+ }
}
done:
@@ -222,84 +224,121 @@ InitMyDatabaseId()
pfree(pg);
if (!OidIsValid(MyDatabaseId))
- elog(FATAL,
- "Database %s does not exist in %s",
- GetDatabaseName(),
- DatabaseRelationName);
+ elog(FATAL,
+ "Database %s does not exist in %s",
+ GetDatabaseName(),
+ DatabaseRelationName);
}
+
+
/*
* DoChdirAndInitDatabaseNameAndPath --
- * Sets current directory appropriately for given path and name.
+ * Set current directory to the database directory for the database
+ * named <name>.
+ * Also set global variables DatabasePath and DatabaseName to those
+ * values. Also check for proper version of database system and
+ * database. Exit program via elog() if anything doesn't check out.
*
* Arguments:
- * Path and name are invalid if it invalid as a string.
- * Path is "badly formated" if it is not a string containing a path
- * to a writable directory.
- * Name is "badly formated" if it contains more than 16 characters or if
- * it is a bad file name (e.g., it contains a '/' or an 8-bit character).
- *
- * Side effects:
- * Initially, DatabasePath and DatabaseName are invalid. They are
- * set to valid strings before this function returns.
+ * Path and name are invalid if it invalid as a string.
+ * Path is "badly formated" if it is not a string containing a path
+ * to a writable directory.
+ * Name is "badly formated" if it contains more than 16 characters or if
+ * it is a bad file name (e.g., it contains a '/' or an 8-bit character).
*
* Exceptions:
- * BadState if called more than once.
- * BadArg if both path and name are "badly formated" or invalid.
- * BadArg if path and name are both "inconsistent" and valid.
- */
-/* ----------------
- * DoChdirAndInitDatabaseNameAndPath
+ * BadState if called more than once.
+ * BadArg if both path and name are "badly formated" or invalid.
+ * BadArg if path and name are both "inconsistent" and valid.
*
- * this just chdir's to the proper data/base directory
- * XXX clean this up more.
- *
- * XXX The following code is an incorrect of the semantics
- * XXX described in the header file. Handling of defaults
- * XXX should happen here, too.
- * ----------------
+ * This routine is inappropriate in bootstrap mode, since the directories
+ * and version files need not exist yet if we're in bootstrap mode.
*/
-void
-DoChdirAndInitDatabaseNameAndPath(char *name, /* name of database */
- char *path) /* full path to database */
-{
- /* ----------------
- * check the path
- * ----------------
- */
- if (path)
- SetDatabasePath(path);
- else
- elog(FATAL, "DoChdirAndInitDatabaseNameAndPath: path:%s is not valid",
- path);
-
- /* ----------------
- * check the name
- * ----------------
- */
- if (name)
- SetDatabaseName(name);
- else
- elog(FATAL, "DoChdirAndInitDatabaseNameAndPath: name:%s is not valid",
- name);
-
- /* ----------------
- * change to the directory, or die trying.
- *
- * XXX unless the path hasn't been set because we're bootstrapping.
- * HP-UX doesn't like chdir("") so check for that case before
- * doing anything drastic.
- * ----------------
- */
- if (*path && (chdir(path) < 0))
- elog(FATAL, "DoChdirAndInitDatabaseNameAndPath: chdir(\"%s\"): %m",
- path);
+static void
+DoChdirAndInitDatabaseNameAndPath(char *name) {
+ char *reason;
+ /* Failure reason returned by some function. NULL if no failure */
+#ifndef WIN32
+ struct stat statbuf;
+#else
+ struct _stat statbuf;
+#endif
+ char errormsg[1000];
+
+ if (stat(DataDir, &statbuf) < 0)
+ sprintf(errormsg, "Database system does not exist. "
+ "PGDATA directory '%s' not found. Normally, you "
+ "create a database system by running initdb.",
+ DataDir);
+ else {
+ char myPath[MAXPGPATH]; /* DatabasePath points here! */
+
+ if (strlen(DataDir) + strlen(name) + 10 > sizeof(myPath))
+ sprintf(errormsg, "Internal error in postinit.c: database "
+ "pathname exceeds maximum allowable length.");
+ else {
+ sprintf(myPath, "%s/base/%s", DataDir, name);
+
+ if (stat(myPath, &statbuf) < 0)
+ sprintf(errormsg,
+ "Database '%s' does not exist. "
+ "(We know this because the directory '%s' "
+ "does not exist). You can create a database "
+ "with the SQL command CREATE DATABASE. To see "
+ "what databases exist, look at the subdirectories "
+ "of '%s/base/'.",
+ name, myPath, DataDir);
+ else {
+ ValidatePgVersion(DataDir, &reason);
+ if (reason != NULL)
+ sprintf(errormsg,
+ "InitPostgres could not validate that the database "
+ "system version is compatible with this level of "
+ "Postgres. You may need to run initdb to create "
+ "a new database system. %s",
+ reason);
+ else {
+ ValidatePgVersion(myPath, &reason);
+ if (reason != NULL)
+ sprintf(errormsg,
+ "InitPostgres could not validate that the "
+ "database version is compatible with this level "
+ "of Postgres, even though the database system "
+ "as a whole appears to be at a compatible level. "
+ "You may need to recreate the database with SQL "
+ "commands DROP DATABASE and CREATE DATABASE. "
+ "%s",
+ reason);
+ else {
+ /* The directories and PG_VERSION files are in order.*/
+ int rc; /* return code from some function we call */
+
+ SetDatabasePath(myPath);
+ SetDatabaseName(name);
+ rc = chdir(myPath);
+ if (rc < 0)
+ sprintf(errormsg,
+ "InitPostgres unable to change "
+ "current directory to '%s', errno = %s (%d).",
+ myPath, strerror(errno), errno);
+ else errormsg[0] = '\0';
+ }
+ }
+ }
+ }
+ }
+ if (errormsg[0] != '\0')
+ elog(FATAL, errormsg);
+ /* Above does not return */
}
+
+
/* --------------------------------
- * InitUserid
+ * InitUserid
*
- * initializes crap associated with the user id.
+ * initializes crap associated with the user id.
* --------------------------------
*/
void
@@ -310,35 +349,35 @@ InitUserid()
}
/* --------------------------------
- * InitCommunication
+ * InitCommunication
*
- * This routine initializes stuff needed for ipc, locking, etc.
- * it should be called something more informative.
+ * This routine initializes stuff needed for ipc, locking, etc.
+ * it should be called something more informative.
*
* Note:
- * This does not set MyBackendId. MyBackendTag is set, however.
+ * This does not set MyBackendId. MyBackendTag is set, however.
* --------------------------------
*/
void
InitCommunication()
{
- char *getenv(); /* XXX style */
+ char *getenv(); /* XXX style */
char *postid;
char *postport;
- IPCKey key = 0;
+ IPCKey key = 0;
/* ----------------
- * try and get the backend tag from POSTID
+ * try and get the backend tag from POSTID
* ----------------
*/
MyBackendId = -1;
postid = getenv("POSTID");
if (!PointerIsValid(postid)) {
- MyBackendTag = -1;
+ MyBackendTag = -1;
} else {
- MyBackendTag = atoi(postid);
- Assert(MyBackendTag >= 0);
+ MyBackendTag = atoi(postid);
+ Assert(MyBackendTag >= 0);
}
/* ----------------
@@ -348,62 +387,62 @@ InitCommunication()
postport = getenv("POSTPORT");
if (PointerIsValid(postport)) {
- SystemPortAddress address = atoi(postport);
-
- if (address == 0)
- elog(FATAL, "InitCommunication: invalid POSTPORT");
-
- if (MyBackendTag == -1)
- elog(FATAL, "InitCommunication: missing POSTID");
-
- key = SystemPortAddressCreateIPCKey(address);
-
- /*
- * Enable this if you are trying to force the backend to run as if it
- * is running under the postmaster.
- *
- * This goto forces Postgres to attach to shared memory instead of
- * using malloc'ed memory (which is the normal behavior if run
- * directly).
- *
- * To enable emulation, run the following shell commands (in addition
- * to enabling this goto)
- *
- * % setenv POSTID 1
- * % setenv POSTPORT 4321
- * % postmaster &
- * % kill -9 %1
- *
- * Upon doing this, Postmaster will have allocated the shared memory
- * resources that Postgres will attach to if you enable
- * EMULATE_UNDER_POSTMASTER.
- *
- * This comment may well age with time - it is current as of
- * 8 January 1990
- *
- * Greg
- */
-
+ SystemPortAddress address = atoi(postport);
+
+ if (address == 0)
+ elog(FATAL, "InitCommunication: invalid POSTPORT");
+
+ if (MyBackendTag == -1)
+ elog(FATAL, "InitCommunication: missing POSTID");
+
+ key = SystemPortAddressCreateIPCKey(address);
+
+ /*
+ * Enable this if you are trying to force the backend to run as if it
+ * is running under the postmaster.
+ *
+ * This goto forces Postgres to attach to shared memory instead of
+ * using malloc'ed memory (which is the normal behavior if run
+ * directly).
+ *
+ * To enable emulation, run the following shell commands (in addition
+ * to enabling this goto)
+ *
+ * % setenv POSTID 1
+ * % setenv POSTPORT 4321
+ * % postmaster &
+ * % kill -9 %1
+ *
+ * Upon doing this, Postmaster will have allocated the shared memory
+ * resources that Postgres will attach to if you enable
+ * EMULATE_UNDER_POSTMASTER.
+ *
+ * This comment may well age with time - it is current as of
+ * 8 January 1990
+ *
+ * Greg
+ */
+
#ifdef EMULATE_UNDER_POSTMASTER
-
- goto forcesharedmemory;
-
+
+ goto forcesharedmemory;
+
#endif
-
+
} else if (IsUnderPostmaster) {
- elog(FATAL,
- "InitCommunication: under postmaster and POSTPORT not set");
+ elog(FATAL,
+ "InitCommunication: under postmaster and POSTPORT not set");
} else {
- /* ----------------
- * assume we're running a postgres backend by itself with
- * no front end or postmaster.
- * ----------------
- */
- if (MyBackendTag == -1) {
- MyBackendTag = 1;
- }
-
- key = PrivateIPCKey;
+ /* ----------------
+ * assume we're running a postgres backend by itself with
+ * no front end or postmaster.
+ * ----------------
+ */
+ if (MyBackendTag == -1) {
+ MyBackendTag = 1;
+ }
+
+ key = PrivateIPCKey;
}
/* ----------------
@@ -422,11 +461,11 @@ InitCommunication()
/* --------------------------------
- * InitStdio
+ * InitStdio
*
- * this routine consists of a bunch of code fragments
- * that used to be randomly scattered through cinit().
- * they all seem to do stuff associated with io.
+ * this routine consists of a bunch of code fragments
+ * that used to be randomly scattered through cinit().
+ * they all seem to do stuff associated with io.
* --------------------------------
*/
void
@@ -437,10 +476,10 @@ InitStdio()
/* --------------------------------
* InitPostgres --
- * Initialize POSTGRES.
+ * Initialize POSTGRES.
*
* Note:
- * Be very careful with the order of calls in the InitPostgres function.
+ * Be very careful with the order of calls in the InitPostgres function.
* --------------------------------
*/
bool PostgresIsInitialized = false;
@@ -452,49 +491,49 @@ extern int NBuffers;
* applications.
*/
-/*int testFlag = 0;*/
-int lockingOff = 0;
+/*int testFlag = 0;*/
+int lockingOff = 0;
/*
*/
void
-InitPostgres(char *name) /* database name */
+InitPostgres(char *name) /* database name */
{
- bool bootstrap; /* true if BootstrapProcessing */
+ bool bootstrap; /* true if BootstrapProcessing */
/* ----------------
- * see if we're running in BootstrapProcessing mode
+ * see if we're running in BootstrapProcessing mode
* ----------------
*/
bootstrap = IsBootstrapProcessingMode();
/* ----------------
- * turn on the exception handler. Note: we cannot use elog, Assert,
+ * turn on the exception handler. Note: we cannot use elog, Assert,
* AssertState, etc. until after exception handling is on.
* ----------------
*/
EnableExceptionHandling(true);
/* ----------------
- * A stupid check to make sure we don't call this more than once.
+ * A stupid check to make sure we don't call this more than once.
* But things like ReinitPostgres() get around this by just diddling
- * the PostgresIsInitialized flag.
+ * the PostgresIsInitialized flag.
* ----------------
*/
AssertState(!PostgresIsInitialized);
/* ----------------
- * Memory system initialization.
+ * Memory system initialization.
* (we may call palloc after EnableMemoryContext())
*
* Note EnableMemoryContext() must happen before EnablePortalManager().
* ----------------
*/
- EnableMemoryContext(true); /* initializes the "top context" */
- EnablePortalManager(true); /* memory for portal/transaction stuff */
+ EnableMemoryContext(true); /* initializes the "top context" */
+ EnablePortalManager(true); /* memory for portal/transaction stuff */
/* ----------------
- * initialize the backend local portal stack used by
+ * initialize the backend local portal stack used by
* internal PQ function calls. see src/lib/libpq/be-dumpdata.c
* This is different from the "portal manager" so this goes here.
* -cim 2/12/91
@@ -503,7 +542,7 @@ InitPostgres(char *name) /* database name */
be_portalinit();
/* ----------------
- * attach to shared memory and semaphores, and initialize our
+ * attach to shared memory and semaphores, and initialize our
* input/output/debugging file descriptors.
* ----------------
*/
@@ -518,48 +557,20 @@ InitPostgres(char *name) /* database name */
if (!TransactionFlushEnabled())
on_exitpg(FlushBufferPool, (caddr_t) NULL);
- /* ----------------
- * check for valid "meta gunk" (??? -cim 10/5/90) and change to
- * database directory.
- *
- * Note: DatabaseName, MyDatabaseName, and DatabasePath are all
- * initialized with DatabaseMetaGunkIsConsistent(), strncpy() and
- * DoChdirAndInitDatabase() below! XXX clean this crap up!
- * -cim 10/5/90
- * ----------------
- */
- {
- char myPath[MAXPGPATH] = "."; /* DatabasePath points here! */
-
- /* ----------------
- * DatabaseMetaGunkIsConsistent fills in myPath, but what about
- * when bootstrap or Noversion is true?? -cim 10/5/90
- * ----------------
- */
-
- if (! bootstrap &&
- ! DatabaseMetaGunkIsConsistent(name, myPath) &&
- ! Noversion) {
- elog(NOTICE, "InitPostgres: could not locate valid PG_VERSION\n");
- elog(NOTICE, "files for %s and %s.", DataDir, name);
- elog(FATAL, "Have you run initdb/createdb and set PGDATA properly?");
- }
-
- /* ----------------
- * ok, we've figured out myName and myPath, now save these
- * and chdir to myPath.
- * ----------------
- */
- DoChdirAndInitDatabaseNameAndPath(name, myPath);
+ if (bootstrap) {
+ SetDatabasePath(".");
+ SetDatabaseName(name);
+ } else {
+ DoChdirAndInitDatabaseNameAndPath(name);
}
/* ********************************
- * code after this point assumes we are in the proper directory!
+ * code after this point assumes we are in the proper directory!
* ********************************
*/
/* ----------------
- * initialize the database id used for system caches and lock tables
+ * initialize the database id used for system caches and lock tables
* ----------------
*/
InitMyDatabaseId();
@@ -567,7 +578,7 @@ InitPostgres(char *name) /* database name */
smgrinit();
/* ----------------
- * initialize the transaction system and the relation descriptor
+ * initialize the transaction system and the relation descriptor
* cache. Note we have to make certain the lock manager is off while
* we do this.
* ----------------
@@ -582,13 +593,13 @@ InitPostgres(char *name) /* database name */
* we only lock it to examine AMI transaction status, and this is
* never written after initdb is done. -mer 15 June 1992
*/
- RelationInitialize(); /* pre-allocated reldescs created here */
+ RelationInitialize(); /* pre-allocated reldescs created here */
InitializeTransactionSystem(); /* pg_log,etc init/crash recovery here */
LockDisable(false);
/* ----------------
- * anyone knows what this does? something having to do with
+ * anyone knows what this does? something having to do with
* system catalog cache invalidation in the case of multiple
* backends, I think -cim 10/3/90
* Sets up MyBackendId a unique backend identifier.
@@ -605,9 +616,9 @@ InitPostgres(char *name) /* database name */
InitProcess(PostgresIpcKey);
if (MyBackendId > MaxBackendId || MyBackendId <= 0) {
- elog(FATAL, "cinit2: bad backend id %d (%d)",
- MyBackendTag,
- MyBackendId);
+ elog(FATAL, "cinit2: bad backend id %d (%d)",
+ MyBackendTag,
+ MyBackendId);
}
/* ----------------
@@ -617,7 +628,7 @@ InitPostgres(char *name) /* database name */
initam();
/* ----------------
- * initialize all the system catalog caches.
+ * initialize all the system catalog caches.
* ----------------
*/
zerocaches();
@@ -632,7 +643,7 @@ InitPostgres(char *name) /* database name */
InitUserid();
/* ----------------
- * ok, all done, now let's make sure we don't do it again.
+ * ok, all done, now let's make sure we don't do it again.
* ----------------
*/
PostgresIsInitialized = true;
@@ -644,10 +655,10 @@ InitPostgres(char *name) /* database name */
* ----------------
*/
if (!bootstrap)
- SetProcessingMode(NormalProcessing);
+ SetProcessingMode(NormalProcessing);
/* if (testFlag || lockingOff) */
if (lockingOff)
- LockDisable(true);
+ LockDisable(true);
}
diff --git a/src/bin/pg_version/Makefile b/src/bin/pg_version/Makefile
index 9e46bd27b08..b04b659a62e 100644
--- a/src/bin/pg_version/Makefile
+++ b/src/bin/pg_version/Makefile
@@ -7,20 +7,34 @@
#
#
# IDENTIFICATION
-# $Header: /cvsroot/pgsql/src/bin/pg_version/Attic/Makefile,v 1.1.1.1 1996/07/09 06:22:14 scrappy Exp $
+# $Header: /cvsroot/pgsql/src/bin/pg_version/Attic/Makefile,v 1.2 1996/11/12 06:46:54 bryanh Exp $
#
#-------------------------------------------------------------------------
-PROG= pg_version
-
-MKDIR= ../../mk
-include $(MKDIR)/postgres.mk
+SRCDIR= ../..
include ../Makefile.global
+include ../../Makefile.global
+
+OBJS= pg_version.o ../../utils/version.o
+
+all: pg_version
+
+pg_version: submake $(OBJS)
+ $(CC) $(LDFLAGS) -o pg_version $(OBJS) $(LD_ADD)
+
+.PHONY: submake
+submake:
+ $(MAKE) -C ../../utils version.o
-VPATH:=$(VPATH):$(srcdir)/backend/utils/init
-SRCS= pg_version.c magic.c
+install: pg_version
+ $(INSTALL) $(INSTL_EXE_OPTS) pg_version $(DESTDIR)$(BINDIR)/pg_version
-CFLAGS+= -I$(srcdir)/backend/port/$(PORTNAME)
+depend dep:
+ $(CC) -MM $(INCLUDE_OPT) *.c >depend
-include $(MKDIR)/postgres.prog.mk
+clean:
+ rm -f pg_version pg_version.o
+ifeq (depend,$(wildcard depend))
+include depend
+endif
diff --git a/src/bin/pg_version/pg_version.c b/src/bin/pg_version/pg_version.c
index 3212182ae39..5cdf3cad5d0 100644
--- a/src/bin/pg_version/pg_version.c
+++ b/src/bin/pg_version/pg_version.c
@@ -7,38 +7,34 @@
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/bin/pg_version/Attic/pg_version.c,v 1.5 1996/11/10 03:04:02 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/bin/pg_version/Attic/pg_version.c,v 1.6 1996/11/12 06:47:00 bryanh Exp $
*
*-------------------------------------------------------------------------
*/
#include <stdlib.h>
#include <stdio.h>
-int Noversion = 0;
-char *DataDir = (char *) NULL;
+#include <version.h> /* interface to SetPgVersion */
+
-extern void SetPgVersion(const char *);
int
main(int argc, char **argv)
{
+ int retcode; /* our eventual return code */
+ char *reason; /* Reason that SetPgVersion failed, NULL if it didn't. */
+
if (argc < 2) {
fprintf(stderr, "pg_version: missing argument\n");
exit(1);
}
- SetPgVersion(argv[1]);
- return(0);
-}
-
-void elog(void); /* make compiler happy */
-
-void
-elog(void) {}
-
-int GetDataHome(void); /* make compiler happy */
-
-int
-GetDataHome(void)
-{
- return(0);
+ SetPgVersion(argv[1], &reason);
+ if (reason) {
+ fprintf(stderr,
+ "pg_version is unable to create the PG_VERSION file. "
+ "SetPgVersion gave this reason: %s\n",
+ reason);
+ retcode = 10;
+ } else retcode = 0;
+ return(retcode);
}
diff --git a/src/include/miscadmin.h b/src/include/miscadmin.h
index 91ceb1140cd..da88c6f824d 100644
--- a/src/include/miscadmin.h
+++ b/src/include/miscadmin.h
@@ -12,7 +12,7 @@
*
* Copyright (c) 1994, Regents of the University of California
*
- * $Id: miscadmin.h,v 1.2 1996/11/06 10:28:59 scrappy Exp $
+ * $Id: miscadmin.h,v 1.3 1996/11/12 06:47:10 bryanh Exp $
*
* NOTES
* some of the information in this file will be moved to
@@ -70,14 +70,6 @@ extern Oid LastOidProcessed; /* for query rewrite */
#define NDBUFS 64
/*****************************************************************************
- * magic.h - definitions of the indexes of the magic numbers *
- *****************************************************************************/
-
-#define PG_RELEASE 6
-#define PG_VERSION 0
-#define PG_VERFILE "PG_VERSION"
-
-/*****************************************************************************
* pdir.h -- *
* POSTGRES directory path definitions. *
*****************************************************************************/
@@ -148,7 +140,6 @@ typedef int16 ExitStatus;
/* in utils/init/postinit.c */
extern void InitMyDatabaseId(void);
-extern void DoChdirAndInitDatabaseNameAndPath(char *name, char *path);
extern void InitUserid(void);
extern void InitCommunication(void);
extern void InitStdio(void);
@@ -170,12 +161,4 @@ extern bool IsNormalProcessingMode(void);
extern void SetProcessingMode(ProcessingMode mode);
extern ProcessingMode GetProcessingMode(void);
-
-/*
- * Prototypes for utils/init/magic.c
- */
-extern int DatabaseMetaGunkIsConsistent(const char *database, char *path);
-extern int ValidPgVersion(const char *path);
-extern void SetPgVersion(const char *path);
-
#endif /* MISCADMIN_H */