Age Owner Branch data TLA Line data Source code
1 : : /*-------------------------------------------------------------------------
2 : : *
3 : : * pg_resetwal.c
4 : : * A utility to "zero out" the xlog when it's corrupt beyond recovery.
5 : : * Can also rebuild pg_control if needed.
6 : : *
7 : : * The theory of operation is fairly simple:
8 : : * 1. Read the existing pg_control (which will include the last
9 : : * checkpoint record).
10 : : * 2. If pg_control is corrupt, attempt to intuit reasonable values,
11 : : * by scanning the old xlog if necessary.
12 : : * 3. Modify pg_control to reflect a "shutdown" state with a checkpoint
13 : : * record at the start of xlog.
14 : : * 4. Flush the existing xlog files and write a new segment with
15 : : * just a checkpoint record in it. The new segment is positioned
16 : : * just past the end of the old xlog, so that existing LSNs in
17 : : * data pages will appear to be "in the past".
18 : : * This is all pretty straightforward except for the intuition part of
19 : : * step 2 ...
20 : : *
21 : : *
22 : : * Portions Copyright (c) 1996-2024, PostgreSQL Global Development Group
23 : : * Portions Copyright (c) 1994, Regents of the University of California
24 : : *
25 : : * src/bin/pg_resetwal/pg_resetwal.c
26 : : *
27 : : *-------------------------------------------------------------------------
28 : : */
29 : :
30 : : /*
31 : : * We have to use postgres.h not postgres_fe.h here, because there's so much
32 : : * backend-only stuff in the XLOG include files we need. But we need a
33 : : * frontend-ish environment otherwise. Hence this ugly hack.
34 : : */
35 : : #define FRONTEND 1
36 : :
37 : : #include "postgres.h"
38 : :
39 : : #include <dirent.h>
40 : : #include <fcntl.h>
41 : : #include <sys/stat.h>
42 : : #include <sys/time.h>
43 : : #include <time.h>
44 : : #include <unistd.h>
45 : :
46 : : #include "access/heaptoast.h"
47 : : #include "access/multixact.h"
48 : : #include "access/transam.h"
49 : : #include "access/xlog.h"
50 : : #include "access/xlog_internal.h"
51 : : #include "common/controldata_utils.h"
52 : : #include "common/fe_memutils.h"
53 : : #include "common/file_perm.h"
54 : : #include "common/logging.h"
55 : : #include "common/restricted_token.h"
56 : : #include "common/string.h"
57 : : #include "fe_utils/option_utils.h"
58 : : #include "getopt_long.h"
59 : : #include "pg_getopt.h"
60 : : #include "storage/large_object.h"
61 : :
62 : : static ControlFileData ControlFile; /* pg_control values */
63 : : static XLogSegNo newXlogSegNo; /* new XLOG segment # */
64 : : static bool guessed = false; /* T if we had to guess at any values */
65 : : static const char *progname;
66 : : static uint32 set_xid_epoch = (uint32) -1;
67 : : static TransactionId set_oldest_xid = 0;
68 : : static TransactionId set_xid = 0;
69 : : static TransactionId set_oldest_commit_ts_xid = 0;
70 : : static TransactionId set_newest_commit_ts_xid = 0;
71 : : static Oid set_oid = 0;
72 : : static MultiXactId set_mxid = 0;
73 : : static MultiXactOffset set_mxoff = (MultiXactOffset) -1;
74 : : static TimeLineID minXlogTli = 0;
75 : : static XLogSegNo minXlogSegNo = 0;
76 : : static int WalSegSz;
77 : : static int set_wal_segsize;
78 : :
79 : : static void CheckDataVersion(void);
80 : : static bool read_controlfile(void);
81 : : static void GuessControlValues(void);
82 : : static void PrintControlValues(bool guessed);
83 : : static void PrintNewControlValues(void);
84 : : static void RewriteControlFile(void);
85 : : static void FindEndOfXLOG(void);
86 : : static void KillExistingXLOG(void);
87 : : static void KillExistingArchiveStatus(void);
88 : : static void KillExistingWALSummaries(void);
89 : : static void WriteEmptyXLOG(void);
90 : : static void usage(void);
91 : :
92 : :
93 : : int
7899 peter_e@gmx.net 94 :CBC 108 : main(int argc, char *argv[])
95 : : {
96 : : static struct option long_options[] = {
97 : : {"commit-timestamp-ids", required_argument, NULL, 'c'},
98 : : {"pgdata", required_argument, NULL, 'D'},
99 : : {"epoch", required_argument, NULL, 'e'},
100 : : {"force", no_argument, NULL, 'f'},
101 : : {"next-wal-file", required_argument, NULL, 'l'},
102 : : {"multixact-ids", required_argument, NULL, 'm'},
103 : : {"dry-run", no_argument, NULL, 'n'},
104 : : {"next-oid", required_argument, NULL, 'o'},
105 : : {"multixact-offset", required_argument, NULL, 'O'},
106 : : {"oldest-transaction-id", required_argument, NULL, 'u'},
107 : : {"next-transaction-id", required_argument, NULL, 'x'},
108 : : {"wal-segsize", required_argument, NULL, 1},
109 : : {NULL, 0, NULL, 0}
110 : : };
111 : :
112 : : int c;
113 : 108 : bool force = false;
114 : 108 : bool noupdate = false;
4099 alvherre@alvh.no-ip. 115 : 108 : MultiXactId set_oldestmxid = 0;
116 : : char *endptr;
117 : : char *endptr2;
3489 heikki.linnakangas@i 118 : 108 : char *DataDir = NULL;
2399 andres@anarazel.de 119 : 108 : char *log_fname = NULL;
120 : : int fd;
121 : :
1840 peter@eisentraut.org 122 : 108 : pg_logging_init(argv[0]);
2621 rhaas@postgresql.org 123 : 108 : set_pglocale_pgservice(argv[0], PG_TEXTDOMAIN("pg_resetwal"));
7681 bruce@momjian.us 124 : 108 : progname = get_progname(argv[0]);
125 : :
7899 peter_e@gmx.net 126 [ + + ]: 108 : if (argc > 1)
127 : : {
128 [ + + - + ]: 107 : if (strcmp(argv[1], "--help") == 0 || strcmp(argv[1], "-?") == 0)
129 : : {
130 : 1 : usage();
131 : 1 : exit(0);
132 : : }
133 [ + + + + ]: 106 : if (strcmp(argv[1], "--version") == 0 || strcmp(argv[1], "-V") == 0)
134 : : {
2621 rhaas@postgresql.org 135 : 28 : puts("pg_resetwal (PostgreSQL) " PG_VERSION);
7899 peter_e@gmx.net 136 : 28 : exit(0);
137 : : }
138 : : }
139 : :
140 : :
993 bruce@momjian.us 141 [ + + ]: 164 : while ((c = getopt_long(argc, argv, "c:D:e:fl:m:no:O:u:x:", long_options, NULL)) != -1)
142 : : {
7899 peter_e@gmx.net 143 [ + + + + : 107 : switch (c)
+ + + + +
+ + + + ]
144 : : {
3489 heikki.linnakangas@i 145 :GBC 4 : case 'D':
146 : 4 : DataDir = optarg;
147 : 4 : break;
148 : :
7899 peter_e@gmx.net 149 :CBC 14 : case 'f':
150 : 14 : force = true;
151 : 14 : break;
152 : :
153 : 24 : case 'n':
154 : 24 : noupdate = true;
155 : 24 : break;
156 : :
6446 tgl@sss.pgh.pa.us 157 : 8 : case 'e':
968 peter@eisentraut.org 158 : 8 : errno = 0;
6446 tgl@sss.pgh.pa.us 159 : 8 : set_xid_epoch = strtoul(optarg, &endptr, 0);
968 peter@eisentraut.org 160 [ + + + - : 8 : if (endptr == optarg || *endptr != '\0' || errno != 0)
- + ]
161 : : {
162 : : /*------
163 : : translator: the second %s is a command line argument (-e, etc) */
1840 peter@eisentraut.org 164 :GBC 1 : pg_log_error("invalid argument for option %s", "-e");
737 tgl@sss.pgh.pa.us 165 : 1 : pg_log_error_hint("Try \"%s --help\" for more information.", progname);
6446 166 : 1 : exit(1);
167 : : }
6446 tgl@sss.pgh.pa.us 168 [ + + ]:CBC 7 : if (set_xid_epoch == -1)
737 tgl@sss.pgh.pa.us 169 :GBC 1 : pg_fatal("transaction ID epoch (-e) must not be -1");
6446 tgl@sss.pgh.pa.us 170 :CBC 6 : break;
171 : :
993 bruce@momjian.us 172 : 7 : case 'u':
968 peter@eisentraut.org 173 : 7 : errno = 0;
993 bruce@momjian.us 174 : 7 : set_oldest_xid = strtoul(optarg, &endptr, 0);
968 peter@eisentraut.org 175 [ + + + - : 7 : if (endptr == optarg || *endptr != '\0' || errno != 0)
- + ]
176 : : {
993 bruce@momjian.us 177 :GBC 1 : pg_log_error("invalid argument for option %s", "-u");
737 tgl@sss.pgh.pa.us 178 : 1 : pg_log_error_hint("Try \"%s --help\" for more information.", progname);
993 bruce@momjian.us 179 : 1 : exit(1);
180 : : }
993 bruce@momjian.us 181 [ + + ]:CBC 6 : if (!TransactionIdIsNormal(set_oldest_xid))
737 tgl@sss.pgh.pa.us 182 :GBC 1 : pg_fatal("oldest transaction ID (-u) must be greater than or equal to %u", FirstNormalTransactionId);
993 bruce@momjian.us 183 :CBC 5 : break;
184 : :
7899 peter_e@gmx.net 185 : 7 : case 'x':
968 peter@eisentraut.org 186 : 7 : errno = 0;
7865 tgl@sss.pgh.pa.us 187 : 7 : set_xid = strtoul(optarg, &endptr, 0);
968 peter@eisentraut.org 188 [ + + + - : 7 : if (endptr == optarg || *endptr != '\0' || errno != 0)
- + ]
189 : : {
1840 peter@eisentraut.org 190 :GBC 1 : pg_log_error("invalid argument for option %s", "-x");
737 tgl@sss.pgh.pa.us 191 : 1 : pg_log_error_hint("Try \"%s --help\" for more information.", progname);
7865 192 : 1 : exit(1);
193 : : }
993 bruce@momjian.us 194 [ + + ]:CBC 6 : if (!TransactionIdIsNormal(set_xid))
737 tgl@sss.pgh.pa.us 195 :GBC 1 : pg_fatal("transaction ID (-x) must be greater than or equal to %u", FirstNormalTransactionId);
7899 peter_e@gmx.net 196 :CBC 5 : break;
197 : :
3420 alvherre@alvh.no-ip. 198 : 9 : case 'c':
968 peter@eisentraut.org 199 : 9 : errno = 0;
3030 mail@joeconway.com 200 : 9 : set_oldest_commit_ts_xid = strtoul(optarg, &endptr, 0);
968 peter@eisentraut.org 201 [ + + + - : 9 : if (endptr == optarg || *endptr != ',' || errno != 0)
- + ]
202 : : {
1840 peter@eisentraut.org 203 :GBC 1 : pg_log_error("invalid argument for option %s", "-c");
737 tgl@sss.pgh.pa.us 204 : 1 : pg_log_error_hint("Try \"%s --help\" for more information.", progname);
3420 alvherre@alvh.no-ip. 205 : 1 : exit(1);
206 : : }
3030 mail@joeconway.com 207 :CBC 8 : set_newest_commit_ts_xid = strtoul(endptr + 1, &endptr2, 0);
968 peter@eisentraut.org 208 [ + + + - : 8 : if (endptr2 == endptr + 1 || *endptr2 != '\0' || errno != 0)
- + ]
209 : : {
1840 peter@eisentraut.org 210 :GBC 1 : pg_log_error("invalid argument for option %s", "-c");
737 tgl@sss.pgh.pa.us 211 : 1 : pg_log_error_hint("Try \"%s --help\" for more information.", progname);
3420 alvherre@alvh.no-ip. 212 : 1 : exit(1);
213 : : }
214 : :
187 peter@eisentraut.org 215 [ + + ]:GNC 7 : if (set_oldest_commit_ts_xid < FirstNormalTransactionId &&
216 [ + - ]: 1 : set_oldest_commit_ts_xid != InvalidTransactionId)
217 : 1 : pg_fatal("transaction ID (-c) must be either %u or greater than or equal to %u", InvalidTransactionId, FirstNormalTransactionId);
218 : :
219 [ + + ]: 6 : if (set_newest_commit_ts_xid < FirstNormalTransactionId &&
220 [ + + ]: 3 : set_newest_commit_ts_xid != InvalidTransactionId)
221 : 1 : pg_fatal("transaction ID (-c) must be either %u or greater than or equal to %u", InvalidTransactionId, FirstNormalTransactionId);
3420 alvherre@alvh.no-ip. 222 :CBC 5 : break;
223 : :
7865 tgl@sss.pgh.pa.us 224 : 7 : case 'o':
968 peter@eisentraut.org 225 : 7 : errno = 0;
7865 tgl@sss.pgh.pa.us 226 : 7 : set_oid = strtoul(optarg, &endptr, 0);
968 peter@eisentraut.org 227 [ + + + - : 7 : if (endptr == optarg || *endptr != '\0' || errno != 0)
- + ]
228 : : {
1840 peter@eisentraut.org 229 :GBC 1 : pg_log_error("invalid argument for option %s", "-o");
737 tgl@sss.pgh.pa.us 230 : 1 : pg_log_error_hint("Try \"%s --help\" for more information.", progname);
7865 231 : 1 : exit(1);
232 : : }
7865 tgl@sss.pgh.pa.us 233 [ + + ]:CBC 6 : if (set_oid == 0)
737 tgl@sss.pgh.pa.us 234 :GBC 1 : pg_fatal("OID (-o) must not be 0");
7865 tgl@sss.pgh.pa.us 235 :CBC 5 : break;
236 : :
6926 237 : 9 : case 'm':
968 peter@eisentraut.org 238 : 9 : errno = 0;
6926 tgl@sss.pgh.pa.us 239 : 9 : set_mxid = strtoul(optarg, &endptr, 0);
968 peter@eisentraut.org 240 [ + + + - : 9 : if (endptr == optarg || *endptr != ',' || errno != 0)
- + ]
241 : : {
1840 peter@eisentraut.org 242 :GBC 1 : pg_log_error("invalid argument for option %s", "-m");
737 tgl@sss.pgh.pa.us 243 : 1 : pg_log_error_hint("Try \"%s --help\" for more information.", progname);
4099 alvherre@alvh.no-ip. 244 : 1 : exit(1);
245 : : }
246 : :
4099 alvherre@alvh.no-ip. 247 :CBC 8 : set_oldestmxid = strtoul(endptr + 1, &endptr2, 0);
968 peter@eisentraut.org 248 [ + + + - : 8 : if (endptr2 == endptr + 1 || *endptr2 != '\0' || errno != 0)
- + ]
249 : : {
1840 peter@eisentraut.org 250 :GBC 1 : pg_log_error("invalid argument for option %s", "-m");
737 tgl@sss.pgh.pa.us 251 : 1 : pg_log_error_hint("Try \"%s --help\" for more information.", progname);
6926 252 : 1 : exit(1);
253 : : }
6926 tgl@sss.pgh.pa.us 254 [ + + ]:CBC 7 : if (set_mxid == 0)
737 tgl@sss.pgh.pa.us 255 :GBC 1 : pg_fatal("multitransaction ID (-m) must not be 0");
256 : :
257 : : /*
258 : : * XXX It'd be nice to have more sanity checks here, e.g. so
259 : : * that oldest is not wrapped around w.r.t. nextMulti.
260 : : */
4099 alvherre@alvh.no-ip. 261 [ + + ]:CBC 6 : if (set_oldestmxid == 0)
737 tgl@sss.pgh.pa.us 262 :GBC 1 : pg_fatal("oldest multitransaction ID (-m) must not be 0");
6926 tgl@sss.pgh.pa.us 263 :CBC 5 : break;
264 : :
6885 265 : 7 : case 'O':
968 peter@eisentraut.org 266 : 7 : errno = 0;
6885 tgl@sss.pgh.pa.us 267 : 7 : set_mxoff = strtoul(optarg, &endptr, 0);
968 peter@eisentraut.org 268 [ + + + - : 7 : if (endptr == optarg || *endptr != '\0' || errno != 0)
- + ]
269 : : {
1840 peter@eisentraut.org 270 :GBC 1 : pg_log_error("invalid argument for option %s", "-O");
737 tgl@sss.pgh.pa.us 271 : 1 : pg_log_error_hint("Try \"%s --help\" for more information.", progname);
6885 272 : 1 : exit(1);
273 : : }
6885 tgl@sss.pgh.pa.us 274 [ + + ]:CBC 6 : if (set_mxoff == -1)
737 tgl@sss.pgh.pa.us 275 :GBC 1 : pg_fatal("multitransaction offset (-O) must not be -1");
6885 tgl@sss.pgh.pa.us 276 :CBC 5 : break;
277 : :
7899 peter_e@gmx.net 278 : 6 : case 'l':
3209 fujii@postgresql.org 279 [ + + ]: 6 : if (strspn(optarg, "01234567890ABCDEFabcdef") != XLOG_FNAME_LEN)
280 : : {
1840 peter@eisentraut.org 281 :GBC 1 : pg_log_error("invalid argument for option %s", "-l");
737 tgl@sss.pgh.pa.us 282 : 1 : pg_log_error_hint("Try \"%s --help\" for more information.", progname);
7899 peter_e@gmx.net 283 : 1 : exit(1);
284 : : }
285 : :
286 : : /*
287 : : * XLogFromFileName requires wal segment size which is not yet
288 : : * set. Hence wal details are set later on.
289 : : */
2399 andres@anarazel.de 290 :CBC 5 : log_fname = pg_strdup(optarg);
7899 peter_e@gmx.net 291 : 5 : break;
292 : :
2212 peter_e@gmx.net 293 :GBC 4 : case 1:
294 : : {
295 : : int wal_segsize_mb;
296 : :
230 peter@eisentraut.org 297 [ + + ]:GNC 4 : if (!option_parse_int(optarg, "--wal-segsize", 1, 1024, &wal_segsize_mb))
298 : 1 : exit(1);
299 : 3 : set_wal_segsize = wal_segsize_mb * 1024 * 1024;
300 [ + - + + : 3 : if (!IsValidWalSegSize(set_wal_segsize))
+ - - + ]
229 dgustafsson@postgres 301 : 1 : pg_fatal("argument of %s must be a power of two between 1 and 1024", "--wal-segsize");
230 peter@eisentraut.org 302 : 2 : break;
303 : : }
304 : :
7899 peter_e@gmx.net 305 :CBC 1 : default:
306 : : /* getopt_long already emitted a complaint */
737 tgl@sss.pgh.pa.us 307 : 1 : pg_log_error_hint("Try \"%s --help\" for more information.", progname);
7899 peter_e@gmx.net 308 : 1 : exit(1);
309 : : }
310 : : }
311 : :
3460 heikki.linnakangas@i 312 [ + + + + ]: 57 : if (DataDir == NULL && optind < argc)
313 : 52 : DataDir = argv[optind++];
314 : :
315 : : /* Complain if any arguments remain */
316 [ + + ]: 57 : if (optind < argc)
317 : : {
1840 peter@eisentraut.org 318 :GBC 1 : pg_log_error("too many command-line arguments (first is \"%s\")",
319 : : argv[optind]);
737 tgl@sss.pgh.pa.us 320 : 1 : pg_log_error_hint("Try \"%s --help\" for more information.", progname);
3460 heikki.linnakangas@i 321 : 1 : exit(1);
322 : : }
323 : :
3460 heikki.linnakangas@i 324 [ + + ]:CBC 56 : if (DataDir == NULL)
325 : : {
1840 peter@eisentraut.org 326 :GBC 1 : pg_log_error("no data directory specified");
737 tgl@sss.pgh.pa.us 327 : 1 : pg_log_error_hint("Try \"%s --help\" for more information.", progname);
7899 peter_e@gmx.net 328 : 1 : exit(1);
329 : : }
330 : :
331 : : /*
332 : : * Don't allow pg_resetwal to be run as root, to avoid overwriting the
333 : : * ownership of files in the data directory. We need only check for root
334 : : * -- any other user won't have sufficient permissions to modify files in
335 : : * the data directory.
336 : : */
337 : : #ifndef WIN32
7061 neilc@samurai.com 338 [ - + ]:CBC 55 : if (geteuid() == 0)
339 : : {
1840 peter@eisentraut.org 340 :UBC 0 : pg_log_error("cannot be executed by \"root\"");
737 tgl@sss.pgh.pa.us 341 : 0 : pg_log_error_hint("You must run %s as the PostgreSQL superuser.",
342 : : progname);
7061 neilc@samurai.com 343 : 0 : exit(1);
344 : : }
345 : : #endif
346 : :
1840 peter@eisentraut.org 347 :CBC 55 : get_restricted_token();
348 : :
349 : : /* Set mask based on PGDATA permissions */
2199 sfrost@snowman.net 350 [ + + ]: 55 : if (!GetDataDirectoryCreatePerm(DataDir))
737 tgl@sss.pgh.pa.us 351 :GBC 1 : pg_fatal("could not read permissions of directory \"%s\": %m",
352 : : DataDir);
353 : :
2199 sfrost@snowman.net 354 :CBC 54 : umask(pg_mode_mask);
355 : :
198 peter@eisentraut.org 356 [ - + ]: 54 : if (chdir(DataDir) < 0)
198 peter@eisentraut.org 357 :UBC 0 : pg_fatal("could not change directory to \"%s\": %m",
358 : : DataDir);
359 : :
360 : : /* Check that data directory matches our server version */
2512 tgl@sss.pgh.pa.us 361 :CBC 54 : CheckDataVersion();
362 : :
363 : : /*
364 : : * Check for a postmaster lock file --- if there is one, refuse to
365 : : * proceed, on grounds we might be interfering with a live installation.
366 : : */
4161 367 [ + + ]: 54 : if ((fd = open("postmaster.pid", O_RDONLY, 0)) < 0)
368 : : {
7899 peter_e@gmx.net 369 [ - + ]: 53 : if (errno != ENOENT)
737 tgl@sss.pgh.pa.us 370 :UBC 0 : pg_fatal("could not open file \"%s\" for reading: %m",
371 : : "postmaster.pid");
372 : : }
373 : : else
374 : : {
1840 peter@eisentraut.org 375 :GBC 1 : pg_log_error("lock file \"%s\" exists", "postmaster.pid");
737 tgl@sss.pgh.pa.us 376 : 1 : pg_log_error_hint("Is a server running? If not, delete the lock file and try again.");
6525 bruce@momjian.us 377 : 1 : exit(1);
378 : : }
379 : :
380 : : /*
381 : : * Attempt to read the existing pg_control file
382 : : */
1518 peter@eisentraut.org 383 [ + + ]:CBC 53 : if (!read_controlfile())
6525 bruce@momjian.us 384 : 4 : GuessControlValues();
385 : :
386 : : /*
387 : : * If no new WAL segment size was specified, use the control file value.
388 : : */
2212 peter_e@gmx.net 389 [ + + ]: 53 : if (set_wal_segsize != 0)
2212 peter_e@gmx.net 390 :GBC 2 : WalSegSz = set_wal_segsize;
391 : : else
2212 peter_e@gmx.net 392 :CBC 51 : WalSegSz = ControlFile.xlog_seg_size;
393 : :
2399 andres@anarazel.de 394 [ + + ]: 53 : if (log_fname != NULL)
395 : 5 : XLogFromFileName(log_fname, &minXlogTli, &minXlogSegNo, WalSegSz);
396 : :
397 : : /*
398 : : * Also look at existing segment files to set up newXlogSegNo
399 : : */
6337 tgl@sss.pgh.pa.us 400 : 53 : FindEndOfXLOG();
401 : :
402 : : /*
403 : : * If we're not going to proceed with the reset, print the current control
404 : : * file parameters.
405 : : */
3776 heikki.linnakangas@i 406 [ + + + + : 53 : if ((guessed && !force) || noupdate)
+ + ]
407 : 25 : PrintControlValues(guessed);
408 : :
409 : : /*
410 : : * Adjust fields if required by switches. (Do this now so that printout,
411 : : * if any, includes these values.)
412 : : */
6446 tgl@sss.pgh.pa.us 413 [ + + ]: 53 : if (set_xid_epoch != -1)
414 : : ControlFile.checkPointCopy.nextXid =
1844 tmunro@postgresql.or 415 : 6 : FullTransactionIdFromEpochAndXid(set_xid_epoch,
1342 andres@anarazel.de 416 : 6 : XidFromFullTransactionId(ControlFile.checkPointCopy.nextXid));
417 : :
993 bruce@momjian.us 418 [ + + ]: 53 : if (set_oldest_xid != 0)
419 : : {
420 : 5 : ControlFile.checkPointCopy.oldestXid = set_oldest_xid;
421 : 5 : ControlFile.checkPointCopy.oldestXidDB = InvalidOid;
422 : : }
423 : :
424 [ + + ]: 53 : if (set_xid != 0)
425 : : ControlFile.checkPointCopy.nextXid =
1342 andres@anarazel.de 426 : 5 : FullTransactionIdFromEpochAndXid(EpochFromFullTransactionId(ControlFile.checkPointCopy.nextXid),
427 : : set_xid);
428 : :
3030 mail@joeconway.com 429 [ + + ]: 53 : if (set_oldest_commit_ts_xid != 0)
430 : 5 : ControlFile.checkPointCopy.oldestCommitTsXid = set_oldest_commit_ts_xid;
431 [ + + ]: 53 : if (set_newest_commit_ts_xid != 0)
432 : 3 : ControlFile.checkPointCopy.newestCommitTsXid = set_newest_commit_ts_xid;
433 : :
7865 tgl@sss.pgh.pa.us 434 [ + + ]: 53 : if (set_oid != 0)
435 : 5 : ControlFile.checkPointCopy.nextOid = set_oid;
436 : :
6926 437 [ + + ]: 53 : if (set_mxid != 0)
438 : : {
439 : 5 : ControlFile.checkPointCopy.nextMulti = set_mxid;
440 : :
4099 alvherre@alvh.no-ip. 441 : 5 : ControlFile.checkPointCopy.oldestMulti = set_oldestmxid;
442 [ - + ]: 5 : if (ControlFile.checkPointCopy.oldestMulti < FirstMultiXactId)
4099 alvherre@alvh.no-ip. 443 :UBC 0 : ControlFile.checkPointCopy.oldestMulti += FirstMultiXactId;
4099 alvherre@alvh.no-ip. 444 :CBC 5 : ControlFile.checkPointCopy.oldestMultiDB = InvalidOid;
445 : : }
446 : :
6885 tgl@sss.pgh.pa.us 447 [ + + ]: 53 : if (set_mxoff != -1)
448 : 5 : ControlFile.checkPointCopy.nextMultiOffset = set_mxoff;
449 : :
7055 450 [ - + ]: 53 : if (minXlogTli > ControlFile.checkPointCopy.ThisTimeLineID)
451 : : {
7055 tgl@sss.pgh.pa.us 452 :UBC 0 : ControlFile.checkPointCopy.ThisTimeLineID = minXlogTli;
4080 heikki.linnakangas@i 453 : 0 : ControlFile.checkPointCopy.PrevTimeLineID = minXlogTli;
454 : : }
455 : :
2212 peter_e@gmx.net 456 [ + + ]:CBC 53 : if (set_wal_segsize != 0)
2212 peter_e@gmx.net 457 :GBC 2 : ControlFile.xlog_seg_size = WalSegSz;
458 : :
4312 heikki.linnakangas@i 459 [ + + ]:CBC 53 : if (minXlogSegNo > newXlogSegNo)
460 : 3 : newXlogSegNo = minXlogSegNo;
461 : :
199 peter@eisentraut.org 462 [ + + ]:GNC 53 : if (noupdate)
463 : : {
199 peter@eisentraut.org 464 :CBC 24 : PrintNewControlValues();
199 peter@eisentraut.org 465 :GNC 24 : exit(0);
466 : : }
467 : :
468 : : /*
469 : : * If we had to guess anything, and -f was not given, just print the
470 : : * guessed values and exit.
471 : : */
472 [ + + + + ]: 29 : if (guessed && !force)
473 : : {
3776 heikki.linnakangas@i 474 : 1 : PrintNewControlValues();
199 peter@eisentraut.org 475 : 1 : pg_log_error("not proceeding because control file values were guessed");
476 : 1 : pg_log_error_hint("If these values seem acceptable, use -f to force reset.");
477 : 1 : exit(1);
478 : : }
479 : :
480 : : /*
481 : : * Don't reset from a dirty pg_control without -f, either.
482 : : */
6525 bruce@momjian.us 483 [ + + + + ]:CBC 28 : if (ControlFile.state != DB_SHUTDOWNED && !force)
484 : : {
199 peter@eisentraut.org 485 :GNC 1 : pg_log_error("database server was not shut down cleanly");
486 : 1 : pg_log_error_detail("Resetting the write-ahead log might cause data to be lost.");
487 : 1 : pg_log_error_hint("If you want to proceed anyway, use -f to force reset.");
7899 peter_e@gmx.net 488 :GBC 1 : exit(1);
489 : : }
490 : :
491 : : /*
492 : : * Else, do the dirty deed.
493 : : */
7899 peter_e@gmx.net 494 :CBC 27 : RewriteControlFile();
495 : 27 : KillExistingXLOG();
5460 tgl@sss.pgh.pa.us 496 : 27 : KillExistingArchiveStatus();
116 rhaas@postgresql.org 497 :GNC 27 : KillExistingWALSummaries();
7899 peter_e@gmx.net 498 :CBC 27 : WriteEmptyXLOG();
499 : :
2529 500 : 27 : printf(_("Write-ahead log reset\n"));
7899 501 : 27 : return 0;
502 : : }
503 : :
504 : :
505 : : /*
506 : : * Look at the version string stored in PG_VERSION and decide if this utility
507 : : * can be run safely or not.
508 : : *
509 : : * We don't want to inject pg_control and WAL files that are for a different
510 : : * major version; that can't do anything good. Note that we don't treat
511 : : * mismatching version info in pg_control as a reason to bail out, because
512 : : * recovering from a corrupted pg_control is one of the main reasons for this
513 : : * program to exist at all. However, PG_VERSION is unlikely to get corrupted,
514 : : * and if it were it would be easy to fix by hand. So let's make this check
515 : : * to prevent simple user errors.
516 : : */
517 : : static void
2512 tgl@sss.pgh.pa.us 518 : 54 : CheckDataVersion(void)
519 : : {
520 : 54 : const char *ver_file = "PG_VERSION";
521 : : FILE *ver_fd;
522 : : char rawline[64];
523 : :
524 [ - + ]: 54 : if ((ver_fd = fopen(ver_file, "r")) == NULL)
737 tgl@sss.pgh.pa.us 525 :UBC 0 : pg_fatal("could not open file \"%s\" for reading: %m",
526 : : ver_file);
527 : :
528 : : /* version number has to be the first line read */
2512 tgl@sss.pgh.pa.us 529 [ - + ]:CBC 54 : if (!fgets(rawline, sizeof(rawline), ver_fd))
530 : : {
2512 tgl@sss.pgh.pa.us 531 [ # # ]:UBC 0 : if (!ferror(ver_fd))
737 532 : 0 : pg_fatal("unexpected empty file \"%s\"", ver_file);
533 : : else
534 : 0 : pg_fatal("could not read file \"%s\": %m", ver_file);
535 : : }
536 : :
537 : : /* strip trailing newline and carriage return */
1710 michael@paquier.xyz 538 :CBC 54 : (void) pg_strip_crlf(rawline);
539 : :
2512 tgl@sss.pgh.pa.us 540 [ - + ]: 54 : if (strcmp(rawline, PG_MAJORVERSION) != 0)
541 : : {
1840 peter@eisentraut.org 542 :UBC 0 : pg_log_error("data directory is of wrong version");
737 tgl@sss.pgh.pa.us 543 : 0 : pg_log_error_detail("File \"%s\" contains \"%s\", which is not compatible with this program's version \"%s\".",
544 : : ver_file, rawline, PG_MAJORVERSION);
2512 545 : 0 : exit(1);
546 : : }
547 : :
2512 tgl@sss.pgh.pa.us 548 :CBC 54 : fclose(ver_fd);
549 : 54 : }
550 : :
551 : :
552 : : /*
553 : : * Try to read the existing pg_control file.
554 : : *
555 : : * This routine is also responsible for updating old pg_control versions
556 : : * to the current format. (Currently we don't do anything of the sort.)
557 : : */
558 : : static bool
1518 peter@eisentraut.org 559 : 53 : read_controlfile(void)
560 : : {
561 : : int fd;
562 : : int len;
563 : : char *buffer;
564 : : pg_crc32c crc;
565 : :
5681 magnus@hagander.net 566 [ - + ]: 53 : if ((fd = open(XLOG_CONTROL_FILE, O_RDONLY | PG_BINARY, 0)) < 0)
567 : : {
568 : : /*
569 : : * If pg_control is not there at all, or we can't read it, the odds
570 : : * are we've been handed a bad DataDir path, so give up. User can do
571 : : * "touch pg_control" to force us to proceed.
572 : : */
1840 peter@eisentraut.org 573 :UBC 0 : pg_log_error("could not open file \"%s\" for reading: %m",
574 : : XLOG_CONTROL_FILE);
7911 bruce@momjian.us 575 [ # # ]: 0 : if (errno == ENOENT)
737 tgl@sss.pgh.pa.us 576 : 0 : pg_log_error_hint("If you are sure the data directory path is correct, execute\n"
577 : : " touch %s\n"
578 : : "and try again.",
579 : : XLOG_CONTROL_FILE);
7911 bruce@momjian.us 580 : 0 : exit(1);
581 : : }
582 : :
583 : : /* Use malloc to ensure we have a maxaligned buffer */
2461 tgl@sss.pgh.pa.us 584 :CBC 53 : buffer = (char *) pg_malloc(PG_CONTROL_FILE_SIZE);
585 : :
586 : 53 : len = read(fd, buffer, PG_CONTROL_FILE_SIZE);
7911 bruce@momjian.us 587 [ - + ]: 53 : if (len < 0)
737 tgl@sss.pgh.pa.us 588 :UBC 0 : pg_fatal("could not read file \"%s\": %m", XLOG_CONTROL_FILE);
7911 bruce@momjian.us 589 :CBC 53 : close(fd);
590 : :
591 [ + - ]: 53 : if (len >= sizeof(ControlFileData) &&
2489 tgl@sss.pgh.pa.us 592 [ + + ]: 53 : ((ControlFileData *) buffer)->pg_control_version == PG_CONTROL_VERSION)
593 : : {
594 : : /* Check the CRC. */
3449 heikki.linnakangas@i 595 : 52 : INIT_CRC32C(crc);
596 : 52 : COMP_CRC32C(crc,
597 : : buffer,
598 : : offsetof(ControlFileData, crc));
599 : 52 : FIN_CRC32C(crc);
600 : :
2399 andres@anarazel.de 601 [ + + ]: 52 : if (!EQ_CRC32C(crc, ((ControlFileData *) buffer)->crc))
602 : : {
603 : : /* We will use the data but treat it as guessed. */
1840 peter@eisentraut.org 604 : 3 : pg_log_warning("pg_control exists but has invalid CRC; proceed with caution");
2399 andres@anarazel.de 605 : 3 : guessed = true;
606 : : }
607 : :
7911 bruce@momjian.us 608 : 52 : memcpy(&ControlFile, buffer, sizeof(ControlFile));
609 : :
610 : : /* return false if WAL segment size is not valid */
2212 peter_e@gmx.net 611 [ + + + - : 52 : if (!IsValidWalSegSize(ControlFile.xlog_seg_size))
+ - - + ]
612 : : {
1840 peter@eisentraut.org 613 : 3 : pg_log_warning(ngettext("pg_control specifies invalid WAL segment size (%d byte); proceed with caution",
614 : : "pg_control specifies invalid WAL segment size (%d bytes); proceed with caution",
615 : : ControlFile.xlog_seg_size),
616 : : ControlFile.xlog_seg_size);
2214 peter_e@gmx.net 617 : 3 : return false;
618 : : }
619 : :
7911 bruce@momjian.us 620 : 49 : return true;
621 : : }
622 : :
623 : : /* Looks like it's a mess. */
1840 peter@eisentraut.org 624 : 1 : pg_log_warning("pg_control exists but is broken or wrong version; ignoring it");
7911 bruce@momjian.us 625 : 1 : return false;
626 : : }
627 : :
628 : :
629 : : /*
630 : : * Guess at pg_control values when we can't read the old ones.
631 : : */
632 : : static void
6525 633 : 4 : GuessControlValues(void)
634 : : {
635 : : uint64 sysidentifier;
636 : : struct timeval tv;
637 : :
638 : : /*
639 : : * Set up a completely default set of pg_control values.
640 : : */
641 : 4 : guessed = true;
7911 642 : 4 : memset(&ControlFile, 0, sizeof(ControlFile));
643 : :
644 : 4 : ControlFile.pg_control_version = PG_CONTROL_VERSION;
645 : 4 : ControlFile.catalog_version_no = CATALOG_VERSION_NO;
646 : :
647 : : /*
648 : : * Create a new unique installation identifier, since we can no longer use
649 : : * any old XLOG records. See notes in xlog.c about the algorithm.
650 : : */
6525 651 : 4 : gettimeofday(&tv, NULL);
652 : 4 : sysidentifier = ((uint64) tv.tv_sec) << 32;
3610 tgl@sss.pgh.pa.us 653 : 4 : sysidentifier |= ((uint64) tv.tv_usec) << 12;
654 : 4 : sysidentifier |= getpid() & 0xFFF;
655 : :
6525 bruce@momjian.us 656 : 4 : ControlFile.system_identifier = sysidentifier;
657 : :
4312 heikki.linnakangas@i 658 : 4 : ControlFile.checkPointCopy.redo = SizeOfXLogLongPHD;
6525 bruce@momjian.us 659 : 4 : ControlFile.checkPointCopy.ThisTimeLineID = 1;
4080 heikki.linnakangas@i 660 : 4 : ControlFile.checkPointCopy.PrevTimeLineID = 1;
4463 simon@2ndQuadrant.co 661 : 4 : ControlFile.checkPointCopy.fullPageWrites = false;
662 : : ControlFile.checkPointCopy.nextXid =
1844 tmunro@postgresql.or 663 : 4 : FullTransactionIdFromEpochAndXid(0, FirstNormalTransactionId);
1004 tgl@sss.pgh.pa.us 664 : 4 : ControlFile.checkPointCopy.nextOid = FirstGenbkiObjectId;
6525 bruce@momjian.us 665 : 4 : ControlFile.checkPointCopy.nextMulti = FirstMultiXactId;
666 : 4 : ControlFile.checkPointCopy.nextMultiOffset = 0;
5340 tgl@sss.pgh.pa.us 667 : 4 : ControlFile.checkPointCopy.oldestXid = FirstNormalTransactionId;
668 : 4 : ControlFile.checkPointCopy.oldestXidDB = InvalidOid;
4099 alvherre@alvh.no-ip. 669 : 4 : ControlFile.checkPointCopy.oldestMulti = FirstMultiXactId;
670 : 4 : ControlFile.checkPointCopy.oldestMultiDB = InvalidOid;
5901 tgl@sss.pgh.pa.us 671 : 4 : ControlFile.checkPointCopy.time = (pg_time_t) time(NULL);
5100 672 : 4 : ControlFile.checkPointCopy.oldestActiveXid = InvalidTransactionId;
673 : :
6525 bruce@momjian.us 674 : 4 : ControlFile.state = DB_SHUTDOWNED;
5901 tgl@sss.pgh.pa.us 675 : 4 : ControlFile.time = (pg_time_t) time(NULL);
6525 bruce@momjian.us 676 : 4 : ControlFile.checkPoint = ControlFile.checkPointCopy.redo;
1631 michael@paquier.xyz 677 : 4 : ControlFile.unloggedLSN = FirstNormalUnloggedLSN;
678 : :
679 : : /* minRecoveryPoint, backupStartPoint and backupEndPoint can be left zero */
680 : :
5100 tgl@sss.pgh.pa.us 681 : 4 : ControlFile.wal_level = WAL_LEVEL_MINIMAL;
3767 fujii@postgresql.org 682 : 4 : ControlFile.wal_log_hints = false;
3420 alvherre@alvh.no-ip. 683 : 4 : ControlFile.track_commit_timestamp = false;
5100 tgl@sss.pgh.pa.us 684 : 4 : ControlFile.MaxConnections = 100;
1888 michael@paquier.xyz 685 : 4 : ControlFile.max_wal_senders = 10;
2687 rhaas@postgresql.org 686 : 4 : ControlFile.max_worker_processes = 8;
5100 tgl@sss.pgh.pa.us 687 : 4 : ControlFile.max_prepared_xacts = 0;
688 : 4 : ControlFile.max_locks_per_xact = 64;
689 : :
6768 690 : 4 : ControlFile.maxAlign = MAXIMUM_ALIGNOF;
691 : 4 : ControlFile.floatFormat = FLOATFORMAT_VALUE;
7911 bruce@momjian.us 692 : 4 : ControlFile.blcksz = BLCKSZ;
693 : 4 : ControlFile.relseg_size = RELSEG_SIZE;
2212 peter_e@gmx.net 694 : 4 : ControlFile.xlog_blcksz = XLOG_BLCKSZ;
695 : 4 : ControlFile.xlog_seg_size = DEFAULT_XLOG_SEG_SIZE;
7865 tgl@sss.pgh.pa.us 696 : 4 : ControlFile.nameDataLen = NAMEDATALEN;
6956 697 : 4 : ControlFile.indexMaxKeys = INDEX_MAX_KEYS;
6221 698 : 4 : ControlFile.toast_max_chunk_size = TOAST_MAX_CHUNK_SIZE;
3601 699 : 4 : ControlFile.loblksize = LOBLKSIZE;
5837 700 : 4 : ControlFile.float8ByVal = FLOAT8PASSBYVAL;
701 : :
702 : : /*
703 : : * XXX eventually, should try to grovel through old XLOG to develop more
704 : : * accurate values for TimeLineID, nextXID, etc.
705 : : */
7911 bruce@momjian.us 706 : 4 : }
707 : :
708 : :
709 : : /*
710 : : * Print the guessed pg_control values when we had to guess.
711 : : *
712 : : * NB: this display should be just those fields that will not be
713 : : * reset by RewriteControlFile().
714 : : */
715 : : static void
6525 716 : 25 : PrintControlValues(bool guessed)
717 : : {
718 [ + + ]: 25 : if (guessed)
719 : 3 : printf(_("Guessed pg_control values:\n\n"));
720 : : else
3776 heikki.linnakangas@i 721 : 22 : printf(_("Current pg_control values:\n\n"));
722 : :
6446 tgl@sss.pgh.pa.us 723 : 25 : printf(_("pg_control version number: %u\n"),
724 : : ControlFile.pg_control_version);
725 : 25 : printf(_("Catalog version number: %u\n"),
726 : : ControlFile.catalog_version_no);
1774 peter@eisentraut.org 727 : 25 : printf(_("Database system identifier: %llu\n"),
728 : : (unsigned long long) ControlFile.system_identifier);
6446 tgl@sss.pgh.pa.us 729 : 25 : printf(_("Latest checkpoint's TimeLineID: %u\n"),
730 : : ControlFile.checkPointCopy.ThisTimeLineID);
4329 peter_e@gmx.net 731 [ + + ]: 25 : printf(_("Latest checkpoint's full_page_writes: %s\n"),
732 : : ControlFile.checkPointCopy.fullPageWrites ? _("on") : _("off"));
2984 mail@joeconway.com 733 : 25 : printf(_("Latest checkpoint's NextXID: %u:%u\n"),
734 : : EpochFromFullTransactionId(ControlFile.checkPointCopy.nextXid),
735 : : XidFromFullTransactionId(ControlFile.checkPointCopy.nextXid));
6446 tgl@sss.pgh.pa.us 736 : 25 : printf(_("Latest checkpoint's NextOID: %u\n"),
737 : : ControlFile.checkPointCopy.nextOid);
738 : 25 : printf(_("Latest checkpoint's NextMultiXactId: %u\n"),
739 : : ControlFile.checkPointCopy.nextMulti);
740 : 25 : printf(_("Latest checkpoint's NextMultiOffset: %u\n"),
741 : : ControlFile.checkPointCopy.nextMultiOffset);
5340 742 : 25 : printf(_("Latest checkpoint's oldestXID: %u\n"),
743 : : ControlFile.checkPointCopy.oldestXid);
744 : 25 : printf(_("Latest checkpoint's oldestXID's DB: %u\n"),
745 : : ControlFile.checkPointCopy.oldestXidDB);
5100 746 : 25 : printf(_("Latest checkpoint's oldestActiveXID: %u\n"),
747 : : ControlFile.checkPointCopy.oldestActiveXid);
4099 alvherre@alvh.no-ip. 748 : 25 : printf(_("Latest checkpoint's oldestMultiXid: %u\n"),
749 : : ControlFile.checkPointCopy.oldestMulti);
750 : 25 : printf(_("Latest checkpoint's oldestMulti's DB: %u\n"),
751 : : ControlFile.checkPointCopy.oldestMultiDB);
3030 mail@joeconway.com 752 : 25 : printf(_("Latest checkpoint's oldestCommitTsXid:%u\n"),
753 : : ControlFile.checkPointCopy.oldestCommitTsXid);
754 : 25 : printf(_("Latest checkpoint's newestCommitTsXid:%u\n"),
755 : : ControlFile.checkPointCopy.newestCommitTsXid);
6446 tgl@sss.pgh.pa.us 756 : 25 : printf(_("Maximum data alignment: %u\n"),
757 : : ControlFile.maxAlign);
758 : : /* we don't print floatFormat since can't say much useful about it */
759 : 25 : printf(_("Database block size: %u\n"),
760 : : ControlFile.blcksz);
761 : 25 : printf(_("Blocks per segment of large relation: %u\n"),
762 : : ControlFile.relseg_size);
763 : 25 : printf(_("WAL block size: %u\n"),
764 : : ControlFile.xlog_blcksz);
765 : 25 : printf(_("Bytes per WAL segment: %u\n"),
766 : : ControlFile.xlog_seg_size);
767 : 25 : printf(_("Maximum length of identifiers: %u\n"),
768 : : ControlFile.nameDataLen);
769 : 25 : printf(_("Maximum columns in an index: %u\n"),
770 : : ControlFile.indexMaxKeys);
6221 771 : 25 : printf(_("Maximum size of a TOAST chunk: %u\n"),
772 : : ControlFile.toast_max_chunk_size);
3601 773 : 25 : printf(_("Size of a large-object chunk: %u\n"),
774 : : ControlFile.loblksize);
775 : : /* This is no longer configurable, but users may still expect to see it: */
7865 776 : 25 : printf(_("Date/time type storage: %s\n"),
777 : : _("64-bit integers"));
5837 778 [ + - ]: 25 : printf(_("Float8 argument passing: %s\n"),
779 : : (ControlFile.float8ByVal ? _("by value") : _("by reference")));
4002 simon@2ndQuadrant.co 780 : 25 : printf(_("Data page checksum version: %u\n"),
781 : : ControlFile.data_checksum_version);
7911 bruce@momjian.us 782 : 25 : }
783 : :
784 : :
785 : : /*
786 : : * Print the values to be changed.
787 : : */
788 : : static void
3165 andres@anarazel.de 789 : 25 : PrintNewControlValues(void)
790 : : {
791 : : char fname[MAXFNAMELEN];
792 : :
793 : : /* This will be always printed in order to keep format same. */
3776 heikki.linnakangas@i 794 : 25 : printf(_("\n\nValues to be changed:\n\n"));
795 : :
2399 andres@anarazel.de 796 : 25 : XLogFileName(fname, ControlFile.checkPointCopy.ThisTimeLineID,
797 : : newXlogSegNo, WalSegSz);
577 tgl@sss.pgh.pa.us 798 : 25 : printf(_("First log segment after reset: %s\n"), fname);
799 : :
3776 heikki.linnakangas@i 800 [ + + ]: 25 : if (set_mxid != 0)
801 : : {
3776 heikki.linnakangas@i 802 :GBC 1 : printf(_("NextMultiXactId: %u\n"),
803 : : ControlFile.checkPointCopy.nextMulti);
804 : 1 : printf(_("OldestMultiXid: %u\n"),
805 : : ControlFile.checkPointCopy.oldestMulti);
806 : 1 : printf(_("OldestMulti's DB: %u\n"),
807 : : ControlFile.checkPointCopy.oldestMultiDB);
808 : : }
809 : :
3776 heikki.linnakangas@i 810 [ + + ]:CBC 25 : if (set_mxoff != -1)
811 : : {
3776 heikki.linnakangas@i 812 :GBC 1 : printf(_("NextMultiOffset: %u\n"),
813 : : ControlFile.checkPointCopy.nextMultiOffset);
814 : : }
815 : :
3776 heikki.linnakangas@i 816 [ + + ]:CBC 25 : if (set_oid != 0)
817 : : {
3776 heikki.linnakangas@i 818 :GBC 1 : printf(_("NextOID: %u\n"),
819 : : ControlFile.checkPointCopy.nextOid);
820 : : }
821 : :
3776 heikki.linnakangas@i 822 [ + + ]:CBC 25 : if (set_xid != 0)
823 : : {
3776 heikki.linnakangas@i 824 :GBC 1 : printf(_("NextXID: %u\n"),
825 : : XidFromFullTransactionId(ControlFile.checkPointCopy.nextXid));
826 : 1 : printf(_("OldestXID: %u\n"),
827 : : ControlFile.checkPointCopy.oldestXid);
828 : 1 : printf(_("OldestXID's DB: %u\n"),
829 : : ControlFile.checkPointCopy.oldestXidDB);
830 : : }
831 : :
3776 heikki.linnakangas@i 832 [ + + ]:CBC 25 : if (set_xid_epoch != -1)
833 : : {
3536 peter_e@gmx.net 834 :GBC 1 : printf(_("NextXID epoch: %u\n"),
835 : : EpochFromFullTransactionId(ControlFile.checkPointCopy.nextXid));
836 : : }
837 : :
3030 mail@joeconway.com 838 [ + + ]:CBC 25 : if (set_oldest_commit_ts_xid != 0)
839 : : {
3030 mail@joeconway.com 840 :GBC 1 : printf(_("oldestCommitTsXid: %u\n"),
841 : : ControlFile.checkPointCopy.oldestCommitTsXid);
842 : : }
3030 mail@joeconway.com 843 [ - + ]:CBC 25 : if (set_newest_commit_ts_xid != 0)
844 : : {
3030 mail@joeconway.com 845 :UBC 0 : printf(_("newestCommitTsXid: %u\n"),
846 : : ControlFile.checkPointCopy.newestCommitTsXid);
847 : : }
848 : :
2212 peter_e@gmx.net 849 [ + + ]:CBC 25 : if (set_wal_segsize != 0)
850 : : {
2212 peter_e@gmx.net 851 :GBC 1 : printf(_("Bytes per WAL segment: %u\n"),
852 : : ControlFile.xlog_seg_size);
853 : : }
3776 heikki.linnakangas@i 854 :CBC 25 : }
855 : :
856 : :
857 : : /*
858 : : * Write out the new pg_control file.
859 : : */
860 : : static void
6525 bruce@momjian.us 861 : 27 : RewriteControlFile(void)
862 : : {
863 : : /*
864 : : * Adjust fields as needed to force an empty XLOG starting at
865 : : * newXlogSegNo.
866 : : */
2106 alvherre@alvh.no-ip. 867 : 27 : XLogSegNoOffsetToRecPtr(newXlogSegNo, SizeOfXLogLongPHD, WalSegSz,
868 : : ControlFile.checkPointCopy.redo);
5901 tgl@sss.pgh.pa.us 869 : 27 : ControlFile.checkPointCopy.time = (pg_time_t) time(NULL);
870 : :
7911 bruce@momjian.us 871 : 27 : ControlFile.state = DB_SHUTDOWNED;
872 : 27 : ControlFile.checkPoint = ControlFile.checkPointCopy.redo;
4312 heikki.linnakangas@i 873 : 27 : ControlFile.minRecoveryPoint = 0;
4149 874 : 27 : ControlFile.minRecoveryPointTLI = 0;
4312 875 : 27 : ControlFile.backupStartPoint = 0;
876 : 27 : ControlFile.backupEndPoint = 0;
4624 877 : 27 : ControlFile.backupEndRequired = false;
878 : :
879 : : /*
880 : : * Force the defaults for max_* settings. The values don't really matter
881 : : * as long as wal_level='minimal'; the postmaster will reset these fields
882 : : * anyway at startup.
883 : : */
5100 tgl@sss.pgh.pa.us 884 : 27 : ControlFile.wal_level = WAL_LEVEL_MINIMAL;
3767 fujii@postgresql.org 885 : 27 : ControlFile.wal_log_hints = false;
3420 alvherre@alvh.no-ip. 886 : 27 : ControlFile.track_commit_timestamp = false;
5100 heikki.linnakangas@i 887 : 27 : ControlFile.MaxConnections = 100;
1888 michael@paquier.xyz 888 : 27 : ControlFile.max_wal_senders = 10;
2687 rhaas@postgresql.org 889 : 27 : ControlFile.max_worker_processes = 8;
5100 heikki.linnakangas@i 890 : 27 : ControlFile.max_prepared_xacts = 0;
891 : 27 : ControlFile.max_locks_per_xact = 64;
892 : :
893 : : /* The control file gets flushed here. */
1840 peter@eisentraut.org 894 : 27 : update_controlfile(".", &ControlFile, true);
7911 bruce@momjian.us 895 : 27 : }
896 : :
897 : :
898 : : /*
899 : : * Scan existing XLOG files and determine the highest existing WAL address
900 : : *
901 : : * On entry, ControlFile.checkPointCopy.redo and ControlFile.xlog_seg_size
902 : : * are assumed valid (note that we allow the old xlog seg size to differ
903 : : * from what we're using). On exit, newXlogSegNo is set to suitable
904 : : * value for the beginning of replacement WAL (in our seg size).
905 : : */
906 : : static void
6337 tgl@sss.pgh.pa.us 907 : 53 : FindEndOfXLOG(void)
908 : : {
909 : : DIR *xldir;
910 : : struct dirent *xlde;
911 : : uint64 xlogbytepos;
912 : :
913 : : /*
914 : : * Initialize the max() computation using the last checkpoint address from
915 : : * old pg_control. Note that for the moment we are working with segment
916 : : * numbering according to the old xlog seg size.
917 : : */
557 michael@paquier.xyz 918 : 53 : XLByteToSeg(ControlFile.checkPointCopy.redo, newXlogSegNo,
919 : : ControlFile.xlog_seg_size);
920 : :
921 : : /*
922 : : * Scan the pg_wal directory to find existing WAL segment files. We assume
923 : : * any present have been used; in most scenarios this should be
924 : : * conservative, because of xlog.c's attempts to pre-create files.
925 : : */
6337 tgl@sss.pgh.pa.us 926 : 53 : xldir = opendir(XLOGDIR);
927 [ - + ]: 53 : if (xldir == NULL)
737 tgl@sss.pgh.pa.us 928 :UBC 0 : pg_fatal("could not open directory \"%s\": %m", XLOGDIR);
929 : :
3677 bruce@momjian.us 930 [ + + ]:CBC 519 : while (errno = 0, (xlde = readdir(xldir)) != NULL)
931 : : {
3208 fujii@postgresql.org 932 [ + + - + ]: 679 : if (IsXLogFileName(xlde->d_name) ||
933 : 213 : IsPartialXLogFileName(xlde->d_name))
934 : : {
935 : : TimeLineID tli;
936 : : XLogSegNo segno;
937 : :
938 : : /* Use the segment size from the control file */
557 michael@paquier.xyz 939 : 253 : XLogFromFileName(xlde->d_name, &tli, &segno,
940 : 253 : ControlFile.xlog_seg_size);
941 : :
942 : : /*
943 : : * Note: we take the max of all files found, regardless of their
944 : : * timelines. Another possibility would be to ignore files of
945 : : * timelines other than the target TLI, but this seems safer.
946 : : * Better too large a result than too small...
947 : : */
4312 heikki.linnakangas@i 948 [ + + ]: 253 : if (segno > newXlogSegNo)
949 : 86 : newXlogSegNo = segno;
950 : : }
951 : : }
952 : :
6337 tgl@sss.pgh.pa.us 953 [ - + ]: 53 : if (errno)
737 tgl@sss.pgh.pa.us 954 :UBC 0 : pg_fatal("could not read directory \"%s\": %m", XLOGDIR);
955 : :
3677 bruce@momjian.us 956 [ - + ]:CBC 53 : if (closedir(xldir))
737 tgl@sss.pgh.pa.us 957 :UBC 0 : pg_fatal("could not close directory \"%s\": %m", XLOGDIR);
958 : :
959 : : /*
960 : : * Finally, convert to new xlog seg size, and advance by one to ensure we
961 : : * are in virgin territory.
962 : : */
4312 heikki.linnakangas@i 963 :CBC 53 : xlogbytepos = newXlogSegNo * ControlFile.xlog_seg_size;
2212 peter_e@gmx.net 964 : 53 : newXlogSegNo = (xlogbytepos + ControlFile.xlog_seg_size - 1) / WalSegSz;
4312 heikki.linnakangas@i 965 : 53 : newXlogSegNo++;
6337 tgl@sss.pgh.pa.us 966 : 53 : }
967 : :
968 : :
969 : : /*
970 : : * Remove existing XLOG files
971 : : */
972 : : static void
7911 bruce@momjian.us 973 : 27 : KillExistingXLOG(void)
974 : : {
975 : : DIR *xldir;
976 : : struct dirent *xlde;
977 : : char path[MAXPGPATH + sizeof(XLOGDIR)];
978 : :
6859 tgl@sss.pgh.pa.us 979 : 27 : xldir = opendir(XLOGDIR);
7911 bruce@momjian.us 980 [ - + ]: 27 : if (xldir == NULL)
737 tgl@sss.pgh.pa.us 981 :UBC 0 : pg_fatal("could not open directory \"%s\": %m", XLOGDIR);
982 : :
3677 bruce@momjian.us 983 [ + + ]:CBC 219 : while (errno = 0, (xlde = readdir(xldir)) != NULL)
984 : : {
3208 fujii@postgresql.org 985 [ + + - + ]: 301 : if (IsXLogFileName(xlde->d_name) ||
986 : 109 : IsPartialXLogFileName(xlde->d_name))
987 : : {
2560 peter_e@gmx.net 988 : 83 : snprintf(path, sizeof(path), "%s/%s", XLOGDIR, xlde->d_name);
7911 bruce@momjian.us 989 [ - + ]: 83 : if (unlink(path) < 0)
737 tgl@sss.pgh.pa.us 990 :UBC 0 : pg_fatal("could not delete file \"%s\": %m", path);
991 : : }
992 : : }
993 : :
7911 bruce@momjian.us 994 [ - + ]:CBC 27 : if (errno)
737 tgl@sss.pgh.pa.us 995 :UBC 0 : pg_fatal("could not read directory \"%s\": %m", XLOGDIR);
996 : :
3677 bruce@momjian.us 997 [ - + ]:CBC 27 : if (closedir(xldir))
737 tgl@sss.pgh.pa.us 998 :UBC 0 : pg_fatal("could not close directory \"%s\": %m", XLOGDIR);
7911 bruce@momjian.us 999 :CBC 27 : }
1000 : :
1001 : :
1002 : : /*
1003 : : * Remove existing archive status files
1004 : : */
1005 : : static void
5460 tgl@sss.pgh.pa.us 1006 : 27 : KillExistingArchiveStatus(void)
1007 : : {
1008 : : #define ARCHSTATDIR XLOGDIR "/archive_status"
1009 : :
1010 : : DIR *xldir;
1011 : : struct dirent *xlde;
1012 : : char path[MAXPGPATH + sizeof(ARCHSTATDIR)];
1013 : :
1014 : 27 : xldir = opendir(ARCHSTATDIR);
1015 [ - + ]: 27 : if (xldir == NULL)
737 tgl@sss.pgh.pa.us 1016 :UBC 0 : pg_fatal("could not open directory \"%s\": %m", ARCHSTATDIR);
1017 : :
3677 bruce@momjian.us 1018 [ + + ]:CBC 81 : while (errno = 0, (xlde = readdir(xldir)) != NULL)
1019 : : {
3209 fujii@postgresql.org 1020 [ - + ]: 54 : if (strspn(xlde->d_name, "0123456789ABCDEF") == XLOG_FNAME_LEN &&
3209 fujii@postgresql.org 1021 [ # # ]:UBC 0 : (strcmp(xlde->d_name + XLOG_FNAME_LEN, ".ready") == 0 ||
3208 1022 [ # # ]: 0 : strcmp(xlde->d_name + XLOG_FNAME_LEN, ".done") == 0 ||
1023 [ # # ]: 0 : strcmp(xlde->d_name + XLOG_FNAME_LEN, ".partial.ready") == 0 ||
1024 [ # # ]: 0 : strcmp(xlde->d_name + XLOG_FNAME_LEN, ".partial.done") == 0))
1025 : : {
2560 peter_e@gmx.net 1026 : 0 : snprintf(path, sizeof(path), "%s/%s", ARCHSTATDIR, xlde->d_name);
5460 tgl@sss.pgh.pa.us 1027 [ # # ]: 0 : if (unlink(path) < 0)
737 1028 : 0 : pg_fatal("could not delete file \"%s\": %m", path);
1029 : : }
1030 : : }
1031 : :
5460 tgl@sss.pgh.pa.us 1032 [ - + ]:CBC 27 : if (errno)
737 tgl@sss.pgh.pa.us 1033 :UBC 0 : pg_fatal("could not read directory \"%s\": %m", ARCHSTATDIR);
1034 : :
3677 bruce@momjian.us 1035 [ - + ]:CBC 27 : if (closedir(xldir))
737 tgl@sss.pgh.pa.us 1036 :UBC 0 : pg_fatal("could not close directory \"%s\": %m", ARCHSTATDIR);
5460 tgl@sss.pgh.pa.us 1037 :CBC 27 : }
1038 : :
1039 : : /*
1040 : : * Remove existing WAL summary files
1041 : : */
1042 : : static void
116 rhaas@postgresql.org 1043 :GNC 27 : KillExistingWALSummaries(void)
1044 : : {
1045 : : #define WALSUMMARYDIR XLOGDIR "/summaries"
1046 : : #define WALSUMMARY_NHEXCHARS 40
1047 : :
1048 : : DIR *xldir;
1049 : : struct dirent *xlde;
1050 : : char path[MAXPGPATH + sizeof(WALSUMMARYDIR)];
1051 : :
1052 : 27 : xldir = opendir(WALSUMMARYDIR);
1053 [ - + ]: 27 : if (xldir == NULL)
116 rhaas@postgresql.org 1054 :UNC 0 : pg_fatal("could not open directory \"%s\": %m", WALSUMMARYDIR);
1055 : :
116 rhaas@postgresql.org 1056 [ + + ]:GNC 81 : while (errno = 0, (xlde = readdir(xldir)) != NULL)
1057 : : {
1058 [ - + ]: 54 : if (strspn(xlde->d_name, "0123456789ABCDEF") == WALSUMMARY_NHEXCHARS &&
116 rhaas@postgresql.org 1059 [ # # ]:UNC 0 : strcmp(xlde->d_name + WALSUMMARY_NHEXCHARS, ".summary") == 0)
1060 : : {
1061 : 0 : snprintf(path, sizeof(path), "%s/%s", WALSUMMARYDIR, xlde->d_name);
1062 [ # # ]: 0 : if (unlink(path) < 0)
1063 : 0 : pg_fatal("could not delete file \"%s\": %m", path);
1064 : : }
1065 : : }
1066 : :
116 rhaas@postgresql.org 1067 [ - + ]:GNC 27 : if (errno)
116 rhaas@postgresql.org 1068 :UNC 0 : pg_fatal("could not read directory \"%s\": %m", WALSUMMARYDIR);
1069 : :
116 rhaas@postgresql.org 1070 [ - + ]:GNC 27 : if (closedir(xldir))
116 rhaas@postgresql.org 1071 :UNC 0 : pg_fatal("could not close directory \"%s\": %m", ARCHSTATDIR);
116 rhaas@postgresql.org 1072 :GNC 27 : }
1073 : :
1074 : : /*
1075 : : * Write an empty XLOG file, containing only the checkpoint record
1076 : : * already set up in ControlFile.
1077 : : */
1078 : : static void
7911 bruce@momjian.us 1079 :CBC 27 : WriteEmptyXLOG(void)
1080 : : {
1081 : : PGAlignedXLogBlock buffer;
1082 : : XLogPageHeader page;
1083 : : XLogLongPageHeader longpage;
1084 : : XLogRecord *record;
1085 : : pg_crc32c crc;
1086 : : char path[MAXPGPATH];
1087 : : int fd;
1088 : : int nbytes;
1089 : : char *recptr;
1090 : :
2052 tgl@sss.pgh.pa.us 1091 : 27 : memset(buffer.data, 0, XLOG_BLCKSZ);
1092 : :
1093 : : /* Set up the XLOG page header */
1094 : 27 : page = (XLogPageHeader) buffer.data;
7911 bruce@momjian.us 1095 : 27 : page->xlp_magic = XLOG_PAGE_MAGIC;
7207 tgl@sss.pgh.pa.us 1096 : 27 : page->xlp_info = XLP_LONG_HEADER;
1097 : 27 : page->xlp_tli = ControlFile.checkPointCopy.ThisTimeLineID;
4312 heikki.linnakangas@i 1098 : 27 : page->xlp_pageaddr = ControlFile.checkPointCopy.redo - SizeOfXLogLongPHD;
7207 tgl@sss.pgh.pa.us 1099 : 27 : longpage = (XLogLongPageHeader) page;
1100 : 27 : longpage->xlp_sysid = ControlFile.system_identifier;
2399 andres@anarazel.de 1101 : 27 : longpage->xlp_seg_size = WalSegSz;
6584 tgl@sss.pgh.pa.us 1102 : 27 : longpage->xlp_xlog_blcksz = XLOG_BLCKSZ;
1103 : :
1104 : : /* Insert the initial checkpoint record */
3433 heikki.linnakangas@i 1105 : 27 : recptr = (char *) page + SizeOfXLogLongPHD;
1106 : 27 : record = (XLogRecord *) recptr;
4312 1107 : 27 : record->xl_prev = 0;
7368 tgl@sss.pgh.pa.us 1108 : 27 : record->xl_xid = InvalidTransactionId;
3433 heikki.linnakangas@i 1109 : 27 : record->xl_tot_len = SizeOfXLogRecord + SizeOfXLogRecordDataHeaderShort + sizeof(CheckPoint);
7911 bruce@momjian.us 1110 : 27 : record->xl_info = XLOG_CHECKPOINT_SHUTDOWN;
1111 : 27 : record->xl_rmid = RM_XLOG_ID;
1112 : :
3433 heikki.linnakangas@i 1113 : 27 : recptr += SizeOfXLogRecord;
2574 tgl@sss.pgh.pa.us 1114 : 27 : *(recptr++) = (char) XLR_BLOCK_ID_DATA_SHORT;
3433 heikki.linnakangas@i 1115 : 27 : *(recptr++) = sizeof(CheckPoint);
1116 : 27 : memcpy(recptr, &ControlFile.checkPointCopy,
1117 : : sizeof(CheckPoint));
1118 : :
3449 1119 : 27 : INIT_CRC32C(crc);
3433 1120 : 27 : COMP_CRC32C(crc, ((char *) record) + SizeOfXLogRecord, record->xl_tot_len - SizeOfXLogRecord);
3449 1121 : 27 : COMP_CRC32C(crc, (char *) record, offsetof(XLogRecord, xl_crc));
1122 : 27 : FIN_CRC32C(crc);
7911 bruce@momjian.us 1123 : 27 : record->xl_crc = crc;
1124 : :
1125 : : /* Write the first page */
2399 andres@anarazel.de 1126 : 27 : XLogFilePath(path, ControlFile.checkPointCopy.ThisTimeLineID,
1127 : : newXlogSegNo, WalSegSz);
1128 : :
7911 bruce@momjian.us 1129 : 27 : unlink(path);
1130 : :
1131 : 27 : fd = open(path, O_RDWR | O_CREAT | O_EXCL | PG_BINARY,
1132 : : pg_file_create_mode);
1133 [ - + ]: 27 : if (fd < 0)
737 tgl@sss.pgh.pa.us 1134 :UBC 0 : pg_fatal("could not open file \"%s\": %m", path);
1135 : :
7911 bruce@momjian.us 1136 :CBC 27 : errno = 0;
2052 tgl@sss.pgh.pa.us 1137 [ - + ]: 27 : if (write(fd, buffer.data, XLOG_BLCKSZ) != XLOG_BLCKSZ)
1138 : : {
1139 : : /* if write didn't set errno, assume problem is no disk space */
7911 bruce@momjian.us 1140 [ # # ]:UBC 0 : if (errno == 0)
1141 : 0 : errno = ENOSPC;
737 tgl@sss.pgh.pa.us 1142 : 0 : pg_fatal("could not write file \"%s\": %m", path);
1143 : : }
1144 : :
1145 : : /* Fill the rest of the file with zeroes */
2052 tgl@sss.pgh.pa.us 1146 :CBC 27 : memset(buffer.data, 0, XLOG_BLCKSZ);
2399 andres@anarazel.de 1147 [ + + ]: 39936 : for (nbytes = XLOG_BLCKSZ; nbytes < WalSegSz; nbytes += XLOG_BLCKSZ)
1148 : : {
7911 bruce@momjian.us 1149 : 39909 : errno = 0;
2052 tgl@sss.pgh.pa.us 1150 [ - + ]: 39909 : if (write(fd, buffer.data, XLOG_BLCKSZ) != XLOG_BLCKSZ)
1151 : : {
7911 bruce@momjian.us 1152 [ # # ]:UBC 0 : if (errno == 0)
1153 : 0 : errno = ENOSPC;
737 tgl@sss.pgh.pa.us 1154 : 0 : pg_fatal("could not write file \"%s\": %m", path);
1155 : : }
1156 : : }
1157 : :
7911 bruce@momjian.us 1158 [ - + ]:CBC 27 : if (fsync(fd) != 0)
737 tgl@sss.pgh.pa.us 1159 :UBC 0 : pg_fatal("fsync error: %m");
1160 : :
7911 bruce@momjian.us 1161 :CBC 27 : close(fd);
1162 : 27 : }
1163 : :
1164 : :
1165 : : static void
1166 : 1 : usage(void)
1167 : : {
2529 peter_e@gmx.net 1168 : 1 : printf(_("%s resets the PostgreSQL write-ahead log.\n\n"), progname);
199 peter@eisentraut.org 1169 :GNC 1 : printf(_("Usage:\n"));
1170 : 1 : printf(_(" %s [OPTION]... DATADIR\n"), progname);
1171 : :
1172 : 1 : printf(_("\nOptions:\n"));
1173 : 1 : printf(_(" [-D, --pgdata=]DATADIR data directory\n"));
1174 : 1 : 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 : 1 : printf(_(" -n, --dry-run no update, just show what would be done\n"));
1177 : 1 : printf(_(" -V, --version output version information, then exit\n"));
1178 : 1 : printf(_(" -?, --help show this help, then exit\n"));
1179 : :
1180 : 1 : printf(_("\nOptions to override control file values:\n"));
2213 peter_e@gmx.net 1181 :CBC 1 : printf(_(" -c, --commit-timestamp-ids=XID,XID\n"
1182 : : " set oldest and newest transactions bearing\n"
1183 : : " commit timestamp (zero means no change)\n"));
993 bruce@momjian.us 1184 : 1 : printf(_(" -e, --epoch=XIDEPOCH set next transaction ID epoch\n"));
1185 : 1 : printf(_(" -l, --next-wal-file=WALFILE set minimum starting location for new WAL\n"));
1186 : 1 : printf(_(" -m, --multixact-ids=MXID,MXID set next and oldest multitransaction ID\n"));
1187 : 1 : printf(_(" -o, --next-oid=OID set next OID\n"));
1188 : 1 : printf(_(" -O, --multixact-offset=OFFSET set next multitransaction offset\n"));
1189 : 1 : printf(_(" -u, --oldest-transaction-id=XID set oldest transaction ID\n"));
1190 : 1 : printf(_(" -x, --next-transaction-id=XID set next transaction ID\n"));
1191 : 1 : printf(_(" --wal-segsize=SIZE size of WAL segments, in megabytes\n"));
1192 : :
1507 peter@eisentraut.org 1193 : 1 : printf(_("\nReport bugs to <%s>.\n"), PACKAGE_BUGREPORT);
1194 : 1 : printf(_("%s home page: <%s>\n"), PACKAGE_NAME, PACKAGE_URL);
7911 bruce@momjian.us 1195 : 1 : }
|
