90 static void usage(
void);
94 main(
int argc,
char *argv[])
96 static struct option long_options[] = {
114 bool noupdate =
false;
119 char *log_fname = NULL;
128 if (strcmp(argv[1],
"--help") == 0 || strcmp(argv[1],
"-?") == 0)
133 if (strcmp(argv[1],
"--version") == 0 || strcmp(argv[1],
"-V") == 0)
135 puts(
"pg_resetwal (PostgreSQL) " PG_VERSION);
141 while ((
c =
getopt_long(argc, argv,
"c:D:e:fl:m:no:O:u:x:", long_options, NULL)) != -1)
160 if (endptr ==
optarg || *endptr !=
'\0' || errno != 0)
169 pg_fatal(
"transaction ID epoch (-e) must not be -1");
175 if (endptr ==
optarg || *endptr !=
'\0' || errno != 0)
188 if (endptr ==
optarg || *endptr !=
'\0' || errno != 0)
201 if (endptr ==
optarg || *endptr !=
',' || errno != 0)
208 if (endptr2 == endptr + 1 || *endptr2 !=
'\0' || errno != 0)
227 if (endptr ==
optarg || *endptr !=
'\0' || errno != 0)
240 if (endptr ==
optarg || *endptr !=
',' || errno != 0)
247 set_oldestmxid = strtoul(endptr + 1, &endptr2, 0);
248 if (endptr2 == endptr + 1 || *endptr2 !=
'\0' || errno != 0)
255 pg_fatal(
"multitransaction ID (-m) must not be 0");
261 if (set_oldestmxid == 0)
262 pg_fatal(
"oldest multitransaction ID (-m) must not be 0");
268 if (endptr ==
optarg || *endptr !=
'\0' || errno != 0)
275 pg_fatal(
"multitransaction offset (-O) must not be -1");
301 pg_fatal(
"argument of %s must be a power of two between 1 and 1024",
"--wal-segsize");
318 pg_log_error(
"too many command-line arguments (first is \"%s\")",
351 pg_fatal(
"could not read permissions of directory \"%s\": %m",
357 pg_fatal(
"could not change directory to \"%s\": %m",
367 if ((
fd = open(
"postmaster.pid", O_RDONLY, 0)) < 0)
370 pg_fatal(
"could not open file \"%s\" for reading: %m",
375 pg_log_error(
"lock file \"%s\" exists",
"postmaster.pid");
376 pg_log_error_hint(
"Is a server running? If not, delete the lock file and try again.");
394 if (log_fname != NULL)
406 if ((
guessed && !force) || noupdate)
475 pg_log_error(
"not proceeding because control file values were guessed");
485 pg_log_error(
"database server was not shut down cleanly");
500 printf(
_(
"Write-ahead log reset\n"));
520 const char *ver_file =
"PG_VERSION";
524 if ((ver_fd = fopen(ver_file,
"r")) == NULL)
525 pg_fatal(
"could not open file \"%s\" for reading: %m",
529 if (!fgets(rawline,
sizeof(rawline), ver_fd))
532 pg_fatal(
"unexpected empty file \"%s\"", ver_file);
534 pg_fatal(
"could not read file \"%s\": %m", ver_file);
540 if (strcmp(rawline, PG_MAJORVERSION) != 0)
543 pg_log_error_detail(
"File \"%s\" contains \"%s\", which is not compatible with this program's version \"%s\".",
544 ver_file, rawline, PG_MAJORVERSION);
573 pg_log_error(
"could not open file \"%s\" for reading: %m",
576 pg_log_error_hint(
"If you are sure the data directory path is correct, execute\n"
604 pg_log_warning(
"pg_control exists but has invalid CRC; proceed with caution");
614 "pg_control specifies invalid WAL segment size (%d bytes); proceed with caution",
624 pg_log_warning(
"pg_control exists but is broken or wrong version; ignoring it");
652 sysidentifier = ((
uint64) tv.tv_sec) << 32;
653 sysidentifier |= ((
uint64) tv.tv_usec) << 12;
654 sysidentifier |= getpid() & 0xFFF;
719 printf(
_(
"Guessed pg_control values:\n\n"));
721 printf(
_(
"Current pg_control values:\n\n"));
723 printf(
_(
"pg_control version number: %u\n"),
725 printf(
_(
"Catalog version number: %u\n"),
727 printf(
_(
"Database system identifier: %llu\n"),
729 printf(
_(
"Latest checkpoint's TimeLineID: %u\n"),
731 printf(
_(
"Latest checkpoint's full_page_writes: %s\n"),
733 printf(
_(
"Latest checkpoint's NextXID: %u:%u\n"),
736 printf(
_(
"Latest checkpoint's NextOID: %u\n"),
738 printf(
_(
"Latest checkpoint's NextMultiXactId: %u\n"),
740 printf(
_(
"Latest checkpoint's NextMultiOffset: %u\n"),
742 printf(
_(
"Latest checkpoint's oldestXID: %u\n"),
744 printf(
_(
"Latest checkpoint's oldestXID's DB: %u\n"),
746 printf(
_(
"Latest checkpoint's oldestActiveXID: %u\n"),
748 printf(
_(
"Latest checkpoint's oldestMultiXid: %u\n"),
750 printf(
_(
"Latest checkpoint's oldestMulti's DB: %u\n"),
752 printf(
_(
"Latest checkpoint's oldestCommitTsXid:%u\n"),
754 printf(
_(
"Latest checkpoint's newestCommitTsXid:%u\n"),
756 printf(
_(
"Maximum data alignment: %u\n"),
759 printf(
_(
"Database block size: %u\n"),
761 printf(
_(
"Blocks per segment of large relation: %u\n"),
763 printf(
_(
"WAL block size: %u\n"),
765 printf(
_(
"Bytes per WAL segment: %u\n"),
767 printf(
_(
"Maximum length of identifiers: %u\n"),
769 printf(
_(
"Maximum columns in an index: %u\n"),
771 printf(
_(
"Maximum size of a TOAST chunk: %u\n"),
773 printf(
_(
"Size of a large-object chunk: %u\n"),
776 printf(
_(
"Date/time type storage: %s\n"),
777 _(
"64-bit integers"));
778 printf(
_(
"Float8 argument passing: %s\n"),
780 printf(
_(
"Data page checksum version: %u\n"),
794 printf(
_(
"\n\nValues to be changed:\n\n"));
798 printf(
_(
"First log segment after reset: %s\n"), fname);
802 printf(
_(
"NextMultiXactId: %u\n"),
804 printf(
_(
"OldestMultiXid: %u\n"),
806 printf(
_(
"OldestMulti's DB: %u\n"),
812 printf(
_(
"NextMultiOffset: %u\n"),
828 printf(
_(
"OldestXID's DB: %u\n"),
834 printf(
_(
"NextXID epoch: %u\n"),
840 printf(
_(
"oldestCommitTsXid: %u\n"),
845 printf(
_(
"newestCommitTsXid: %u\n"),
851 printf(
_(
"Bytes per WAL segment: %u\n"),
930 while (errno = 0, (xlde =
readdir(xldir)) != NULL)
983 while (errno = 0, (xlde =
readdir(xldir)) != NULL)
989 if (unlink(path) < 0)
990 pg_fatal(
"could not delete file \"%s\": %m", path);
1008 #define ARCHSTATDIR XLOGDIR "/archive_status"
1018 while (errno = 0, (xlde =
readdir(xldir)) != NULL)
1027 if (unlink(path) < 0)
1028 pg_fatal(
"could not delete file \"%s\": %m", path);
1045 #define WALSUMMARYDIR XLOGDIR "/summaries"
1046 #define WALSUMMARY_NHEXCHARS 40
1056 while (errno = 0, (xlde =
readdir(xldir)) != NULL)
1062 if (unlink(path) < 0)
1063 pg_fatal(
"could not delete file \"%s\": %m", path);
1091 memset(buffer.
data, 0, XLOG_BLCKSZ);
1131 fd = open(path, O_RDWR | O_CREAT | O_EXCL |
PG_BINARY,
1134 pg_fatal(
"could not open file \"%s\": %m", path);
1137 if (
write(
fd, buffer.
data, XLOG_BLCKSZ) != XLOG_BLCKSZ)
1142 pg_fatal(
"could not write file \"%s\": %m", path);
1146 memset(buffer.
data, 0, XLOG_BLCKSZ);
1147 for (nbytes = XLOG_BLCKSZ; nbytes <
WalSegSz; nbytes += XLOG_BLCKSZ)
1150 if (
write(
fd, buffer.
data, XLOG_BLCKSZ) != XLOG_BLCKSZ)
1154 pg_fatal(
"could not write file \"%s\": %m", path);
1173 printf(
_(
" [-D, --pgdata=]DATADIR data directory\n"));
1174 printf(
_(
" -f, --force force update to be done even after unclean shutdown or\n"
1175 " if pg_control values had to be guessed\n"));
1176 printf(
_(
" -n, --dry-run no update, just show what would be done\n"));
1177 printf(
_(
" -V, --version output version information, then exit\n"));
1178 printf(
_(
" -?, --help show this help, then exit\n"));
1180 printf(
_(
"\nOptions to override control file values:\n"));
1181 printf(
_(
" -c, --commit-timestamp-ids=XID,XID\n"
1182 " set oldest and newest transactions bearing\n"
1183 " commit timestamp (zero means no change)\n"));
1184 printf(
_(
" -e, --epoch=XIDEPOCH set next transaction ID epoch\n"));
1185 printf(
_(
" -l, --next-wal-file=WALFILE set minimum starting location for new WAL\n"));
1186 printf(
_(
" -m, --multixact-ids=MXID,MXID set next and oldest multitransaction ID\n"));
1187 printf(
_(
" -o, --next-oid=OID set next OID\n"));
1188 printf(
_(
" -O, --multixact-offset=OFFSET set next multitransaction offset\n"));
1189 printf(
_(
" -u, --oldest-transaction-id=XID set oldest transaction ID\n"));
1190 printf(
_(
" -x, --next-transaction-id=XID set next transaction ID\n"));
1191 printf(
_(
" --wal-segsize=SIZE size of WAL segments, in megabytes\n"));
1193 printf(
_(
"\nReport bugs to <%s>.\n"), PACKAGE_BUGREPORT);
1194 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 void KillExistingWALSummaries(void)
#define WALSUMMARY_NHEXCHARS
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