#include "postgres_fe.h"#include <ctype.h>#include <dirent.h>#include <sys/stat.h>#include <fcntl.h>#include <signal.h>#include <sys/time.h>#include <unistd.h>
Go to the source code of this file.
Defines | |
| #define | NoFailover 0 |
| #define | SmartFailover 1 |
| #define | FastFailover 2 |
| #define | RESTORE_COMMAND_COPY 0 |
| #define | RESTORE_COMMAND_LINK 1 |
| #define | XLOG_DATA 0 |
| #define | XLOG_HISTORY 1 |
| #define | XLOG_BACKUP_LABEL 2 |
| #define | SET_RESTORE_COMMAND(cmd, arg1, arg2) snprintf(restoreCommand, MAXPGPATH, cmd " \"%s\" \"%s\"", arg1, arg2) |
| #define | XLOG_DATA_FNAME_LEN 24 |
| #define | XLogFileName(fname, tli, log, seg) snprintf(fname, XLOG_DATA_FNAME_LEN + 1, "%08X%08X%08X", tli, log, seg) |
| #define | MaxSegmentsPerLogFile ( 0xFFFFFFFF / XLOG_SEG_SIZE ) |
Functions | |
| static void | CustomizableInitialize (void) |
| static bool | CustomizableNextWALFileReady () |
| static void | CustomizableCleanupPriorWALFiles (void) |
| static bool | SetWALFileNameForCleanup (void) |
| static void | CheckForExternalTrigger (void) |
| static bool | RestoreWALFileForRecovery (void) |
| static void | usage (void) |
| static void | sighandler (int sig) |
| static void | sigquit_handler (int sig) |
| int | main (int argc, char **argv) |
Variables | |
| char * | optarg |
| int | optind |
| const char * | progname |
| int | sleeptime = 5 |
| int | waittime = -1 |
| int | maxwaittime = 0 |
| int | keepfiles = 0 |
| int | maxretries = 3 |
| bool | debug = false |
| bool | need_cleanup = false |
| static volatile sig_atomic_t | signaled = false |
| char * | archiveLocation |
| char * | triggerPath |
| char * | xlogFilePath |
| char * | nextWALFileName |
| char * | restartWALFileName |
| char * | priorWALFileName |
| char | WALFilePath [MAXPGPATH] |
| char | restoreCommand [MAXPGPATH] |
| char | exclusiveCleanupFileName [MAXPGPATH] |
| static int | Failover = NoFailover |
| int | restoreCommandType |
| int | nextWALFileType |
| struct stat | stat_buf |
| #define FastFailover 2 |
Definition at line 94 of file pg_standby.c.
Referenced by main().
| #define MaxSegmentsPerLogFile ( 0xFFFFFFFF / XLOG_SEG_SIZE ) |
Definition at line 238 of file pg_standby.c.
Referenced by SetWALFileNameForCleanup().
| #define NoFailover 0 |
Definition at line 92 of file pg_standby.c.
| #define RESTORE_COMMAND_COPY 0 |
Definition at line 98 of file pg_standby.c.
Referenced by CustomizableInitialize().
| #define RESTORE_COMMAND_LINK 1 |
Definition at line 99 of file pg_standby.c.
Referenced by CustomizableInitialize().
| #define SET_RESTORE_COMMAND | ( | cmd, | ||
| arg1, | ||||
| arg2 | ||||
| ) | snprintf(restoreCommand, MAXPGPATH, cmd " \"%s\" \"%s\"", arg1, arg2) |
Definition at line 107 of file pg_standby.c.
Referenced by CustomizableInitialize().
| #define SmartFailover 1 |
Definition at line 93 of file pg_standby.c.
Referenced by main().
| #define XLOG_BACKUP_LABEL 2 |
Definition at line 104 of file pg_standby.c.
| #define XLOG_DATA 0 |
Definition at line 102 of file pg_standby.c.
Referenced by CustomizableCleanupPriorWALFiles().
| #define XLOG_DATA_FNAME_LEN 24 |
Definition at line 127 of file pg_standby.c.
Referenced by CustomizableCleanupPriorWALFiles().
| #define XLOG_HISTORY 1 |
Definition at line 103 of file pg_standby.c.
| #define XLogFileName | ( | fname, | ||
| tli, | ||||
| log, | ||||
| seg | ||||
| ) | snprintf(fname, XLOG_DATA_FNAME_LEN + 1, "%08X%08X%08X", tli, log, seg) |
Definition at line 129 of file pg_standby.c.
Referenced by SetWALFileNameForCleanup().
| static void CheckForExternalTrigger | ( | void | ) | [static] |
Definition at line 386 of file pg_standby.c.
References buf, close, Failover, ftruncate, read, stat_buf, strerror(), and triggerPath.
Referenced by main().
{
char buf[32];
int fd;
int len;
/*
* Look for a trigger file, if that option has been selected
*
* We use stat() here because triggerPath is always a file rather than
* potentially being in an archive
*/
if (!triggerPath || stat(triggerPath, &stat_buf) != 0)
return;
/*
* An empty trigger file performs smart failover. There's a little race
* condition here: if the writer of the trigger file has just created the
* file, but not yet written anything to it, we'll treat that as smart
* shutdown even if the other process was just about to write "fast" to
* it. But that's fine: we'll restore one more WAL file, and when we're
* invoked next time, we'll see the word "fast" and fail over immediately.
*/
if (stat_buf.st_size == 0)
{
Failover = SmartFailover;
fprintf(stderr, "trigger file found: smart failover\n");
fflush(stderr);
return;
}
if ((fd = open(triggerPath, O_RDWR, 0)) < 0)
{
fprintf(stderr, "WARNING: could not open \"%s\": %s\n",
triggerPath, strerror(errno));
fflush(stderr);
return;
}
if ((len = read(fd, buf, sizeof(buf))) < 0)
{
fprintf(stderr, "WARNING: could not read \"%s\": %s\n",
triggerPath, strerror(errno));
fflush(stderr);
close(fd);
return;
}
buf[len] = '\0';
if (strncmp(buf, "smart", 5) == 0)
{
Failover = SmartFailover;
fprintf(stderr, "trigger file found: smart failover\n");
fflush(stderr);
close(fd);
return;
}
if (strncmp(buf, "fast", 4) == 0)
{
Failover = FastFailover;
fprintf(stderr, "trigger file found: fast failover\n");
fflush(stderr);
/*
* Turn it into a "smart" trigger by truncating the file. Otherwise if
* the server asks us again to restore a segment that was restored
* already, we would return "not found" and upset the server.
*/
if (ftruncate(fd, 0) < 0)
{
fprintf(stderr, "WARNING: could not read \"%s\": %s\n",
triggerPath, strerror(errno));
fflush(stderr);
}
close(fd);
return;
}
close(fd);
fprintf(stderr, "WARNING: invalid content in \"%s\"\n", triggerPath);
fflush(stderr);
return;
}
| static void CustomizableCleanupPriorWALFiles | ( | void | ) | [static] |
Definition at line 241 of file pg_standby.c.
References archiveLocation, closedir(), dirent::d_name, debug, exclusiveCleanupFileName, MAXPGPATH, nextWALFileType, NULL, opendir(), progname, readdir(), snprintf(), strerror(), unlink(), WALFilePath, XLOG_DATA, and XLOG_DATA_FNAME_LEN.
Referenced by main().
{
/*
* Work out name of prior file from current filename
*/
if (nextWALFileType == XLOG_DATA)
{
int rc;
DIR *xldir;
struct dirent *xlde;
/*
* Assume it's OK to keep failing. The failure situation may change
* over time, so we'd rather keep going on the main processing than
* fail because we couldn't clean up yet.
*/
if ((xldir = opendir(archiveLocation)) != NULL)
{
while ((xlde = readdir(xldir)) != NULL)
{
/*
* We ignore the timeline part of the XLOG segment identifiers
* in deciding whether a segment is still needed. This
* ensures that we won't prematurely remove a segment from a
* parent timeline. We could probably be a little more
* proactive about removing segments of non-parent timelines,
* but that would be a whole lot more complicated.
*
* We use the alphanumeric sorting property of the filenames
* to decide which ones are earlier than the
* exclusiveCleanupFileName file. Note that this means files
* are not removed in the order they were originally written,
* in case this worries you.
*/
if (strlen(xlde->d_name) == XLOG_DATA_FNAME_LEN &&
strspn(xlde->d_name, "0123456789ABCDEF") == XLOG_DATA_FNAME_LEN &&
strcmp(xlde->d_name + 8, exclusiveCleanupFileName + 8) < 0)
{
#ifdef WIN32
snprintf(WALFilePath, MAXPGPATH, "%s\\%s", archiveLocation, xlde->d_name);
#else
snprintf(WALFilePath, MAXPGPATH, "%s/%s", archiveLocation, xlde->d_name);
#endif
if (debug)
fprintf(stderr, "\nremoving file \"%s\"", WALFilePath);
rc = unlink(WALFilePath);
if (rc != 0)
{
fprintf(stderr, "\n%s: ERROR: could not remove file \"%s\": %s\n",
progname, WALFilePath, strerror(errno));
break;
}
}
}
if (debug)
fprintf(stderr, "\n");
}
else
fprintf(stderr, "%s: could not open archive location \"%s\": %s\n",
progname, archiveLocation, strerror(errno));
closedir(xldir);
fflush(stderr);
}
}
| static void CustomizableInitialize | ( | void | ) | [static] |
Definition at line 139 of file pg_standby.c.
References archiveLocation, MAXPGPATH, nextWALFileName, progname, RESTORE_COMMAND_COPY, RESTORE_COMMAND_LINK, restoreCommandType, SET_RESTORE_COMMAND, snprintf(), stat_buf, WALFilePath, and xlogFilePath.
Referenced by main().
{
#ifdef WIN32
snprintf(WALFilePath, MAXPGPATH, "%s\\%s", archiveLocation, nextWALFileName);
switch (restoreCommandType)
{
case RESTORE_COMMAND_LINK:
SET_RESTORE_COMMAND("mklink", WALFilePath, xlogFilePath);
break;
case RESTORE_COMMAND_COPY:
default:
SET_RESTORE_COMMAND("copy", WALFilePath, xlogFilePath);
break;
}
#else
snprintf(WALFilePath, MAXPGPATH, "%s/%s", archiveLocation, nextWALFileName);
switch (restoreCommandType)
{
case RESTORE_COMMAND_LINK:
#if HAVE_WORKING_LINK
SET_RESTORE_COMMAND("ln -s -f", WALFilePath, xlogFilePath);
break;
#endif
case RESTORE_COMMAND_COPY:
default:
SET_RESTORE_COMMAND("cp", WALFilePath, xlogFilePath);
break;
}
#endif
/*
* This code assumes that archiveLocation is a directory You may wish to
* add code to check for tape libraries, etc.. So, since it is a
* directory, we use stat to test if it's accessible
*/
if (stat(archiveLocation, &stat_buf) != 0)
{
fprintf(stderr, "%s: archive location \"%s\" does not exist\n", progname, archiveLocation);
fflush(stderr);
exit(2);
}
}
| static bool CustomizableNextWALFileReady | ( | ) | [static] |
Definition at line 188 of file pg_standby.c.
References debug, nextWALFileName, nextWALFileType, pg_usleep(), sleeptime, stat_buf, and WALFilePath.
Referenced by main().
{
if (stat(WALFilePath, &stat_buf) == 0)
{
/*
* If it's a backup file, return immediately. If it's a regular file
* return only if it's the right size already.
*/
if (strlen(nextWALFileName) > 24 &&
strspn(nextWALFileName, "0123456789ABCDEF") == 24 &&
strcmp(nextWALFileName + strlen(nextWALFileName) - strlen(".backup"),
".backup") == 0)
{
nextWALFileType = XLOG_BACKUP_LABEL;
return true;
}
else if (stat_buf.st_size == XLOG_SEG_SIZE)
{
#ifdef WIN32
/*
* Windows 'cp' sets the final file size before the copy is
* complete, and not yet ready to be opened by pg_standby. So we
* wait for sleeptime secs before attempting to restore. If that
* is not enough, we will rely on the retry/holdoff mechanism.
* GNUWin32's cp does not have this problem.
*/
pg_usleep(sleeptime * 1000000L);
#endif
nextWALFileType = XLOG_DATA;
return true;
}
/*
* If still too small, wait until it is the correct size
*/
if (stat_buf.st_size > XLOG_SEG_SIZE)
{
if (debug)
{
fprintf(stderr, "file size greater than expected\n");
fflush(stderr);
}
exit(3);
}
}
return false;
}
| int main | ( | int | argc, | |
| char ** | argv | |||
| ) |
Definition at line 559 of file pg_standby.c.
References archiveLocation, CheckForExternalTrigger(), CustomizableCleanupPriorWALFiles(), CustomizableInitialize(), CustomizableNextWALFileReady(), debug, exclusiveCleanupFileName, Failover, FastFailover, get_progname(), getopt(), keepfiles, maxretries, maxwaittime, need_cleanup, nextWALFileName, nextWALFileType, optarg, optind, pg_usleep(), pqsignal(), progname, restartWALFileName, restoreCommand, restoreCommandType, RestoreWALFileForRecovery(), SetWALFileNameForCleanup(), sighandler(), signaled, SIGQUIT, sigquit_handler(), SIGUSR1, sleeptime, SmartFailover, triggerPath, usage(), waittime, WALFilePath, and xlogFilePath.
{
int c;
progname = get_progname(argv[0]);
if (argc > 1)
{
if (strcmp(argv[1], "--help") == 0 || strcmp(argv[1], "-?") == 0)
{
usage();
exit(0);
}
if (strcmp(argv[1], "--version") == 0 || strcmp(argv[1], "-V") == 0)
{
puts("pg_standby (PostgreSQL) " PG_VERSION);
exit(0);
}
}
#ifndef WIN32
/*
* You can send SIGUSR1 to trigger failover.
*
* Postmaster uses SIGQUIT to request immediate shutdown. The default
* action is to core dump, but we don't want that, so trap it and commit
* suicide without core dump.
*
* We used to use SIGINT and SIGQUIT to trigger failover, but that turned
* out to be a bad idea because postmaster uses SIGQUIT to request
* immediate shutdown. We still trap SIGINT, but that may change in a
* future release.
*
* There's no way to trigger failover via signal on Windows.
*/
(void) pqsignal(SIGUSR1, sighandler);
(void) pqsignal(SIGINT, sighandler); /* deprecated, use SIGUSR1 */
(void) pqsignal(SIGQUIT, sigquit_handler);
#endif
while ((c = getopt(argc, argv, "cdk:lr:s:t:w:")) != -1)
{
switch (c)
{
case 'c': /* Use copy */
restoreCommandType = RESTORE_COMMAND_COPY;
break;
case 'd': /* Debug mode */
debug = true;
break;
case 'k': /* keepfiles */
keepfiles = atoi(optarg);
if (keepfiles < 0)
{
fprintf(stderr, "%s: -k keepfiles must be >= 0\n", progname);
exit(2);
}
break;
case 'l': /* Use link */
/*
* Link feature disabled, possibly permanently. Linking causes
* a problem after recovery ends that is not currently
* resolved by PostgreSQL. 25 Jun 2009
*/
#ifdef NOT_USED
restoreCommandType = RESTORE_COMMAND_LINK;
#endif
break;
case 'r': /* Retries */
maxretries = atoi(optarg);
if (maxretries < 0)
{
fprintf(stderr, "%s: -r maxretries must be >= 0\n", progname);
exit(2);
}
break;
case 's': /* Sleep time */
sleeptime = atoi(optarg);
if (sleeptime <= 0 || sleeptime > 60)
{
fprintf(stderr, "%s: -s sleeptime incorrectly set\n", progname);
exit(2);
}
break;
case 't': /* Trigger file */
triggerPath = strdup(optarg);
break;
case 'w': /* Max wait time */
maxwaittime = atoi(optarg);
if (maxwaittime < 0)
{
fprintf(stderr, "%s: -w maxwaittime incorrectly set\n", progname);
exit(2);
}
break;
default:
fprintf(stderr, "Try \"%s --help\" for more information.\n", progname);
exit(2);
break;
}
}
/*
* Parameter checking - after checking to see if trigger file present
*/
if (argc == 1)
{
fprintf(stderr, "%s: not enough command-line arguments\n", progname);
exit(2);
}
/*
* We will go to the archiveLocation to get nextWALFileName.
* nextWALFileName may not exist yet, which would not be an error, so we
* separate the archiveLocation and nextWALFileName so we can check
* separately whether archiveLocation exists, if not that is an error
*/
if (optind < argc)
{
archiveLocation = argv[optind];
optind++;
}
else
{
fprintf(stderr, "%s: must specify archive location\n", progname);
fprintf(stderr, "Try \"%s --help\" for more information.\n", progname);
exit(2);
}
if (optind < argc)
{
nextWALFileName = argv[optind];
optind++;
}
else
{
fprintf(stderr, "%s: must specify WAL file name as second non-option argument (use \"%%f\")\n", progname);
fprintf(stderr, "Try \"%s --help\" for more information.\n", progname);
exit(2);
}
if (optind < argc)
{
xlogFilePath = argv[optind];
optind++;
}
else
{
fprintf(stderr, "%s: must specify xlog destination as third non-option argument (use \"%%p\")\n", progname);
fprintf(stderr, "Try \"%s --help\" for more information.\n", progname);
exit(2);
}
if (optind < argc)
{
restartWALFileName = argv[optind];
optind++;
}
CustomizableInitialize();
need_cleanup = SetWALFileNameForCleanup();
if (debug)
{
fprintf(stderr, "Trigger file: %s\n", triggerPath ? triggerPath : "<not set>");
fprintf(stderr, "Waiting for WAL file: %s\n", nextWALFileName);
fprintf(stderr, "WAL file path: %s\n", WALFilePath);
fprintf(stderr, "Restoring to: %s\n", xlogFilePath);
fprintf(stderr, "Sleep interval: %d second%s\n",
sleeptime, (sleeptime > 1 ? "s" : " "));
fprintf(stderr, "Max wait interval: %d %s\n",
maxwaittime, (maxwaittime > 0 ? "seconds" : "forever"));
fprintf(stderr, "Command for restore: %s\n", restoreCommand);
fprintf(stderr, "Keep archive history: ");
if (need_cleanup)
fprintf(stderr, "%s and later\n", exclusiveCleanupFileName);
else
fprintf(stderr, "no cleanup required\n");
fflush(stderr);
}
/*
* Check for initial history file: always the first file to be requested
* It's OK if the file isn't there - all other files need to wait
*/
if (strlen(nextWALFileName) > 8 &&
strspn(nextWALFileName, "0123456789ABCDEF") == 8 &&
strcmp(nextWALFileName + strlen(nextWALFileName) - strlen(".history"),
".history") == 0)
{
nextWALFileType = XLOG_HISTORY;
if (RestoreWALFileForRecovery())
exit(0);
else
{
if (debug)
{
fprintf(stderr, "history file not found\n");
fflush(stderr);
}
exit(1);
}
}
/*
* Main wait loop
*/
for (;;)
{
/* Check for trigger file or signal first */
CheckForExternalTrigger();
#ifndef WIN32
if (signaled)
{
Failover = FastFailover;
if (debug)
{
fprintf(stderr, "signaled to exit: fast failover\n");
fflush(stderr);
}
}
#endif
/*
* Check for fast failover immediately, before checking if the
* requested WAL file is available
*/
if (Failover == FastFailover)
exit(1);
if (CustomizableNextWALFileReady())
{
/*
* Once we have restored this file successfully we can remove some
* prior WAL files. If this restore fails we musn't remove any
* file because some of them will be requested again immediately
* after the failed restore, or when we restart recovery.
*/
if (RestoreWALFileForRecovery())
{
if (need_cleanup)
CustomizableCleanupPriorWALFiles();
exit(0);
}
else
{
/* Something went wrong in copying the file */
exit(1);
}
}
/* Check for smart failover if the next WAL file was not available */
if (Failover == SmartFailover)
exit(1);
if (sleeptime <= 60)
pg_usleep(sleeptime * 1000000L);
waittime += sleeptime;
if (waittime >= maxwaittime && maxwaittime > 0)
{
Failover = FastFailover;
if (debug)
{
fprintf(stderr, "Timed out after %d seconds: fast failover\n",
waittime);
fflush(stderr);
}
}
if (debug)
{
fprintf(stderr, "WAL file not present yet.");
if (triggerPath)
fprintf(stderr, " Checking for trigger file...");
fprintf(stderr, "\n");
fflush(stderr);
}
}
}
| static bool RestoreWALFileForRecovery | ( | void | ) | [static] |
Definition at line 479 of file pg_standby.c.
References debug, maxretries, pg_usleep(), restoreCommand, sleeptime, and system().
Referenced by main().
{
int rc = 0;
int numretries = 0;
if (debug)
{
fprintf(stderr, "running restore: ");
fflush(stderr);
}
while (numretries <= maxretries)
{
rc = system(restoreCommand);
if (rc == 0)
{
if (debug)
{
fprintf(stderr, "OK\n");
fflush(stderr);
}
return true;
}
pg_usleep(numretries++ * sleeptime * 1000000L);
}
/*
* Allow caller to add additional info
*/
if (debug)
fprintf(stderr, "not restored\n");
return false;
}
| static bool SetWALFileNameForCleanup | ( | void | ) | [static] |
Definition at line 321 of file pg_standby.c.
References cleanup(), exclusiveCleanupFileName, keepfiles, MaxSegmentsPerLogFile, nextWALFileName, restartWALFileName, and XLogFileName.
Referenced by main().
{
uint32 tli = 1,
log = 0,
seg = 0;
uint32 log_diff = 0,
seg_diff = 0;
bool cleanup = false;
if (restartWALFileName)
{
/*
* Don't do cleanup if the restartWALFileName provided is later than
* the xlog file requested. This is an error and we must not remove
* these files from archive. This shouldn't happen, but better safe
* than sorry.
*/
if (strcmp(restartWALFileName, nextWALFileName) > 0)
return false;
strcpy(exclusiveCleanupFileName, restartWALFileName);
return true;
}
if (keepfiles > 0)
{
sscanf(nextWALFileName, "%08X%08X%08X", &tli, &log, &seg);
if (tli > 0 && log >= 0 && seg > 0)
{
log_diff = keepfiles / MaxSegmentsPerLogFile;
seg_diff = keepfiles % MaxSegmentsPerLogFile;
if (seg_diff > seg)
{
log_diff++;
seg = MaxSegmentsPerLogFile - (seg_diff - seg);
}
else
seg -= seg_diff;
if (log >= log_diff)
{
log -= log_diff;
cleanup = true;
}
else
{
log = 0;
seg = 0;
}
}
}
XLogFileName(exclusiveCleanupFileName, tli, log, seg);
return cleanup;
}
| static void sighandler | ( | int | sig | ) | [static] |
Definition at line 543 of file pg_standby.c.
References signaled.
Referenced by main().
{
signaled = true;
}
| static void sigquit_handler | ( | int | sig | ) | [static] |
Definition at line 550 of file pg_standby.c.
References pqsignal(), and SIG_DFL.
Referenced by main().
| static void usage | ( | void | ) | [static] |
Definition at line 514 of file pg_standby.c.
References progname.
{
printf("%s allows PostgreSQL warm standby servers to be configured.\n\n", progname);
printf("Usage:\n");
printf(" %s [OPTION]... ARCHIVELOCATION NEXTWALFILE XLOGFILEPATH [RESTARTWALFILE]\n", progname);
printf("\nOptions:\n");
printf(" -c copy file from archive (default)\n");
printf(" -d generate lots of debugging output (testing only)\n");
printf(" -k NUMFILESTOKEEP if RESTARTWALFILE is not used, remove files prior to limit\n"
" (0 keeps all)\n");
printf(" -l does nothing; use of link is now deprecated\n");
printf(" -r MAXRETRIES max number of times to retry, with progressive wait\n"
" (default=3)\n");
printf(" -s SLEEPTIME seconds to wait between file checks (min=1, max=60,\n"
" default=5)\n");
printf(" -t TRIGGERFILE trigger file to initiate failover (no default)\n");
printf(" -V, --version output version information, then exit\n");
printf(" -w MAXWAITTIME max seconds to wait for a file (0=no limit) (default=0)\n");
printf(" -?, --help show this help, then exit\n");
printf("\n"
"Main intended use as restore_command in recovery.conf:\n"
" restore_command = 'pg_standby [OPTION]... ARCHIVELOCATION %%f %%p %%r'\n"
"e.g.\n"
" restore_command = 'pg_standby /mnt/server/archiverdir %%f %%p %%r'\n");
printf("\nReport bugs to <[email protected]>.\n");
}
| char* archiveLocation |
Definition at line 63 of file pg_standby.c.
| bool debug = false |
Definition at line 55 of file pg_standby.c.
| char exclusiveCleanupFileName[MAXPGPATH] |
Definition at line 71 of file pg_standby.c.
int Failover = NoFailover [static] |
Definition at line 96 of file pg_standby.c.
Referenced by CheckForExternalTrigger(), and main().
| int keepfiles = 0 |
Definition at line 53 of file pg_standby.c.
Referenced by main(), and SetWALFileNameForCleanup().
| int maxretries = 3 |
Definition at line 54 of file pg_standby.c.
Referenced by main(), and RestoreWALFileForRecovery().
| int maxwaittime = 0 |
Definition at line 52 of file pg_standby.c.
Referenced by main().
| bool need_cleanup = false |
Definition at line 56 of file pg_standby.c.
Referenced by main().
| char* nextWALFileName |
Definition at line 66 of file pg_standby.c.
Referenced by CustomizableInitialize(), CustomizableNextWALFileReady(), main(), and SetWALFileNameForCleanup().
| int nextWALFileType |
Definition at line 105 of file pg_standby.c.
Referenced by CustomizableCleanupPriorWALFiles(), CustomizableNextWALFileReady(), and main().
| char* priorWALFileName |
Definition at line 68 of file pg_standby.c.
| const char* progname |
Definition at line 46 of file pg_standby.c.
| char* restartWALFileName |
Definition at line 67 of file pg_standby.c.
| char restoreCommand[MAXPGPATH] |
Definition at line 70 of file pg_standby.c.
Referenced by main(), and RestoreWALFileForRecovery().
Definition at line 100 of file pg_standby.c.
Referenced by CustomizableInitialize(), and main().
volatile sig_atomic_t signaled = false [static] |
Definition at line 60 of file pg_standby.c.
Referenced by ExecuteRecoveryCommand(), main(), RestoreArchivedFile(), SICleanupQueue(), sighandler(), SignalSomeChildren(), and SignalUnconnectedWorkers().
| int sleeptime = 5 |
Definition at line 49 of file pg_standby.c.
Referenced by CustomizableNextWALFileReady(), main(), RestoreWALFileForRecovery(), and WalSndLoop().
| struct stat stat_buf |
Definition at line 110 of file pg_standby.c.
Referenced by CheckForExternalTrigger(), CustomizableInitialize(), and CustomizableNextWALFileReady().
| char* triggerPath |
Definition at line 64 of file pg_standby.c.
Referenced by CheckForExternalTrigger(), and main().
| int waittime = -1 |
Definition at line 50 of file pg_standby.c.
Referenced by AutoVacLauncherMain(), main(), and pg_timer_thread().
| char WALFilePath[MAXPGPATH] |
Definition at line 69 of file pg_standby.c.
| char* xlogFilePath |
Definition at line 65 of file pg_standby.c.
Referenced by CustomizableInitialize(), and main().
1.7.1