* Portions Copyright (c) 1996-2000, PostgreSQL, Inc
* Portions Copyright (c) 1994, Regents of the University of California
*
- * $Header: /cvsroot/pgsql/src/backend/access/transam/xlog.c,v 1.24 2000/11/05 22:50:19 vadim Exp $
+ * $Header: /cvsroot/pgsql/src/backend/access/transam/xlog.c,v 1.25 2000/11/09 11:25:58 vadim Exp $
*
*-------------------------------------------------------------------------
*/
char XLogDir[MAXPGPATH];
char ControlFilePath[MAXPGPATH];
-uint32 XLOGbuffers = 0;
+int XLOGbuffers = 0;
XLogRecPtr MyLastRecPtr = {0, 0};
bool StopIfError = false;
bool InRecovery = false;
StartUpID ThisStartUpID = 0;
-int XLOG_DEBUG = 1;
+int XLOG_DEBUG = 0;
/* To read/update control file and create new log file */
SPINLOCK ControlFileLockId;
elog(LOG, "MoveOfflineLogs: %s %s", (archdir[0]) ?
"archive" : "remove", xlde->d_name);
sprintf(path, "%s%c%s", XLogDir, SEP_CHAR, xlde->d_name);
- if (archdir[0] != 0)
+ if (archdir[0] == 0)
unlink(path);
errno = 0;
}
void
ShutdownXLOG()
{
-
+#ifdef XLOG
+ extern void CreateDummyCaches(void);
+#endif
elog(LOG, "Data Base System shutting down at %s", str_time(time(NULL)));
+#ifdef XLOG
+ CreateDummyCaches();
+#endif
CreateCheckPoint(true);
elog(LOG, "Data Base System shut down at %s", str_time(time(NULL)));
* Portions Copyright (c) 1994, Regents of the University of California
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/bootstrap/bootstrap.c,v 1.97 2000/11/08 22:09:56 tgl Exp $
+ * $Header: /cvsroot/pgsql/src/backend/bootstrap/bootstrap.c,v 1.98 2000/11/09 11:25:58 vadim Exp $
*
*-------------------------------------------------------------------------
*/
int i;
char *dbName;
int flag;
- bool xloginit = false;
+ int xlogop = BS_XLOG_NOP;
char *potential_DataDir = NULL;
extern int optind;
potential_DataDir = getenv("PGDATA"); /* Null if no PGDATA variable */
}
- while ((flag = getopt(argc, argv, "D:dCQxpB:F")) != EOF)
+ while ((flag = getopt(argc, argv, "D:dCQx:pB:F")) != EOF)
{
switch (flag)
{
Quiet = true;
break;
case 'x':
- xloginit = true;
+ xlogop = atoi(optarg);
break;
case 'p':
/* indicates fork from postmaster */
}
/*
- * Bootstrap under Postmaster means two things: (xloginit) ?
- * StartupXLOG : ShutdownXLOG
- *
- * If !under Postmaster and xloginit then BootStrapXLOG.
+ * XLOG operations
*/
- if (IsUnderPostmaster || xloginit)
+ if (xlogop != BS_XLOG_NOP)
{
snprintf(XLogDir, MAXPGPATH, "%s/pg_xlog", DataDir);
snprintf(ControlFilePath, MAXPGPATH, "%s/global/pg_control", DataDir);
+ if (xlogop == BS_XLOG_BOOTSTRAP)
+ BootStrapXLOG();
+ else
+ {
+ SetProcessingMode(NormalProcessing);
+ if (xlogop == BS_XLOG_STARTUP)
+ StartupXLOG();
+ else if (xlogop == BS_XLOG_CHECKPOINT)
+ {
+#ifdef XLOG
+ extern void CreateDummyCaches(void);
+ CreateDummyCaches();
+#endif
+ CreateCheckPoint(false);
+ }
+ else if (xlogop == BS_XLOG_SHUTDOWN)
+ ShutdownXLOG();
+ else
+ elog(STOP, "Unsupported XLOG op %d", xlogop);
+ proc_exit(0);
+ }
}
- if (IsUnderPostmaster && xloginit)
- {
- SetProcessingMode(NormalProcessing);
- StartupXLOG();
- proc_exit(0);
- }
-
- if (!IsUnderPostmaster && xloginit)
- BootStrapXLOG();
-
/*
* backend initialization
*/
InitPostgres(dbName, NULL);
LockDisable(true);
- if (IsUnderPostmaster && !xloginit)
- {
- SetProcessingMode(NormalProcessing);
- ShutdownXLOG();
- proc_exit(0);
- }
-
for (i = 0; i < MAXATTR; i++)
{
attrtypes[i] = (Form_pg_attribute) NULL;
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/postmaster/postmaster.c,v 1.180 2000/11/08 17:57:46 petere Exp $
+ * $Header: /cvsroot/pgsql/src/backend/postmaster/postmaster.c,v 1.181 2000/11/09 11:25:59 vadim Exp $
*
* NOTES
*
#include "utils/exc.h"
#include "utils/guc.h"
#include "utils/memutils.h"
-
+#include "bootstrap/bootstrap.h"
#define INVALID_SOCK (-1)
#define ARGV_SIZE 64
bool EnableSSL = false;
bool SilentMode = false; /* silent mode (-S) */
-static pid_t StartupPID = 0,
- ShutdownPID = 0;
+int CheckPointTimeout = 300;
+
+static pid_t StartupPID = 0,
+ ShutdownPID = 0,
+ CheckPointPID = 0;
+static time_t checkpointed = 0;
#define NoShutdown 0
#define SmartShutdown 1
static int CountChildren(void);
static bool CreateOptsFile(int argc, char *argv[]);
-extern int BootstrapMain(int argc, char *argv[]);
-static pid_t SSDataBase(bool startup);
+static pid_t SSDataBase(int xlop);
-#define StartupDataBase() SSDataBase(true)
-#define ShutdownDataBase() SSDataBase(false)
+#define StartupDataBase() SSDataBase(BS_XLOG_STARTUP)
+#define CheckPointDataBase() SSDataBase(BS_XLOG_CHECKPOINT)
+#define ShutdownDataBase() SSDataBase(BS_XLOG_SHUTDOWN)
#ifdef USE_SSL
static void InitSSL(void);
for (;;)
{
- Port *port;
- fd_set rmask,
- wmask;
- struct timeval *timeout = (struct timeval *) NULL;
-#ifdef USE_SSL
- struct timeval timeout_tv;
+ Port *port;
+ fd_set rmask,
+ wmask;
+ struct timeval *timeout = NULL;
+ struct timeval timeout_tv;
+
+ if (CheckPointPID == 0 && checkpointed)
+ {
+ time_t now = time(NULL);
+
+ if (CheckPointTimeout + checkpointed > now)
+ {
+ timeout_tv.tv_sec = CheckPointTimeout + checkpointed - now;
+ timeout_tv.tv_usec = 0;
+ timeout = &timeout_tv;
+ }
+ else
+ CheckPointPID = CheckPointDataBase();
+ }
+#ifdef USE_SSL
/*
* If we are using SSL, there may be input data already read and
* pending in SSL's input buffers. If so, check for additional
if (select(nSockets, &rmask, &wmask, (fd_set *) NULL, timeout) < 0)
{
+ PG_SETMASK(&BlockSig);
if (errno == EINTR || errno == EWOULDBLOCK)
continue;
fprintf(stderr, "%s: ServerLoop: select failed: %s\n",
backendPID = (int) ntohl(canc->backendPID);
cancelAuthCode = (long) ntohl(canc->cancelAuthCode);
+ if (backendPID == CheckPointPID)
+ {
+ if (DebugLvl)
+ fprintf(stderr, "%s: processCancelRequest: CheckPointPID in cancel request for process %d\n",
+ progname, backendPID);
+ return STATUS_ERROR;
+ }
+
/* See if we have a matching backend */
for (curr = DLGetHead(BackendList); curr; curr = DLGetSucc(curr))
*/
SetThisStartUpID();
+ CheckPointPID = 0;
+ checkpointed = time(NULL);
+
pqsignal(SIGCHLD, reaper);
return;
}
curr = DLGetSucc(curr);
}
- ProcRemove(pid);
+ if (pid == CheckPointPID)
+ {
+ CheckPointPID = 0;
+ checkpointed = time(NULL);
+ }
+ else
+ ProcRemove(pid);
return;
}
* only, couldn't we just sigpause?), so probably we'll remove
* this call from here someday. -- vadim 04-10-1999
*/
- ProcRemove(pid);
+ if (pid == CheckPointPID)
+ {
+ CheckPointPID = 0;
+ checkpointed = 0;
+ }
+ else
+ ProcRemove(pid);
DLRemove(curr);
free(bp);
if (bp->pid != mypid)
cnt++;
}
+ if (CheckPointPID != 0)
+ cnt--;
return cnt;
}
#endif
static pid_t
-SSDataBase(bool startup)
+SSDataBase(int xlop)
{
pid_t pid;
int i;
+ Backend *bn;
static char ssEntry[4][2 * ARGV_SIZE];
for (i = 0; i < 4; ++i)
int ac = 0;
char nbbuf[ARGV_SIZE];
char dbbuf[ARGV_SIZE];
+ char xlbuf[ARGV_SIZE];
/* Lose the postmaster's on-exit routines and port connections */
on_exit_reset();
sprintf(nbbuf, "-B%u", NBuffers);
av[ac++] = nbbuf;
- if (startup)
- av[ac++] = "-x";
+ sprintf(xlbuf, "-x %d", xlop);
+ av[ac++] = xlbuf;
av[ac++] = "-p";
if (pid < 0)
{
fprintf(stderr, "%s Data Base: fork failed: %s\n",
- ((startup) ? "Startup" : "Shutdown"), strerror(errno));
+ ((xlop == BS_XLOG_STARTUP) ? "Startup" :
+ ((xlop == BS_XLOG_CHECKPOINT) ? "CheckPoint" :
+ "Shutdown")), strerror(errno));
ExitPostmaster(1);
}
NextBackendTag -= 1;
+ if (xlop != BS_XLOG_CHECKPOINT)
+ return(pid);
+
+ if (!(bn = (Backend *) calloc(1, sizeof(Backend))))
+ {
+ fprintf(stderr, "%s: CheckPointDataBase: malloc failed\n",
+ progname);
+ ExitPostmaster(1);
+ }
+
+ bn->pid = pid;
+ bn->cancel_key = 0;
+ DLAddHead(BackendList, DLNewElem(bn));
+
return (pid);
}
* Support for grand unified configuration scheme, including SET
* command, configuration file, and command line options.
*
- * $Header: /cvsroot/pgsql/src/backend/utils/misc/guc.c,v 1.15 2000/11/01 21:14:03 petere Exp $
+ * $Header: /cvsroot/pgsql/src/backend/utils/misc/guc.c,v 1.16 2000/11/09 11:25:59 vadim Exp $
*
* Copyright 2000 by PostgreSQL Global Development Group
* Written by Peter Eisentraut <peter_e@gmx.net>.
/* XXX should be in a header file */
extern bool Log_connections;
+extern int CheckPointTimeout;
+extern int XLOGbuffers;
+extern int XLOG_DEBUG;
+
/*
* Debugging options
*/
{"unix_socket_permissions", PGC_POSTMASTER, &Unix_socket_permissions,
0777, 0000, 0777},
+ {"checkpoint_timeout", PGC_POSTMASTER, &CheckPointTimeout,
+ 300, 30, 1800},
+
+ {"wal_buffers", PGC_POSTMASTER, &XLOGbuffers,
+ 4, 4, INT_MAX},
+
+ {"wal_debug", PGC_POSTMASTER, &XLOG_DEBUG,
+ 0, 0, 16},
+
{NULL, 0, NULL, 0, 0, 0}
};
#
# Copyright (c) 1994, Regents of the University of California
#
-# $Header: /cvsroot/pgsql/src/bin/initdb/Attic/initdb.sh,v 1.111 2000/11/06 22:18:09 petere Exp $
+# $Header: /cvsroot/pgsql/src/bin/initdb/Attic/initdb.sh,v 1.112 2000/11/09 11:26:00 vadim Exp $
#
#-------------------------------------------------------------------------
fi
BACKENDARGS="-boot -C -F -D$PGDATA $BACKEND_TALK_ARG"
-FIRSTRUN="-boot -x -C -F -D$PGDATA $BACKEND_TALK_ARG"
+FIRSTRUN="-boot -x1 -C -F -D$PGDATA $BACKEND_TALK_ARG"
echo "Creating template database in $PGDATA/base/1"
[ "$debug" = yes ] && echo "Running: $PGPATH/postgres $FIRSTRUN template1"
* Portions Copyright (c) 1996-2000, PostgreSQL, Inc
* Portions Copyright (c) 1994, Regents of the University of California
*
- * $Id: bootstrap.h,v 1.19 2000/07/14 22:17:54 tgl Exp $
+ * $Id: bootstrap.h,v 1.20 2000/11/09 11:26:00 vadim Exp $
*
*-------------------------------------------------------------------------
*/
extern int Int_yylex(void);
extern void Int_yyerror(const char *str);
+#define BS_XLOG_NOP 0
+#define BS_XLOG_BOOTSTRAP 1
+#define BS_XLOG_STARTUP 2
+#define BS_XLOG_CHECKPOINT 3
+#define BS_XLOG_SHUTDOWN 4
+
#endif /* BOOTSTRAP_H */
projects / postgresql / commitdiff