89 static void usage(
void);
93 main(
int argc,
char *argv[])
95 static struct option long_options[] = {
113 bool noupdate =
false;
118 char *log_fname = NULL;
127 if (strcmp(argv[1],
"--help") == 0 || strcmp(argv[1],
"-?") == 0)
132 if (strcmp(argv[1],
"--version") == 0 || strcmp(argv[1],
"-V") == 0)
134 puts(
"pg_resetwal (PostgreSQL) " PG_VERSION);
140 while ((
c =
getopt_long(argc, argv,
"c:D:e:fl:m:no:O:u:x:", long_options, NULL)) != -1)
159 if (endptr ==
optarg || *endptr !=
'\0' || errno != 0)
168 pg_fatal(
"transaction ID epoch (-e) must not be -1");
174 if (endptr ==
optarg || *endptr !=
'\0' || errno != 0)
187 if (endptr ==
optarg || *endptr !=
'\0' || errno != 0)
200 if (endptr ==
optarg || *endptr !=
',' || errno != 0)
207 if (endptr2 == endptr + 1 || *endptr2 !=
'\0' || errno != 0)
226 if (endptr ==
optarg || *endptr !=
'\0' || errno != 0)
239 if (endptr ==
optarg || *endptr !=
',' || errno != 0)
246 set_oldestmxid = strtoul(endptr + 1, &endptr2, 0);
247 if (endptr2 == endptr + 1 || *endptr2 !=
'\0' || errno != 0)
254 pg_fatal(
"multitransaction ID (-m) must not be 0");
260 if (set_oldestmxid == 0)
261 pg_fatal(
"oldest multitransaction ID (-m) must not be 0");
267 if (endptr ==
optarg || *endptr !=
'\0' || errno != 0)
274 pg_fatal(
"multitransaction offset (-O) must not be -1");
300 pg_fatal(
"argument of %s must be a power of two between 1 and 1024",
"--wal-segsize");
317 pg_log_error(
"too many command-line arguments (first is \"%s\")",
350 pg_fatal(
"could not read permissions of directory \"%s\": %m",
356 pg_fatal(
"could not change directory to \"%s\": %m",
366 if ((
fd = open(
"postmaster.pid", O_RDONLY, 0)) < 0)
369 pg_fatal(
"could not open file \"%s\" for reading: %m",
374 pg_log_error(
"lock file \"%s\" exists",
"postmaster.pid");
375 pg_log_error_hint(
"Is a server running? If not, delete the lock file and try again.");
393 if (log_fname != NULL)
405 if ((
guessed && !force) || noupdate)
474 pg_log_error(
"not proceeding because control file values were guessed");
484 pg_log_error(
"database server was not shut down cleanly");
498 printf(
_(
"Write-ahead log reset\n"));
518 const char *ver_file =
"PG_VERSION";
522 if ((ver_fd = fopen(ver_file,
"r")) == NULL)
523 pg_fatal(
"could not open file \"%s\" for reading: %m",
527 if (!fgets(rawline,
sizeof(rawline), ver_fd))
530 pg_fatal(
"unexpected empty file \"%s\"", ver_file);
532 pg_fatal(
"could not read file \"%s\": %m", ver_file);
538 if (strcmp(rawline, PG_MAJORVERSION) != 0)
541 pg_log_error_detail(
"File \"%s\" contains \"%s\", which is not compatible with this program's version \"%s\".",
542 ver_file, rawline, PG_MAJORVERSION);
571 pg_log_error(
"could not open file \"%s\" for reading: %m",
574 pg_log_error_hint(
"If you are sure the data directory path is correct, execute\n"
602 pg_log_warning(
"pg_control exists but has invalid CRC; proceed with caution");
612 "pg_control specifies invalid WAL segment size (%d bytes); proceed with caution",
622 pg_log_warning(
"pg_control exists but is broken or wrong version; ignoring it");
633 uint64 sysidentifier;
650 sysidentifier = ((uint64) tv.tv_sec) << 32;
651 sysidentifier |= ((uint64) tv.tv_usec) << 12;
652 sysidentifier |= getpid() & 0xFFF;
717 printf(
_(
"Guessed pg_control values:\n\n"));
719 printf(
_(
"Current pg_control values:\n\n"));
721 printf(
_(
"pg_control version number: %u\n"),
723 printf(
_(
"Catalog version number: %u\n"),
725 printf(
_(
"Database system identifier: %llu\n"),
727 printf(
_(
"Latest checkpoint's TimeLineID: %u\n"),
729 printf(
_(
"Latest checkpoint's full_page_writes: %s\n"),
731 printf(
_(
"Latest checkpoint's NextXID: %u:%u\n"),
734 printf(
_(
"Latest checkpoint's NextOID: %u\n"),
736 printf(
_(
"Latest checkpoint's NextMultiXactId: %u\n"),
738 printf(
_(
"Latest checkpoint's NextMultiOffset: %u\n"),
740 printf(
_(
"Latest checkpoint's oldestXID: %u\n"),
742 printf(
_(
"Latest checkpoint's oldestXID's DB: %u\n"),
744 printf(
_(
"Latest checkpoint's oldestActiveXID: %u\n"),
746 printf(
_(
"Latest checkpoint's oldestMultiXid: %u\n"),
748 printf(
_(
"Latest checkpoint's oldestMulti's DB: %u\n"),
750 printf(
_(
"Latest checkpoint's oldestCommitTsXid:%u\n"),
752 printf(
_(
"Latest checkpoint's newestCommitTsXid:%u\n"),
754 printf(
_(
"Maximum data alignment: %u\n"),
757 printf(
_(
"Database block size: %u\n"),
759 printf(
_(
"Blocks per segment of large relation: %u\n"),
761 printf(
_(
"WAL block size: %u\n"),
763 printf(
_(
"Bytes per WAL segment: %u\n"),
765 printf(
_(
"Maximum length of identifiers: %u\n"),
767 printf(
_(
"Maximum columns in an index: %u\n"),
769 printf(
_(
"Maximum size of a TOAST chunk: %u\n"),
771 printf(
_(
"Size of a large-object chunk: %u\n"),
774 printf(
_(
"Date/time type storage: %s\n"),
775 _(
"64-bit integers"));
776 printf(
_(
"Float8 argument passing: %s\n"),
778 printf(
_(
"Data page checksum version: %u\n"),
792 printf(
_(
"\n\nValues to be changed:\n\n"));
796 printf(
_(
"First log segment after reset: %s\n"), fname);
800 printf(
_(
"NextMultiXactId: %u\n"),
802 printf(
_(
"OldestMultiXid: %u\n"),
804 printf(
_(
"OldestMulti's DB: %u\n"),
810 printf(
_(
"NextMultiOffset: %u\n"),
826 printf(
_(
"OldestXID's DB: %u\n"),
832 printf(
_(
"NextXID epoch: %u\n"),
838 printf(
_(
"oldestCommitTsXid: %u\n"),
843 printf(
_(
"newestCommitTsXid: %u\n"),
849 printf(
_(
"Bytes per WAL segment: %u\n"),
928 while (errno = 0, (xlde =
readdir(xldir)) != NULL)
981 while (errno = 0, (xlde =
readdir(xldir)) != NULL)
987 if (unlink(path) < 0)
988 pg_fatal(
"could not delete file \"%s\": %m", path);
1006 #define ARCHSTATDIR XLOGDIR "/archive_status"
1016 while (errno = 0, (xlde =
readdir(xldir)) != NULL)
1025 if (unlink(path) < 0)
1026 pg_fatal(
"could not delete file \"%s\": %m", path);
1055 memset(buffer.
data, 0, XLOG_BLCKSZ);
1095 fd = open(path, O_RDWR | O_CREAT | O_EXCL |
PG_BINARY,
1098 pg_fatal(
"could not open file \"%s\": %m", path);
1101 if (
write(
fd, buffer.
data, XLOG_BLCKSZ) != XLOG_BLCKSZ)
1106 pg_fatal(
"could not write file \"%s\": %m", path);
1110 memset(buffer.
data, 0, XLOG_BLCKSZ);
1111 for (nbytes = XLOG_BLCKSZ; nbytes <
WalSegSz; nbytes += XLOG_BLCKSZ)
1114 if (
write(
fd, buffer.
data, XLOG_BLCKSZ) != XLOG_BLCKSZ)
1118 pg_fatal(
"could not write file \"%s\": %m", path);
1137 printf(
_(
" [-D, --pgdata=]DATADIR data directory\n"));
1138 printf(
_(
" -f, --force force update to be done even after unclean shutdown or\n"
1139 " if pg_control values had to be guessed\n"));
1140 printf(
_(
" -n, --dry-run no update, just show what would be done\n"));
1141 printf(
_(
" -V, --version output version information, then exit\n"));
1142 printf(
_(
" -?, --help show this help, then exit\n"));
1144 printf(
_(
"\nOptions to override control file values:\n"));
1145 printf(
_(
" -c, --commit-timestamp-ids=XID,XID\n"
1146 " set oldest and newest transactions bearing\n"
1147 " commit timestamp (zero means no change)\n"));
1148 printf(
_(
" -e, --epoch=XIDEPOCH set next transaction ID epoch\n"));
1149 printf(
_(
" -l, --next-wal-file=WALFILE set minimum starting location for new WAL\n"));
1150 printf(
_(
" -m, --multixact-ids=MXID,MXID set next and oldest multitransaction ID\n"));
1151 printf(
_(
" -o, --next-oid=OID set next OID\n"));
1152 printf(
_(
" -O, --multixact-offset=OFFSET set next multitransaction offset\n"));
1153 printf(
_(
" -u, --oldest-transaction-id=XID set oldest transaction ID\n"));
1154 printf(
_(
" -x, --next-transaction-id=XID set next transaction ID\n"));
1155 printf(
_(
" --wal-segsize=SIZE size of WAL segments, in megabytes\n"));
1157 printf(
_(
"\nReport bugs to <%s>.\n"), PACKAGE_BUGREPORT);
1158 printf(
_(
"%s home page: <%s>\n"), PACKAGE_NAME, PACKAGE_URL);
#define ngettext(s, p, n)
#define PG_TEXTDOMAIN(domain)
TransactionId MultiXactId
#define CATALOG_VERSION_NO
void set_pglocale_pgservice(const char *argv0, const char *app)
void update_controlfile(const char *DataDir, ControlFileData *ControlFile, bool do_sync)
struct dirent * readdir(DIR *)
DIR * opendir(const char *)
char * pg_strdup(const char *in)
void * pg_malloc(size_t size)
bool GetDataDirectoryCreatePerm(const char *dataDir)
int getopt_long(int argc, char *const argv[], const char *optstring, const struct option *longopts, int *longindex)
#define required_argument
#define TOAST_MAX_CHUNK_SIZE
void pg_logging_init(const char *argv0)
#define pg_log_error(...)
#define pg_log_error_hint(...)
#define pg_log_error_detail(...)
bool option_parse_int(const char *optarg, const char *optname, int min_range, int max_range, int *result)
#define DEFAULT_XLOG_SEG_SIZE
#define FLOATFORMAT_VALUE
#define PG_CONTROL_VERSION
struct CheckPoint CheckPoint
#define XLOG_CHECKPOINT_SHUTDOWN
#define PG_CONTROL_FILE_SIZE
#define COMP_CRC32C(crc, data, len)
#define EQ_CRC32C(c1, c2)
PGDLLIMPORT char * optarg
static void FindEndOfXLOG(void)
static void RewriteControlFile(void)
int main(int argc, char *argv[])
static ControlFileData ControlFile
static void KillExistingXLOG(void)
static void CheckDataVersion(void)
static XLogSegNo minXlogSegNo
static int set_wal_segsize
static MultiXactOffset set_mxoff
static MultiXactId set_mxid
static TimeLineID minXlogTli
static TransactionId set_oldest_xid
static TransactionId set_oldest_commit_ts_xid
static TransactionId set_xid
static void PrintNewControlValues(void)
static XLogSegNo newXlogSegNo
static bool read_controlfile(void)
static void KillExistingArchiveStatus(void)
static void WriteEmptyXLOG(void)
static const char * progname
static void PrintControlValues(bool guessed)
static TransactionId set_newest_commit_ts_xid
static uint32 set_xid_epoch
static void GuessControlValues(void)
#define pg_log_warning(...)
const char * get_progname(const char *argv0)
static int fd(const char *x, int i)
void get_restricted_token(void)
int pg_strip_crlf(char *str)
MultiXactOffset nextMultiOffset
TransactionId newestCommitTsXid
TimeLineID PrevTimeLineID
TimeLineID ThisTimeLineID
TransactionId oldestActiveXid
FullTransactionId nextXid
TransactionId oldestCommitTsXid
uint32 pg_control_version
XLogRecPtr backupStartPoint
bool track_commit_timestamp
CheckPoint checkPointCopy
XLogRecPtr backupEndPoint
XLogRecPtr minRecoveryPoint
uint32 data_checksum_version
uint32 catalog_version_no
TimeLineID minRecoveryPointTLI
uint32 toast_max_chunk_size
#define InvalidTransactionId
#define EpochFromFullTransactionId(x)
#define XidFromFullTransactionId(x)
#define FirstGenbkiObjectId
#define FirstNormalTransactionId
static FullTransactionId FullTransactionIdFromEpochAndXid(uint32 epoch, TransactionId xid)
#define TransactionIdIsNormal(xid)
int gettimeofday(struct timeval *tp, void *tzp)
#define IsValidWalSegSize(size)
#define XLOG_CONTROL_FILE
static bool IsXLogFileName(const char *fname)
static void XLogFromFileName(const char *fname, TimeLineID *tli, XLogSegNo *logSegNo, int wal_segsz_bytes)
#define XLogSegNoOffsetToRecPtr(segno, offset, wal_segsz_bytes, dest)
XLogPageHeaderData * XLogPageHeader
#define XLByteToSeg(xlrp, logSegNo, wal_segsz_bytes)
static void XLogFilePath(char *path, TimeLineID tli, XLogSegNo logSegNo, int wal_segsz_bytes)
#define SizeOfXLogLongPHD
static void XLogFileName(char *fname, TimeLineID tli, XLogSegNo logSegNo, int wal_segsz_bytes)
static bool IsPartialXLogFileName(const char *fname)
#define FirstNormalUnloggedLSN
#define SizeOfXLogRecordDataHeaderShort
#define XLR_BLOCK_ID_DATA_SHORT