Age Owner Branch data TLA Line data Source code
1 : : /*-------------------------------------------------------------------------
2 : : *
3 : : * pg_waldump.c - decode and display WAL
4 : : *
5 : : * Copyright (c) 2013-2024, PostgreSQL Global Development Group
6 : : *
7 : : * IDENTIFICATION
8 : : * src/bin/pg_waldump/pg_waldump.c
9 : : *-------------------------------------------------------------------------
10 : : */
11 : :
12 : : #define FRONTEND 1
13 : : #include "postgres.h"
14 : :
15 : : #include <dirent.h>
16 : : #include <limits.h>
17 : : #include <signal.h>
18 : : #include <sys/stat.h>
19 : : #include <unistd.h>
20 : :
21 : : #include "access/transam.h"
22 : : #include "access/xlog_internal.h"
23 : : #include "access/xlogreader.h"
24 : : #include "access/xlogrecord.h"
25 : : #include "access/xlogstats.h"
26 : : #include "common/fe_memutils.h"
27 : : #include "common/file_perm.h"
28 : : #include "common/file_utils.h"
29 : : #include "common/logging.h"
30 : : #include "common/relpath.h"
31 : : #include "getopt_long.h"
32 : : #include "rmgrdesc.h"
33 : : #include "storage/bufpage.h"
34 : :
35 : : /*
36 : : * NOTE: For any code change or issue fix here, it is highly recommended to
37 : : * give a thought about doing the same in pg_walinspect contrib module as well.
38 : : */
39 : :
40 : : static const char *progname;
41 : :
42 : : static int WalSegSz;
43 : : static volatile sig_atomic_t time_to_stop = false;
44 : :
45 : : static const RelFileLocator emptyRelFileLocator = {0, 0, 0};
46 : :
47 : : typedef struct XLogDumpPrivate
48 : : {
49 : : TimeLineID timeline;
50 : : XLogRecPtr startptr;
51 : : XLogRecPtr endptr;
52 : : bool endptr_reached;
53 : : } XLogDumpPrivate;
54 : :
55 : : typedef struct XLogDumpConfig
56 : : {
57 : : /* display options */
58 : : bool quiet;
59 : : bool bkp_details;
60 : : int stop_after_records;
61 : : int already_displayed_records;
62 : : bool follow;
63 : : bool stats;
64 : : bool stats_per_record;
65 : :
66 : : /* filter options */
67 : : bool filter_by_rmgr[RM_MAX_ID + 1];
68 : : bool filter_by_rmgr_enabled;
69 : : TransactionId filter_by_xid;
70 : : bool filter_by_xid_enabled;
71 : : RelFileLocator filter_by_relation;
72 : : bool filter_by_extended;
73 : : bool filter_by_relation_enabled;
74 : : BlockNumber filter_by_relation_block;
75 : : bool filter_by_relation_block_enabled;
76 : : ForkNumber filter_by_relation_forknum;
77 : : bool filter_by_fpw;
78 : :
79 : : /* save options */
80 : : char *save_fullpage_path;
81 : : } XLogDumpConfig;
82 : :
83 : :
84 : : /*
85 : : * When sigint is called, just tell the system to exit at the next possible
86 : : * moment.
87 : : */
88 : : #ifndef WIN32
89 : :
90 : : static void
578 tgl@sss.pgh.pa.us 91 :UBC 0 : sigint_handler(SIGNAL_ARGS)
92 : : {
864 michael@paquier.xyz 93 : 0 : time_to_stop = true;
94 : 0 : }
95 : : #endif
96 : :
97 : : static void
4069 alvherre@alvh.no-ip. 98 :GBC 1 : print_rmgr_list(void)
99 : : {
100 : : int i;
101 : :
739 jdavis@postgresql.or 102 [ + + ]: 23 : for (i = 0; i <= RM_MAX_BUILTIN_ID; i++)
103 : : {
104 : 22 : printf("%s\n", GetRmgrDesc(i)->rm_name);
105 : : }
4069 alvherre@alvh.no-ip. 106 : 1 : }
107 : :
108 : : /*
109 : : * Check whether directory exists and whether we can open it. Keep errno set so
110 : : * that the caller can report errors somewhat more accurately.
111 : : */
112 : : static bool
4069 alvherre@alvh.no-ip. 113 :CBC 70 : verify_directory(const char *directory)
114 : : {
3973 bruce@momjian.us 115 : 70 : DIR *dir = opendir(directory);
116 : :
4069 alvherre@alvh.no-ip. 117 [ + + ]: 70 : if (dir == NULL)
118 : 1 : return false;
119 : 69 : closedir(dir);
120 : 69 : return true;
121 : : }
122 : :
123 : : /*
124 : : * Create if necessary the directory storing the full-page images extracted
125 : : * from the WAL records read.
126 : : */
127 : : static void
474 michael@paquier.xyz 128 : 1 : create_fullpage_directory(char *path)
129 : : {
130 : : int ret;
131 : :
132 [ + - - - ]: 1 : switch ((ret = pg_check_dir(path)))
133 : : {
134 : 1 : case 0:
135 : : /* Does not exist, so create it */
136 [ - + ]: 1 : if (pg_mkdir_p(path, pg_dir_create_mode) < 0)
474 michael@paquier.xyz 137 :UBC 0 : pg_fatal("could not create directory \"%s\": %m", path);
474 michael@paquier.xyz 138 :CBC 1 : break;
474 michael@paquier.xyz 139 :UBC 0 : case 1:
140 : : /* Present and empty, so do nothing */
141 : 0 : break;
142 : 0 : case 2:
143 : : case 3:
144 : : case 4:
145 : : /* Exists and not empty */
146 : 0 : pg_fatal("directory \"%s\" exists but is not empty", path);
147 : : break;
148 : 0 : default:
149 : : /* Trouble accessing directory */
150 : 0 : pg_fatal("could not access directory \"%s\": %m", path);
151 : : }
474 michael@paquier.xyz 152 :CBC 1 : }
153 : :
154 : : /*
155 : : * Split a pathname as dirname(1) and basename(1) would.
156 : : *
157 : : * XXX this probably doesn't do very well on Windows. We probably need to
158 : : * apply canonicalize_path(), at the very least.
159 : : */
160 : : static void
4069 alvherre@alvh.no-ip. 161 : 9 : split_path(const char *path, char **dir, char **fname)
162 : : {
163 : : char *sep;
164 : :
165 : : /* split filepath into directory & filename */
166 : 9 : sep = strrchr(path, '/');
167 : :
168 : : /* directory path */
169 [ + + ]: 9 : if (sep != NULL)
170 : : {
1593 171 : 7 : *dir = pnstrdup(path, sep - path);
4069 172 : 7 : *fname = pg_strdup(sep + 1);
173 : : }
174 : : /* local directory */
175 : : else
176 : : {
4069 alvherre@alvh.no-ip. 177 :GBC 2 : *dir = NULL;
178 : 2 : *fname = pg_strdup(path);
179 : : }
4069 alvherre@alvh.no-ip. 180 :CBC 9 : }
181 : :
182 : : /*
183 : : * Open the file in the valid target directory.
184 : : *
185 : : * return a read only fd
186 : : */
187 : : static int
2399 andres@anarazel.de 188 : 147 : open_file_in_directory(const char *directory, const char *fname)
189 : : {
4069 alvherre@alvh.no-ip. 190 : 147 : int fd = -1;
191 : : char fpath[MAXPGPATH];
192 : :
2399 andres@anarazel.de 193 [ - + ]: 147 : Assert(directory != NULL);
194 : :
195 : 147 : snprintf(fpath, MAXPGPATH, "%s/%s", directory, fname);
196 : 147 : fd = open(fpath, O_RDONLY | PG_BINARY, 0);
197 : :
198 [ + + - + ]: 147 : if (fd < 0 && errno != ENOENT)
737 tgl@sss.pgh.pa.us 199 :UBC 0 : pg_fatal("could not open file \"%s\": %m", fname);
2399 andres@anarazel.de 200 :CBC 147 : return fd;
201 : : }
202 : :
203 : : /*
204 : : * Try to find fname in the given directory. Returns true if it is found,
205 : : * false otherwise. If fname is NULL, search the complete directory for any
206 : : * file with a valid WAL file name. If file is successfully opened, set the
207 : : * wal segment size.
208 : : */
209 : : static bool
2357 peter_e@gmx.net 210 : 84 : search_directory(const char *directory, const char *fname)
211 : : {
2399 andres@anarazel.de 212 : 84 : int fd = -1;
213 : : DIR *xldir;
214 : :
215 : : /* open file if valid filename is provided */
216 [ + + ]: 84 : if (fname != NULL)
217 : 8 : fd = open_file_in_directory(directory, fname);
218 : :
219 : : /*
220 : : * A valid file name is not passed, so search the complete directory. If
221 : : * we find any file whose name is a valid WAL file name then try to open
222 : : * it. If we cannot open it, bail out.
223 : : */
224 [ + - ]: 76 : else if ((xldir = opendir(directory)) != NULL)
225 : : {
226 : : struct dirent *xlde;
227 : :
228 [ + + ]: 641 : while ((xlde = readdir(xldir)) != NULL)
229 : : {
230 [ + + ]: 628 : if (IsXLogFileName(xlde->d_name))
231 : : {
232 : 63 : fd = open_file_in_directory(directory, xlde->d_name);
753 233 : 63 : fname = pg_strdup(xlde->d_name);
2399 234 : 63 : break;
235 : : }
236 : : }
237 : :
238 : 76 : closedir(xldir);
239 : : }
240 : :
241 : : /* set WalSegSz if file is successfully opened */
242 [ + + ]: 84 : if (fd >= 0)
243 : : {
244 : : PGAlignedXLogBlock buf;
245 : : int r;
246 : :
2052 tgl@sss.pgh.pa.us 247 : 69 : r = read(fd, buf.data, XLOG_BLCKSZ);
2097 michael@paquier.xyz 248 [ + - ]: 69 : if (r == XLOG_BLCKSZ)
249 : : {
2052 tgl@sss.pgh.pa.us 250 : 69 : XLogLongPageHeader longhdr = (XLogLongPageHeader) buf.data;
251 : :
2399 andres@anarazel.de 252 : 69 : WalSegSz = longhdr->xlp_seg_size;
253 : :
254 [ + - + + : 69 : if (!IsValidWalSegSize(WalSegSz))
+ - - + ]
255 : : {
230 peter@eisentraut.org 256 :GNC 1 : pg_log_error(ngettext("invalid WAL segment size in WAL file \"%s\" (%d byte)",
257 : : "invalid WAL segment size in WAL file \"%s\" (%d bytes)",
258 : : WalSegSz),
259 : : fname, WalSegSz);
260 : 1 : pg_log_error_detail("The WAL segment size must be a power of two between 1 MB and 1 GB.");
261 : 1 : exit(1);
262 : : }
263 : : }
779 andres@anarazel.de 264 [ # # ]:UBC 0 : else if (r < 0)
737 tgl@sss.pgh.pa.us 265 : 0 : pg_fatal("could not read file \"%s\": %m",
266 : : fname);
267 : : else
268 : 0 : pg_fatal("could not read file \"%s\": read %d of %d",
269 : : fname, r, XLOG_BLCKSZ);
2399 andres@anarazel.de 270 :CBC 68 : close(fd);
271 : 68 : return true;
272 : : }
273 : :
2399 andres@anarazel.de 274 :GBC 15 : return false;
275 : : }
276 : :
277 : : /*
278 : : * Identify the target directory.
279 : : *
280 : : * Try to find the file in several places:
281 : : * if directory != NULL:
282 : : * directory /
283 : : * directory / XLOGDIR /
284 : : * else
285 : : * .
286 : : * XLOGDIR /
287 : : * $PGDATA / XLOGDIR /
288 : : *
289 : : * The valid target directory is returned.
290 : : */
291 : : static char *
1664 alvherre@alvh.no-ip. 292 :CBC 70 : identify_target_directory(char *directory, char *fname)
293 : : {
294 : : char fpath[MAXPGPATH];
295 : :
2399 andres@anarazel.de 296 [ + + ]: 70 : if (directory != NULL)
297 : : {
298 [ + + ]: 69 : if (search_directory(directory, fname))
1664 alvherre@alvh.no-ip. 299 : 55 : return pg_strdup(directory);
300 : :
301 : : /* directory / XLOGDIR */
2399 andres@anarazel.de 302 :GBC 13 : snprintf(fpath, MAXPGPATH, "%s/%s", directory, XLOGDIR);
303 [ + - ]: 13 : if (search_directory(fpath, fname))
1664 alvherre@alvh.no-ip. 304 : 13 : return pg_strdup(fpath);
305 : : }
306 : : else
307 : : {
308 : : const char *datadir;
309 : :
310 : : /* current directory */
2399 andres@anarazel.de 311 [ - + ]: 1 : if (search_directory(".", fname))
1664 alvherre@alvh.no-ip. 312 :UBC 0 : return pg_strdup(".");
313 : : /* XLOGDIR */
2399 andres@anarazel.de 314 [ - + ]:GBC 1 : if (search_directory(XLOGDIR, fname))
1664 alvherre@alvh.no-ip. 315 :UBC 0 : return pg_strdup(XLOGDIR);
316 : :
4069 alvherre@alvh.no-ip. 317 :GBC 1 : datadir = getenv("PGDATA");
318 : : /* $PGDATA / XLOGDIR */
319 [ - + ]: 1 : if (datadir != NULL)
320 : : {
2399 andres@anarazel.de 321 :UBC 0 : snprintf(fpath, MAXPGPATH, "%s/%s", datadir, XLOGDIR);
322 [ # # ]: 0 : if (search_directory(fpath, fname))
1664 alvherre@alvh.no-ip. 323 : 0 : return pg_strdup(fpath);
324 : : }
325 : : }
326 : :
327 : : /* could not locate WAL file */
2399 andres@anarazel.de 328 [ + - ]:GBC 1 : if (fname)
737 tgl@sss.pgh.pa.us 329 : 1 : pg_fatal("could not locate WAL file \"%s\"", fname);
330 : : else
737 tgl@sss.pgh.pa.us 331 :UBC 0 : pg_fatal("could not find any WAL file");
332 : :
333 : : return NULL; /* not reached */
334 : : }
335 : :
336 : : /* pg_waldump's XLogReaderRoutine->segment_open callback */
337 : : static void
1432 alvherre@alvh.no-ip. 338 :CBC 68 : WALDumpOpenSegment(XLogReaderState *state, XLogSegNo nextSegNo,
339 : : TimeLineID *tli_p)
340 : : {
1602 341 : 68 : TimeLineID tli = *tli_p;
342 : : char fname[MAXPGPATH];
343 : : int tries;
344 : :
1432 345 : 68 : XLogFileName(fname, tli, nextSegNo, state->segcxt.ws_segsize);
346 : :
347 : : /*
348 : : * In follow mode there is a short period of time after the server has
349 : : * written the end of the previous file before the new file is available.
350 : : * So we loop for 5 seconds looking for the file to appear before giving
351 : : * up.
352 : : */
1602 353 [ + - ]: 68 : for (tries = 0; tries < 10; tries++)
354 : : {
1432 355 : 68 : state->seg.ws_file = open_file_in_directory(state->segcxt.ws_dir, fname);
356 [ + - ]: 68 : if (state->seg.ws_file >= 0)
357 : 68 : return;
1602 alvherre@alvh.no-ip. 358 [ # # ]:UBC 0 : if (errno == ENOENT)
4069 359 : 0 : {
2097 michael@paquier.xyz 360 : 0 : int save_errno = errno;
361 : :
362 : : /* File not there yet, try again */
1602 alvherre@alvh.no-ip. 363 : 0 : pg_usleep(500 * 1000);
364 : :
365 : 0 : errno = save_errno;
366 : 0 : continue;
367 : : }
368 : : /* Any other error, fall through and fail */
369 : 0 : break;
370 : : }
371 : :
737 tgl@sss.pgh.pa.us 372 : 0 : pg_fatal("could not find file \"%s\": %m", fname);
373 : : }
374 : :
375 : : /*
376 : : * pg_waldump's XLogReaderRoutine->segment_close callback. Same as
377 : : * wal_segment_close
378 : : */
379 : : static void
1437 alvherre@alvh.no-ip. 380 :CBC 66 : WALDumpCloseSegment(XLogReaderState *state)
381 : : {
382 : 66 : close(state->seg.ws_file);
383 : : /* need to check errno? */
384 : 66 : state->seg.ws_file = -1;
385 : 66 : }
386 : :
387 : : /* pg_waldump's XLogReaderRoutine->page_read callback */
388 : : static int
1070 tmunro@postgresql.or 389 : 16781 : WALDumpReadPage(XLogReaderState *state, XLogRecPtr targetPagePtr, int reqLen,
390 : : XLogRecPtr targetPtr, char *readBuff)
391 : : {
392 : 16781 : XLogDumpPrivate *private = state->private_data;
4069 alvherre@alvh.no-ip. 393 : 16781 : int count = XLOG_BLCKSZ;
394 : : WALReadError errinfo;
395 : :
1070 tmunro@postgresql.or 396 [ + + ]: 16781 : if (private->endptr != InvalidXLogRecPtr)
397 : : {
398 [ + + ]: 14909 : if (targetPagePtr + XLOG_BLCKSZ <= private->endptr)
4069 alvherre@alvh.no-ip. 399 : 14788 : count = XLOG_BLCKSZ;
1070 tmunro@postgresql.or 400 [ + + ]: 121 : else if (targetPagePtr + reqLen <= private->endptr)
401 : 58 : count = private->endptr - targetPagePtr;
402 : : else
403 : : {
404 : 63 : private->endptr_reached = true;
405 : 63 : return -1;
406 : : }
407 : : }
408 : :
409 [ - + ]: 16718 : if (!WALRead(state, readBuff, targetPagePtr, count, private->timeline,
410 : : &errinfo))
411 : : {
1602 alvherre@alvh.no-ip. 412 :UBC 0 : WALOpenSegment *seg = &errinfo.wre_seg;
413 : : char fname[MAXPGPATH];
414 : :
415 : 0 : XLogFileName(fname, seg->ws_tli, seg->ws_segno,
416 : : state->segcxt.ws_segsize);
417 : :
418 [ # # ]: 0 : if (errinfo.wre_errno != 0)
419 : : {
420 : 0 : errno = errinfo.wre_errno;
213 dgustafsson@postgres 421 :UNC 0 : pg_fatal("could not read from file \"%s\", offset %d: %m",
422 : : fname, errinfo.wre_off);
423 : : }
424 : : else
425 : 0 : pg_fatal("could not read from file \"%s\", offset %d: read %d of %d",
426 : : fname, errinfo.wre_off, errinfo.wre_read,
427 : : errinfo.wre_req);
428 : : }
429 : :
1070 tmunro@postgresql.or 430 :CBC 16718 : return count;
431 : : }
432 : :
433 : : /*
434 : : * Boolean to return whether the given WAL record matches a specific relation
435 : : * and optionally block.
436 : : */
437 : : static bool
752 438 : 129392 : XLogRecordMatchesRelationBlock(XLogReaderState *record,
439 : : RelFileLocator matchRlocator,
440 : : BlockNumber matchBlock,
441 : : ForkNumber matchFork)
442 : : {
443 : : int block_id;
444 : :
445 [ + + ]: 272315 : for (block_id = 0; block_id <= XLogRecMaxBlockId(record); block_id++)
446 : : {
447 : : RelFileLocator rlocator;
448 : : ForkNumber forknum;
449 : : BlockNumber blk;
450 : :
734 tgl@sss.pgh.pa.us 451 [ + + ]: 143130 : if (!XLogRecGetBlockTagExtended(record, block_id,
452 : : &rlocator, &forknum, &blk, NULL))
752 tmunro@postgresql.or 453 : 40 : continue;
454 : :
455 [ + + + + ]: 143090 : if ((matchFork == InvalidForkNumber || matchFork == forknum) &&
648 rhaas@postgresql.org 456 [ + + + - : 103881 : (RelFileLocatorEquals(matchRlocator, emptyRelFileLocator) ||
- + ]
457 [ + + + - : 103881 : RelFileLocatorEquals(matchRlocator, rlocator)) &&
+ - + + ]
752 tmunro@postgresql.or 458 [ + + ]:GBC 4 : (matchBlock == InvalidBlockNumber || matchBlock == blk))
752 tmunro@postgresql.or 459 :CBC 207 : return true;
460 : : }
461 : :
462 : 129185 : return false;
463 : : }
464 : :
465 : : /*
466 : : * Boolean to return whether the given WAL record contains a full page write.
467 : : */
468 : : static bool
752 tmunro@postgresql.or 469 :GBC 34578 : XLogRecordHasFPW(XLogReaderState *record)
470 : : {
471 : : int block_id;
472 : :
473 [ + + ]: 72745 : for (block_id = 0; block_id <= XLogRecMaxBlockId(record); block_id++)
474 : : {
475 [ + - + + ]: 39194 : if (!XLogRecHasBlockRef(record, block_id))
476 : 7 : continue;
477 : :
478 [ + + ]: 39187 : if (XLogRecHasBlockImage(record, block_id))
479 : 1027 : return true;
480 : : }
481 : :
482 : 33551 : return false;
483 : : }
484 : :
485 : : /*
486 : : * Function to externally save all FPWs stored in the given WAL record.
487 : : * Decompression is applied to all the blocks saved, if necessary.
488 : : */
489 : : static void
474 michael@paquier.xyz 490 :CBC 200 : XLogRecordSaveFPWs(XLogReaderState *record, const char *savepath)
491 : : {
492 : : int block_id;
493 : :
494 [ + + ]: 400 : for (block_id = 0; block_id <= XLogRecMaxBlockId(record); block_id++)
495 : : {
496 : : PGAlignedBlock buf;
497 : : Page page;
498 : : char filename[MAXPGPATH];
499 : : char forkname[FORKNAMECHARS + 2]; /* _ + terminating zero */
500 : : FILE *file;
501 : : BlockNumber blk;
502 : : RelFileLocator rnode;
503 : : ForkNumber fork;
504 : :
505 [ + - - + ]: 200 : if (!XLogRecHasBlockRef(record, block_id))
474 michael@paquier.xyz 506 :UBC 0 : continue;
507 : :
474 michael@paquier.xyz 508 [ + + ]:CBC 200 : if (!XLogRecHasBlockImage(record, block_id))
509 : 199 : continue;
510 : :
511 : 1 : page = (Page) buf.data;
512 : :
513 : : /* Full page exists, so let's save it */
514 [ - + ]: 1 : if (!RestoreBlockImage(record, block_id, page))
474 michael@paquier.xyz 515 :UBC 0 : pg_fatal("%s", record->errormsg_buf);
516 : :
474 michael@paquier.xyz 517 :CBC 1 : (void) XLogRecGetBlockTagExtended(record, block_id,
518 : : &rnode, &fork, &blk, NULL);
519 : :
520 [ + - + - ]: 1 : if (fork >= 0 && fork <= MAX_FORKNUM)
521 : 1 : sprintf(forkname, "_%s", forkNames[fork]);
522 : : else
474 michael@paquier.xyz 523 :UBC 0 : pg_fatal("invalid fork number: %u", fork);
524 : :
291 michael@paquier.xyz 525 :CBC 1 : snprintf(filename, MAXPGPATH, "%s/%08X-%08X-%08X.%u.%u.%u.%u%s", savepath,
526 : : record->seg.ws_tli,
474 527 : 1 : LSN_FORMAT_ARGS(record->ReadRecPtr),
528 : : rnode.spcOid, rnode.dbOid, rnode.relNumber, blk, forkname);
529 : :
530 : 1 : file = fopen(filename, PG_BINARY_W);
531 [ - + ]: 1 : if (!file)
474 michael@paquier.xyz 532 :UBC 0 : pg_fatal("could not open file \"%s\": %m", filename);
533 : :
474 michael@paquier.xyz 534 [ - + ]:CBC 1 : if (fwrite(page, BLCKSZ, 1, file) != 1)
474 michael@paquier.xyz 535 :UBC 0 : pg_fatal("could not write file \"%s\": %m", filename);
536 : :
474 michael@paquier.xyz 537 [ - + ]:CBC 1 : if (fclose(file) != 0)
474 michael@paquier.xyz 538 :UBC 0 : pg_fatal("could not close file \"%s\": %m", filename);
539 : : }
474 michael@paquier.xyz 540 :CBC 200 : }
541 : :
542 : : /*
543 : : * Print a record to stdout
544 : : */
545 : : static void
3433 heikki.linnakangas@i 546 :GBC 260375 : XLogDumpDisplayRecord(XLogDumpConfig *config, XLogReaderState *record)
547 : : {
548 : : const char *id;
739 jdavis@postgresql.or 549 : 260375 : const RmgrDescData *desc = GetRmgrDesc(XLogRecGetRmid(record));
550 : : uint32 rec_len;
551 : : uint32 fpi_len;
3433 heikki.linnakangas@i 552 : 260375 : uint8 info = XLogRecGetInfo(record);
553 : 260375 : XLogRecPtr xl_prev = XLogRecGetPrev(record);
554 : : StringInfoData s;
555 : :
737 jdavis@postgresql.or 556 : 260375 : XLogRecGetLen(record, &rec_len, &fpi_len);
557 : :
3433 heikki.linnakangas@i 558 : 260375 : printf("rmgr: %-11s len (rec/tot): %6u/%6u, tx: %10u, lsn: %X/%08X, prev %X/%08X, ",
559 : : desc->rm_name,
560 : : rec_len, XLogRecGetTotalLen(record),
561 : : XLogRecGetXid(record),
562 : : LSN_FORMAT_ARGS(record->ReadRecPtr),
563 : : LSN_FORMAT_ARGS(xl_prev));
564 : :
1629 andres@anarazel.de 565 : 260375 : id = desc->rm_identify(info);
566 [ - + ]: 260375 : if (id == NULL)
1629 andres@anarazel.de 567 :UBC 0 : printf("desc: UNKNOWN (%x) ", info & ~XLR_INFO_MASK);
568 : : else
1629 andres@anarazel.de 569 :GBC 260375 : printf("desc: %s ", id);
570 : :
1622 571 : 260375 : initStringInfo(&s);
572 : 260375 : desc->rm_desc(&s, record);
573 : 260375 : printf("%s", s.data);
574 : :
737 jdavis@postgresql.or 575 : 260375 : resetStringInfo(&s);
576 : 260375 : XLogRecGetBlockRefInfo(record, true, config->bkp_details, &s, NULL);
577 : 260375 : printf("%s", s.data);
578 : 260375 : pfree(s.data);
4069 alvherre@alvh.no-ip. 579 : 260375 : }
580 : :
581 : : /*
582 : : * Display a single row of record counts and sizes for an rmgr or record.
583 : : */
584 : : static void
3495 andres@anarazel.de 585 : 79 : XLogDumpStatsRow(const char *name,
586 : : uint64 n, uint64 total_count,
587 : : uint64 rec_len, uint64 total_rec_len,
588 : : uint64 fpi_len, uint64 total_fpi_len,
589 : : uint64 tot_len, uint64 total_len)
590 : : {
591 : : double n_pct,
592 : : rec_len_pct,
593 : : fpi_len_pct,
594 : : tot_len_pct;
595 : :
3276 596 : 79 : n_pct = 0;
597 [ + - ]: 79 : if (total_count != 0)
598 : 79 : n_pct = 100 * (double) n / total_count;
599 : :
600 : 79 : rec_len_pct = 0;
601 [ + - ]: 79 : if (total_rec_len != 0)
602 : 79 : rec_len_pct = 100 * (double) rec_len / total_rec_len;
603 : :
604 : 79 : fpi_len_pct = 0;
605 [ + - ]: 79 : if (total_fpi_len != 0)
606 : 79 : fpi_len_pct = 100 * (double) fpi_len / total_fpi_len;
607 : :
608 : 79 : tot_len_pct = 0;
609 [ + - ]: 79 : if (total_len != 0)
610 : 79 : tot_len_pct = 100 * (double) tot_len / total_len;
611 : :
3495 612 : 79 : printf("%-27s "
613 : : "%20" INT64_MODIFIER "u (%6.02f) "
614 : : "%20" INT64_MODIFIER "u (%6.02f) "
615 : : "%20" INT64_MODIFIER "u (%6.02f) "
616 : : "%20" INT64_MODIFIER "u (%6.02f)\n",
617 : : name, n, n_pct, rec_len, rec_len_pct, fpi_len, fpi_len_pct,
618 : : tot_len, tot_len_pct);
619 : 79 : }
620 : :
621 : :
622 : : /*
623 : : * Display summary statistics about the records seen so far.
624 : : */
625 : : static void
737 jdavis@postgresql.or 626 : 2 : XLogDumpDisplayStats(XLogDumpConfig *config, XLogStats *stats)
627 : : {
628 : : int ri,
629 : : rj;
3495 andres@anarazel.de 630 : 2 : uint64 total_count = 0;
631 : 2 : uint64 total_rec_len = 0;
632 : 2 : uint64 total_fpi_len = 0;
633 : 2 : uint64 total_len = 0;
634 : : double rec_len_pct,
635 : : fpi_len_pct;
636 : :
637 : : /*
638 : : * Leave if no stats have been computed yet, as tracked by the end LSN.
639 : : */
864 michael@paquier.xyz 640 [ - + ]: 2 : if (XLogRecPtrIsInvalid(stats->endptr))
864 michael@paquier.xyz 641 :UBC 0 : return;
642 : :
643 : : /*
644 : : * Each row shows its percentages of the total, so make a first pass to
645 : : * calculate column totals.
646 : : */
647 : :
738 jdavis@postgresql.or 648 [ + + ]:GBC 514 : for (ri = 0; ri <= RM_MAX_ID; ri++)
649 : : {
737 650 [ + + + + ]: 512 : if (!RmgrIdIsValid(ri))
651 : 212 : continue;
652 : :
3495 andres@anarazel.de 653 : 300 : total_count += stats->rmgr_stats[ri].count;
654 : 300 : total_rec_len += stats->rmgr_stats[ri].rec_len;
655 : 300 : total_fpi_len += stats->rmgr_stats[ri].fpi_len;
656 : : }
3249 bruce@momjian.us 657 : 2 : total_len = total_rec_len + total_fpi_len;
658 : :
864 michael@paquier.xyz 659 : 2 : printf("WAL statistics between %X/%X and %X/%X:\n",
660 : : LSN_FORMAT_ARGS(stats->startptr), LSN_FORMAT_ARGS(stats->endptr));
661 : :
662 : : /*
663 : : * 27 is strlen("Transaction/COMMIT_PREPARED"), 20 is strlen(2^64), 8 is
664 : : * strlen("(100.00%)")
665 : : */
666 : :
3495 andres@anarazel.de 667 : 2 : printf("%-27s %20s %8s %20s %8s %20s %8s %20s %8s\n"
668 : : "%-27s %20s %8s %20s %8s %20s %8s %20s %8s\n",
669 : : "Type", "N", "(%)", "Record size", "(%)", "FPI size", "(%)", "Combined size", "(%)",
670 : : "----", "-", "---", "-----------", "---", "--------", "---", "-------------", "---");
671 : :
739 jdavis@postgresql.or 672 [ + + ]: 514 : for (ri = 0; ri <= RM_MAX_ID; ri++)
673 : : {
674 : : uint64 count,
675 : : rec_len,
676 : : fpi_len,
677 : : tot_len;
678 : : const RmgrDescData *desc;
679 : :
738 680 [ + + + + ]: 512 : if (!RmgrIdIsValid(ri))
739 681 : 212 : continue;
682 : :
683 : 300 : desc = GetRmgrDesc(ri);
684 : :
3495 andres@anarazel.de 685 [ + + ]: 300 : if (!config->stats_per_record)
686 : : {
687 : 150 : count = stats->rmgr_stats[ri].count;
688 : 150 : rec_len = stats->rmgr_stats[ri].rec_len;
689 : 150 : fpi_len = stats->rmgr_stats[ri].fpi_len;
690 : 150 : tot_len = rec_len + fpi_len;
691 : :
738 jdavis@postgresql.or 692 [ + + + - ]: 150 : if (RmgrIdIsCustom(ri) && count == 0)
739 693 : 128 : continue;
694 : :
3495 andres@anarazel.de 695 : 22 : XLogDumpStatsRow(desc->rm_name,
696 : : count, total_count, rec_len, total_rec_len,
697 : : fpi_len, total_fpi_len, tot_len, total_len);
698 : : }
699 : : else
700 : : {
701 [ + + ]: 2550 : for (rj = 0; rj < MAX_XLINFO_TYPES; rj++)
702 : : {
703 : : const char *id;
704 : :
705 : 2400 : count = stats->record_stats[ri][rj].count;
706 : 2400 : rec_len = stats->record_stats[ri][rj].rec_len;
707 : 2400 : fpi_len = stats->record_stats[ri][rj].fpi_len;
708 : 2400 : tot_len = rec_len + fpi_len;
709 : :
710 : : /* Skip undefined combinations and ones that didn't occur */
711 [ + + ]: 2400 : if (count == 0)
712 : 2343 : continue;
713 : :
714 : : /* the upper four bits in xl_info are the rmgr's */
715 : 57 : id = desc->rm_identify(rj << 4);
716 [ - + ]: 57 : if (id == NULL)
3495 andres@anarazel.de 717 :UBC 0 : id = psprintf("UNKNOWN (%x)", rj << 4);
718 : :
3495 andres@anarazel.de 719 :GBC 57 : XLogDumpStatsRow(psprintf("%s/%s", desc->rm_name, id),
720 : : count, total_count, rec_len, total_rec_len,
721 : : fpi_len, total_fpi_len, tot_len, total_len);
722 : : }
723 : : }
724 : : }
725 : :
726 : 2 : printf("%-27s %20s %8s %20s %8s %20s %8s %20s\n",
727 : : "", "--------", "", "--------", "", "--------", "", "--------");
728 : :
729 : : /*
730 : : * The percentages in earlier rows were calculated against the column
731 : : * total, but the ones that follow are against the row total. Note that
732 : : * these are displayed with a % symbol to differentiate them from the
733 : : * earlier ones, and are thus up to 9 characters long.
734 : : */
735 : :
3276 736 : 2 : rec_len_pct = 0;
737 [ + - ]: 2 : if (total_len != 0)
738 : 2 : rec_len_pct = 100 * (double) total_rec_len / total_len;
739 : :
740 : 2 : fpi_len_pct = 0;
741 [ + - ]: 2 : if (total_len != 0)
742 : 2 : fpi_len_pct = 100 * (double) total_fpi_len / total_len;
743 : :
3495 744 : 2 : printf("%-27s "
745 : : "%20" INT64_MODIFIER "u %-9s"
746 : : "%20" INT64_MODIFIER "u %-9s"
747 : : "%20" INT64_MODIFIER "u %-9s"
748 : : "%20" INT64_MODIFIER "u %-6s\n",
749 : : "Total", stats->count, "",
750 : : total_rec_len, psprintf("[%.02f%%]", rec_len_pct),
751 : : total_fpi_len, psprintf("[%.02f%%]", fpi_len_pct),
752 : : total_len, "[100%]");
753 : : }
754 : :
755 : : static void
4069 alvherre@alvh.no-ip. 756 :CBC 1 : usage(void)
757 : : {
2529 peter_e@gmx.net 758 : 1 : printf(_("%s decodes and displays PostgreSQL write-ahead logs for debugging.\n\n"),
759 : : progname);
2738 760 : 1 : printf(_("Usage:\n"));
2558 761 : 1 : printf(_(" %s [OPTION]... [STARTSEG [ENDSEG]]\n"), progname);
2738 762 : 1 : printf(_("\nOptions:\n"));
763 : 1 : printf(_(" -b, --bkp-details output detailed information about backup blocks\n"));
751 tmunro@postgresql.or 764 : 1 : printf(_(" -B, --block=N with --relation, only show records that modify block N\n"));
2529 peter_e@gmx.net 765 : 1 : printf(_(" -e, --end=RECPTR stop reading at WAL location RECPTR\n"));
2738 766 : 1 : printf(_(" -f, --follow keep retrying after reaching end of WAL\n"));
751 tmunro@postgresql.or 767 : 1 : printf(_(" -F, --fork=FORK only show records that modify blocks in fork FORK;\n"
768 : : " valid names are main, fsm, vm, init\n"));
2738 peter_e@gmx.net 769 : 1 : printf(_(" -n, --limit=N number of records to display\n"));
578 tgl@sss.pgh.pa.us 770 : 1 : printf(_(" -p, --path=PATH directory in which to find WAL segment files or a\n"
771 : : " directory with a ./pg_wal that contains such files\n"
772 : : " (default: current directory, ./pg_wal, $PGDATA/pg_wal)\n"));
1473 rhaas@postgresql.org 773 : 1 : printf(_(" -q, --quiet do not print any output, except for errors\n"));
2424 peter_e@gmx.net 774 : 1 : printf(_(" -r, --rmgr=RMGR only show records generated by resource manager RMGR;\n"
775 : : " use --rmgr=list to list valid resource manager names\n"));
751 tmunro@postgresql.or 776 : 1 : printf(_(" -R, --relation=T/D/R only show records that modify blocks in relation T/D/R\n"));
2529 peter_e@gmx.net 777 : 1 : printf(_(" -s, --start=RECPTR start reading at WAL location RECPTR\n"));
578 tgl@sss.pgh.pa.us 778 : 1 : printf(_(" -t, --timeline=TLI timeline from which to read WAL records\n"
779 : : " (default: 1 or the value used in STARTSEG)\n"));
2738 peter_e@gmx.net 780 : 1 : printf(_(" -V, --version output version information, then exit\n"));
752 tmunro@postgresql.or 781 : 1 : printf(_(" -w, --fullpage only show records with a full page write\n"));
751 782 : 1 : printf(_(" -x, --xid=XID only show records with transaction ID XID\n"));
2524 tgl@sss.pgh.pa.us 783 : 1 : printf(_(" -z, --stats[=record] show statistics instead of records\n"
784 : : " (optionally, show per-record statistics)\n"));
363 peter@eisentraut.org 785 : 1 : printf(_(" --save-fullpage=DIR save full page images to DIR\n"));
2738 peter_e@gmx.net 786 : 1 : printf(_(" -?, --help show this help, then exit\n"));
1507 peter@eisentraut.org 787 : 1 : printf(_("\nReport bugs to <%s>.\n"), PACKAGE_BUGREPORT);
788 : 1 : printf(_("%s home page: <%s>\n"), PACKAGE_NAME, PACKAGE_URL);
4069 alvherre@alvh.no-ip. 789 : 1 : }
790 : :
791 : : int
792 : 172 : main(int argc, char **argv)
793 : : {
794 : : uint32 xlogid;
795 : : uint32 xrecoff;
796 : : XLogReaderState *xlogreader_state;
797 : : XLogDumpPrivate private;
798 : : XLogDumpConfig config;
799 : : XLogStats stats;
800 : : XLogRecord *record;
801 : : XLogRecPtr first_record;
1664 802 : 172 : char *waldir = NULL;
803 : : char *errormsg;
804 : :
805 : : static struct option long_options[] = {
806 : : {"bkp-details", no_argument, NULL, 'b'},
807 : : {"block", required_argument, NULL, 'B'},
808 : : {"end", required_argument, NULL, 'e'},
809 : : {"follow", no_argument, NULL, 'f'},
810 : : {"fork", required_argument, NULL, 'F'},
811 : : {"fullpage", no_argument, NULL, 'w'},
812 : : {"help", no_argument, NULL, '?'},
813 : : {"limit", required_argument, NULL, 'n'},
814 : : {"path", required_argument, NULL, 'p'},
815 : : {"quiet", no_argument, NULL, 'q'},
816 : : {"relation", required_argument, NULL, 'R'},
817 : : {"rmgr", required_argument, NULL, 'r'},
818 : : {"start", required_argument, NULL, 's'},
819 : : {"timeline", required_argument, NULL, 't'},
820 : : {"xid", required_argument, NULL, 'x'},
821 : : {"version", no_argument, NULL, 'V'},
822 : : {"stats", optional_argument, NULL, 'z'},
823 : : {"save-fullpage", required_argument, NULL, 1},
824 : : {NULL, 0, NULL, 0}
825 : : };
826 : :
827 : : int option;
4069 828 : 172 : int optindex = 0;
829 : :
830 : : #ifndef WIN32
864 michael@paquier.xyz 831 : 172 : pqsignal(SIGINT, sigint_handler);
832 : : #endif
833 : :
1840 peter@eisentraut.org 834 : 172 : pg_logging_init(argv[0]);
2621 rhaas@postgresql.org 835 : 172 : set_pglocale_pgservice(argv[0], PG_TEXTDOMAIN("pg_waldump"));
4069 alvherre@alvh.no-ip. 836 : 172 : progname = get_progname(argv[0]);
837 : :
1775 peter@eisentraut.org 838 [ + + ]: 172 : if (argc > 1)
839 : : {
840 [ + + - + ]: 171 : if (strcmp(argv[1], "--help") == 0 || strcmp(argv[1], "-?") == 0)
841 : : {
842 : 1 : usage();
843 : 1 : exit(0);
844 : : }
845 [ + + + + ]: 170 : if (strcmp(argv[1], "--version") == 0 || strcmp(argv[1], "-V") == 0)
846 : : {
847 : 89 : puts("pg_waldump (PostgreSQL) " PG_VERSION);
848 : 89 : exit(0);
849 : : }
850 : : }
851 : :
1070 tmunro@postgresql.or 852 : 82 : memset(&private, 0, sizeof(XLogDumpPrivate));
4069 alvherre@alvh.no-ip. 853 : 82 : memset(&config, 0, sizeof(XLogDumpConfig));
737 jdavis@postgresql.or 854 : 82 : memset(&stats, 0, sizeof(XLogStats));
855 : :
1070 tmunro@postgresql.or 856 : 82 : private.timeline = 1;
857 : 82 : private.startptr = InvalidXLogRecPtr;
858 : 82 : private.endptr = InvalidXLogRecPtr;
859 : 82 : private.endptr_reached = false;
860 : :
1473 rhaas@postgresql.org 861 : 82 : config.quiet = false;
4069 alvherre@alvh.no-ip. 862 : 82 : config.bkp_details = false;
863 : 82 : config.stop_after_records = -1;
864 : 82 : config.already_displayed_records = 0;
3672 heikki.linnakangas@i 865 : 82 : config.follow = false;
866 : : /* filter_by_rmgr array was zeroed by memset above */
1018 867 : 82 : config.filter_by_rmgr_enabled = false;
4069 alvherre@alvh.no-ip. 868 : 82 : config.filter_by_xid = InvalidTransactionId;
869 : 82 : config.filter_by_xid_enabled = false;
752 tmunro@postgresql.or 870 : 82 : config.filter_by_extended = false;
871 : 82 : config.filter_by_relation_enabled = false;
872 : 82 : config.filter_by_relation_block_enabled = false;
873 : 82 : config.filter_by_relation_forknum = InvalidForkNumber;
874 : 82 : config.filter_by_fpw = false;
474 michael@paquier.xyz 875 : 82 : config.save_fullpage_path = NULL;
3495 andres@anarazel.de 876 : 82 : config.stats = false;
877 : 82 : config.stats_per_record = false;
878 : :
864 michael@paquier.xyz 879 : 82 : stats.startptr = InvalidXLogRecPtr;
880 : 82 : stats.endptr = InvalidXLogRecPtr;
881 : :
4069 alvherre@alvh.no-ip. 882 [ + + ]: 82 : if (argc <= 1)
883 : : {
1840 peter@eisentraut.org 884 :GBC 1 : pg_log_error("no arguments specified");
4069 alvherre@alvh.no-ip. 885 : 1 : goto bad_argument;
886 : : }
887 : :
751 tmunro@postgresql.or 888 :CBC 386 : while ((option = getopt_long(argc, argv, "bB:e:fF:n:p:qr:R:s:t:wx:z",
4069 alvherre@alvh.no-ip. 889 [ + + ]: 386 : long_options, &optindex)) != -1)
890 : : {
891 [ - + + - : 314 : switch (option)
+ + + + +
+ + + + -
+ + + ]
892 : : {
4069 alvherre@alvh.no-ip. 893 :UBC 0 : case 'b':
894 : 0 : config.bkp_details = true;
895 : 0 : break;
751 tmunro@postgresql.or 896 :GBC 2 : case 'B':
897 [ + + ]: 2 : if (sscanf(optarg, "%u", &config.filter_by_relation_block) != 1 ||
898 [ - + ]: 1 : !BlockNumberIsValid(config.filter_by_relation_block))
899 : : {
695 peter@eisentraut.org 900 : 1 : pg_log_error("invalid block number: \"%s\"", optarg);
751 tmunro@postgresql.or 901 : 1 : goto bad_argument;
902 : : }
903 : 1 : config.filter_by_relation_block_enabled = true;
904 : 1 : config.filter_by_extended = true;
905 : 1 : break;
4069 alvherre@alvh.no-ip. 906 :CBC 62 : case 'e':
907 [ + + ]: 62 : if (sscanf(optarg, "%X/%X", &xlogid, &xrecoff) != 2)
908 : : {
695 peter@eisentraut.org 909 :GBC 1 : pg_log_error("invalid WAL location: \"%s\"",
910 : : optarg);
4069 alvherre@alvh.no-ip. 911 : 1 : goto bad_argument;
912 : : }
1070 tmunro@postgresql.or 913 :CBC 61 : private.endptr = (uint64) xlogid << 32 | xrecoff;
4069 alvherre@alvh.no-ip. 914 : 61 : break;
3672 heikki.linnakangas@i 915 :UBC 0 : case 'f':
916 : 0 : config.follow = true;
917 : 0 : break;
752 tmunro@postgresql.or 918 :GBC 2 : case 'F':
751 919 : 2 : config.filter_by_relation_forknum = forkname_to_number(optarg);
920 [ + + ]: 2 : if (config.filter_by_relation_forknum == InvalidForkNumber)
921 : : {
695 peter@eisentraut.org 922 : 1 : pg_log_error("invalid fork name: \"%s\"", optarg);
752 tmunro@postgresql.or 923 : 1 : goto bad_argument;
924 : : }
925 : 1 : config.filter_by_extended = true;
926 : 1 : break;
4069 alvherre@alvh.no-ip. 927 : 2 : case 'n':
928 [ + + ]: 2 : if (sscanf(optarg, "%d", &config.stop_after_records) != 1)
929 : : {
695 peter@eisentraut.org 930 : 1 : pg_log_error("invalid value \"%s\" for option %s", optarg, "-n/--limit");
4069 alvherre@alvh.no-ip. 931 : 1 : goto bad_argument;
932 : : }
933 : 1 : break;
4069 alvherre@alvh.no-ip. 934 :CBC 64 : case 'p':
1664 935 : 64 : waldir = pg_strdup(optarg);
4069 936 : 64 : break;
1473 rhaas@postgresql.org 937 : 54 : case 'q':
938 : 54 : config.quiet = true;
939 : 54 : break;
4069 alvherre@alvh.no-ip. 940 :GBC 3 : case 'r':
941 : : {
942 : : int rmid;
943 : :
944 [ + + ]: 3 : if (pg_strcasecmp(optarg, "list") == 0)
945 : : {
946 : 1 : print_rmgr_list();
947 : 1 : exit(EXIT_SUCCESS);
948 : : }
949 : :
950 : : /*
951 : : * First look for the generated name of a custom rmgr, of
952 : : * the form "custom###". We accept this form, because the
953 : : * custom rmgr module is not loaded, so there's no way to
954 : : * know the real name. This convention should be
955 : : * consistent with that in rmgrdesc.c.
956 : : */
739 jdavis@postgresql.or 957 [ - + ]: 2 : if (sscanf(optarg, "custom%03d", &rmid) == 1)
958 : : {
738 jdavis@postgresql.or 959 [ # # ]:UBC 0 : if (!RmgrIdIsCustom(rmid))
960 : : {
739 961 : 0 : pg_log_error("custom resource manager \"%s\" does not exist",
962 : : optarg);
963 : 0 : goto bad_argument;
964 : : }
965 : 0 : config.filter_by_rmgr[rmid] = true;
966 : 0 : config.filter_by_rmgr_enabled = true;
967 : : }
968 : : else
969 : : {
970 : : /* then look for builtin rmgrs */
739 jdavis@postgresql.or 971 [ + + ]:GBC 35 : for (rmid = 0; rmid <= RM_MAX_BUILTIN_ID; rmid++)
972 : : {
973 [ + + ]: 34 : if (pg_strcasecmp(optarg, GetRmgrDesc(rmid)->rm_name) == 0)
974 : : {
975 : 1 : config.filter_by_rmgr[rmid] = true;
976 : 1 : config.filter_by_rmgr_enabled = true;
977 : 1 : break;
978 : : }
979 : : }
980 [ + + ]: 2 : if (rmid > RM_MAX_BUILTIN_ID)
981 : : {
982 : 1 : pg_log_error("resource manager \"%s\" does not exist",
983 : : optarg);
984 : 1 : goto bad_argument;
985 : : }
986 : : }
987 : : }
4069 alvherre@alvh.no-ip. 988 : 1 : break;
751 tmunro@postgresql.or 989 :CBC 4 : case 'R':
564 rhaas@postgresql.org 990 [ + + ]: 4 : if (sscanf(optarg, "%u/%u/%u",
991 : : &config.filter_by_relation.spcOid,
992 : : &config.filter_by_relation.dbOid,
648 993 : 3 : &config.filter_by_relation.relNumber) != 3 ||
994 [ + - ]: 3 : !OidIsValid(config.filter_by_relation.spcOid) ||
995 [ - + ]: 3 : !RelFileNumberIsValid(config.filter_by_relation.relNumber))
996 : : {
695 peter@eisentraut.org 997 :GBC 1 : pg_log_error("invalid relation specification: \"%s\"", optarg);
998 : 1 : pg_log_error_detail("Expecting \"tablespace OID/database OID/relation filenode\".");
751 tmunro@postgresql.or 999 : 1 : goto bad_argument;
1000 : : }
751 tmunro@postgresql.or 1001 :CBC 3 : config.filter_by_relation_enabled = true;
1002 : 3 : config.filter_by_extended = true;
1003 : 3 : break;
4069 alvherre@alvh.no-ip. 1004 : 65 : case 's':
1005 [ + + ]: 65 : if (sscanf(optarg, "%X/%X", &xlogid, &xrecoff) != 2)
1006 : : {
695 peter@eisentraut.org 1007 :GBC 1 : pg_log_error("invalid WAL location: \"%s\"",
1008 : : optarg);
4069 alvherre@alvh.no-ip. 1009 : 1 : goto bad_argument;
1010 : : }
1011 : : else
1070 tmunro@postgresql.or 1012 :CBC 64 : private.startptr = (uint64) xlogid << 32 | xrecoff;
4069 alvherre@alvh.no-ip. 1013 : 64 : break;
1014 : 51 : case 't':
1015 : :
1016 : : /*
1017 : : * This is like option_parse_int() but needs to handle
1018 : : * unsigned 32-bit int. Also, we accept both decimal and
1019 : : * hexadecimal specifications here.
1020 : : */
1021 : : {
1022 : : char *endptr;
1023 : : unsigned long val;
1024 : :
390 peter@eisentraut.org 1025 : 51 : errno = 0;
1026 : 51 : val = strtoul(optarg, &endptr, 0);
1027 : :
1028 [ - + - - ]: 51 : while (*endptr != '\0' && isspace((unsigned char) *endptr))
390 peter@eisentraut.org 1029 :UBC 0 : endptr++;
1030 : :
390 peter@eisentraut.org 1031 [ - + ]:CBC 51 : if (*endptr != '\0')
1032 : : {
390 peter@eisentraut.org 1033 :UBC 0 : pg_log_error("invalid value \"%s\" for option %s",
1034 : : optarg, "-t/--timeline");
1035 : 0 : goto bad_argument;
1036 : : }
1037 : :
390 peter@eisentraut.org 1038 [ + - + - :CBC 51 : if (errno == ERANGE || val < 1 || val > UINT_MAX)
- + ]
1039 : : {
390 peter@eisentraut.org 1040 :UBC 0 : pg_log_error("%s must be in range %u..%u",
1041 : : "-t/--timeline", 1, UINT_MAX);
1042 : 0 : goto bad_argument;
1043 : : }
1044 : :
390 peter@eisentraut.org 1045 :CBC 51 : private.timeline = val;
1046 : :
1047 : 51 : break;
1048 : : }
752 tmunro@postgresql.or 1049 :GBC 1 : case 'w':
1050 : 1 : config.filter_by_fpw = true;
1051 : 1 : break;
4069 alvherre@alvh.no-ip. 1052 :UBC 0 : case 'x':
1053 [ # # ]: 0 : if (sscanf(optarg, "%u", &config.filter_by_xid) != 1)
1054 : : {
695 peter@eisentraut.org 1055 : 0 : pg_log_error("invalid transaction ID specification: \"%s\"",
1056 : : optarg);
4069 alvherre@alvh.no-ip. 1057 : 0 : goto bad_argument;
1058 : : }
1059 : 0 : config.filter_by_xid_enabled = true;
1060 : 0 : break;
3495 andres@anarazel.de 1061 :GBC 2 : case 'z':
1062 : 2 : config.stats = true;
1063 : 2 : config.stats_per_record = false;
1064 [ + + ]: 2 : if (optarg)
1065 : : {
1066 [ + - ]: 1 : if (strcmp(optarg, "record") == 0)
1067 : 1 : config.stats_per_record = true;
3495 andres@anarazel.de 1068 [ # # ]:UBC 0 : else if (strcmp(optarg, "rmgr") != 0)
1069 : : {
695 peter@eisentraut.org 1070 : 0 : pg_log_error("unrecognized value for option %s: %s",
1071 : : "--stats", optarg);
3495 andres@anarazel.de 1072 : 0 : goto bad_argument;
1073 : : }
1074 : : }
3495 andres@anarazel.de 1075 :GBC 2 : break;
474 michael@paquier.xyz 1076 :CBC 1 : case 1:
1077 : 1 : config.save_fullpage_path = pg_strdup(optarg);
1078 : 1 : break;
4069 alvherre@alvh.no-ip. 1079 : 1 : default:
1080 : 1 : goto bad_argument;
1081 : : }
1082 : : }
1083 : :
752 tmunro@postgresql.or 1084 [ + + ]: 72 : if (config.filter_by_relation_block_enabled &&
752 tmunro@postgresql.or 1085 [ - + ]:GBC 1 : !config.filter_by_relation_enabled)
1086 : : {
695 peter@eisentraut.org 1087 :UBC 0 : pg_log_error("option %s requires option %s to be specified",
1088 : : "-B/--block", "-R/--relation");
752 tmunro@postgresql.or 1089 : 0 : goto bad_argument;
1090 : : }
1091 : :
4069 alvherre@alvh.no-ip. 1092 [ + + ]:CBC 72 : if ((optind + 2) < argc)
1093 : : {
1840 peter@eisentraut.org 1094 :GBC 1 : pg_log_error("too many command-line arguments (first is \"%s\")",
1095 : : argv[optind + 2]);
4069 alvherre@alvh.no-ip. 1096 : 1 : goto bad_argument;
1097 : : }
1098 : :
1664 alvherre@alvh.no-ip. 1099 [ + + ]:CBC 71 : if (waldir != NULL)
1100 : : {
1101 : : /* validate path points to directory */
1102 [ + + ]: 64 : if (!verify_directory(waldir))
1103 : : {
1573 michael@paquier.xyz 1104 : 1 : pg_log_error("could not open directory \"%s\": %m", waldir);
4069 alvherre@alvh.no-ip. 1105 : 1 : goto bad_argument;
1106 : : }
1107 : : }
1108 : :
474 michael@paquier.xyz 1109 [ + + ]: 70 : if (config.save_fullpage_path != NULL)
1110 : 1 : create_fullpage_directory(config.save_fullpage_path);
1111 : :
1112 : : /* parse files as start/end boundaries, extract path if not specified */
4069 alvherre@alvh.no-ip. 1113 [ + + ]: 70 : if (optind < argc)
1114 : : {
1115 : 7 : char *directory = NULL;
1116 : 7 : char *fname = NULL;
1117 : : int fd;
1118 : : XLogSegNo segno;
1119 : :
1120 : 7 : split_path(argv[optind], &directory, &fname);
1121 : :
1664 1122 [ + - + + ]: 7 : if (waldir == NULL && directory != NULL)
1123 : : {
1124 : 6 : waldir = directory;
1125 : :
1126 [ - + ]: 6 : if (!verify_directory(waldir))
737 tgl@sss.pgh.pa.us 1127 :UBC 0 : pg_fatal("could not open directory \"%s\": %m", waldir);
1128 : : }
1129 : :
1664 alvherre@alvh.no-ip. 1130 :CBC 7 : waldir = identify_target_directory(waldir, fname);
1131 : 6 : fd = open_file_in_directory(waldir, fname);
4069 1132 [ - + ]: 6 : if (fd < 0)
737 tgl@sss.pgh.pa.us 1133 :UBC 0 : pg_fatal("could not open file \"%s\"", fname);
4069 alvherre@alvh.no-ip. 1134 :CBC 6 : close(fd);
1135 : :
1136 : : /* parse position from file */
1070 tmunro@postgresql.or 1137 : 6 : XLogFromFileName(fname, &private.timeline, &segno, WalSegSz);
1138 : :
1139 [ + + ]: 6 : if (XLogRecPtrIsInvalid(private.startptr))
1140 : 5 : XLogSegNoOffsetToRecPtr(segno, 0, WalSegSz, private.startptr);
1070 tmunro@postgresql.or 1141 [ - + ]:GBC 1 : else if (!XLByteInSeg(private.startptr, segno, WalSegSz))
1142 : : {
1840 peter@eisentraut.org 1143 :UBC 0 : pg_log_error("start WAL location %X/%X is not inside file \"%s\"",
1144 : : LSN_FORMAT_ARGS(private.startptr),
1145 : : fname);
4069 alvherre@alvh.no-ip. 1146 : 0 : goto bad_argument;
1147 : : }
1148 : :
1149 : : /* no second file specified, set end position */
1070 tmunro@postgresql.or 1150 [ + + + - ]:CBC 6 : if (!(optind + 1 < argc) && XLogRecPtrIsInvalid(private.endptr))
1151 : 4 : XLogSegNoOffsetToRecPtr(segno + 1, 0, WalSegSz, private.endptr);
1152 : :
1153 : : /* parse ENDSEG if passed */
4069 alvherre@alvh.no-ip. 1154 [ + + ]: 6 : if (optind + 1 < argc)
1155 : : {
1156 : : XLogSegNo endsegno;
1157 : :
1158 : : /* ignore directory, already have that */
4069 alvherre@alvh.no-ip. 1159 :GBC 2 : split_path(argv[optind + 1], &directory, &fname);
1160 : :
1664 1161 : 2 : fd = open_file_in_directory(waldir, fname);
4069 1162 [ + + ]: 2 : if (fd < 0)
737 tgl@sss.pgh.pa.us 1163 : 1 : pg_fatal("could not open file \"%s\"", fname);
4069 alvherre@alvh.no-ip. 1164 : 1 : close(fd);
1165 : :
1166 : : /* parse position from file */
1070 tmunro@postgresql.or 1167 : 1 : XLogFromFileName(fname, &private.timeline, &endsegno, WalSegSz);
1168 : :
4069 alvherre@alvh.no-ip. 1169 [ - + ]: 1 : if (endsegno < segno)
737 tgl@sss.pgh.pa.us 1170 :UBC 0 : pg_fatal("ENDSEG %s is before STARTSEG %s",
1171 : : argv[optind + 1], argv[optind]);
1172 : :
1070 tmunro@postgresql.or 1173 [ + - ]:GBC 1 : if (XLogRecPtrIsInvalid(private.endptr))
2106 alvherre@alvh.no-ip. 1174 : 1 : XLogSegNoOffsetToRecPtr(endsegno + 1, 0, WalSegSz,
1175 : : private.endptr);
1176 : :
1177 : : /* set segno to endsegno for check of --end */
4069 1178 : 1 : segno = endsegno;
1179 : : }
1180 : :
1181 : :
1070 tmunro@postgresql.or 1182 [ + - ]:CBC 5 : if (!XLByteInSeg(private.endptr, segno, WalSegSz) &&
1183 [ - + ]: 5 : private.endptr != (segno + 1) * WalSegSz)
1184 : : {
1840 peter@eisentraut.org 1185 :UBC 0 : pg_log_error("end WAL location %X/%X is not inside file \"%s\"",
1186 : : LSN_FORMAT_ARGS(private.endptr),
1187 : : argv[argc - 1]);
4069 alvherre@alvh.no-ip. 1188 : 0 : goto bad_argument;
1189 : : }
1190 : : }
1191 : : else
1664 alvherre@alvh.no-ip. 1192 :CBC 63 : waldir = identify_target_directory(waldir, NULL);
1193 : :
1194 : : /* we don't know what to print */
1070 tmunro@postgresql.or 1195 [ + + ]: 67 : if (XLogRecPtrIsInvalid(private.startptr))
1196 : : {
1840 peter@eisentraut.org 1197 :GBC 1 : pg_log_error("no start WAL location given");
4069 alvherre@alvh.no-ip. 1198 : 1 : goto bad_argument;
1199 : : }
1200 : :
1201 : : /* done with argument parsing, do the actual work */
1202 : :
1203 : : /* we have everything we need, start reading */
1204 : : xlogreader_state =
1070 tmunro@postgresql.or 1205 :CBC 66 : XLogReaderAllocate(WalSegSz, waldir,
1206 : 66 : XL_ROUTINE(.page_read = WALDumpReadPage,
1207 : : .segment_open = WALDumpOpenSegment,
1208 : : .segment_close = WALDumpCloseSegment),
1209 : : &private);
4069 alvherre@alvh.no-ip. 1210 [ - + ]: 66 : if (!xlogreader_state)
737 tgl@sss.pgh.pa.us 1211 :UBC 0 : pg_fatal("out of memory while allocating a WAL reading processor");
1212 : :
1213 : : /* first find a valid recptr to start from */
1070 tmunro@postgresql.or 1214 :CBC 66 : first_record = XLogFindNextRecord(xlogreader_state, private.startptr);
1215 : :
4069 alvherre@alvh.no-ip. 1216 [ - + ]: 66 : if (first_record == InvalidXLogRecPtr)
737 tgl@sss.pgh.pa.us 1217 :UBC 0 : pg_fatal("could not find a valid record after %X/%X",
1218 : : LSN_FORMAT_ARGS(private.startptr));
1219 : :
1220 : : /*
1221 : : * Display a message that we're skipping data if `from` wasn't a pointer
1222 : : * to the start of a record and also wasn't a pointer to the beginning of
1223 : : * a segment (e.g. we were used in file mode).
1224 : : */
1070 tmunro@postgresql.or 1225 [ + + ]:CBC 66 : if (first_record != private.startptr &&
1226 [ + + ]: 5 : XLogSegmentOffset(private.startptr, WalSegSz) != 0)
284 peter@eisentraut.org 1227 :GNC 1 : pg_log_info(ngettext("first record is after %X/%X, at %X/%X, skipping over %u byte",
1228 : : "first record is after %X/%X, at %X/%X, skipping over %u bytes",
1229 : : (first_record - private.startptr)),
1230 : : LSN_FORMAT_ARGS(private.startptr),
1231 : : LSN_FORMAT_ARGS(first_record),
1232 : : (uint32) (first_record - private.startptr));
1233 : :
864 michael@paquier.xyz 1234 [ + + + - ]:CBC 66 : if (config.stats == true && !config.quiet)
864 michael@paquier.xyz 1235 :GBC 2 : stats.startptr = first_record;
1236 : :
1237 : : for (;;)
1238 : : {
864 michael@paquier.xyz 1239 [ - + ]:CBC 620844 : if (time_to_stop)
1240 : : {
1241 : : /* We've been Ctrl-C'ed, so leave */
864 michael@paquier.xyz 1242 :UBC 0 : break;
1243 : : }
1244 : :
1245 : : /* try to read the next record */
1070 tmunro@postgresql.or 1246 :CBC 620844 : record = XLogReadRecord(xlogreader_state, &errormsg);
3672 heikki.linnakangas@i 1247 [ + + ]: 620844 : if (!record)
1248 : : {
1070 tmunro@postgresql.or 1249 [ - + - - ]: 65 : if (!config.follow || private.endptr_reached)
1250 : : break;
1251 : : else
1252 : : {
3631 bruce@momjian.us 1253 :UBC 0 : pg_usleep(1000000L); /* 1 second */
3672 heikki.linnakangas@i 1254 : 0 : continue;
1255 : : }
1256 : : }
1257 : :
1258 : : /* apply all specified filters */
1018 heikki.linnakangas@i 1259 [ + + ]:CBC 620779 : if (config.filter_by_rmgr_enabled &&
1018 heikki.linnakangas@i 1260 [ + + ]:GBC 34578 : !config.filter_by_rmgr[record->xl_rmid])
3495 andres@anarazel.de 1261 : 33543 : continue;
1262 : :
3495 andres@anarazel.de 1263 [ - + ]:CBC 587236 : if (config.filter_by_xid_enabled &&
3495 andres@anarazel.de 1264 [ # # ]:UBC 0 : config.filter_by_xid != record->xl_xid)
1265 : 0 : continue;
1266 : :
1267 : : /* check for extended filtering */
752 tmunro@postgresql.or 1268 [ + + ]:CBC 587236 : if (config.filter_by_extended &&
1269 [ + + ]: 258784 : !XLogRecordMatchesRelationBlock(xlogreader_state,
1270 [ + + ]: 129392 : config.filter_by_relation_enabled ?
1271 : : config.filter_by_relation :
1272 : : emptyRelFileLocator,
1273 [ + + ]: 129392 : config.filter_by_relation_block_enabled ?
1274 : : config.filter_by_relation_block :
1275 : : InvalidBlockNumber,
1276 : : config.filter_by_relation_forknum))
1277 : 129185 : continue;
1278 : :
1279 [ + + + + ]: 458051 : if (config.filter_by_fpw && !XLogRecordHasFPW(xlogreader_state))
752 tmunro@postgresql.or 1280 :GBC 33551 : continue;
1281 : :
1282 : : /* perform any per-record work */
1473 rhaas@postgresql.org 1283 [ + + ]:CBC 424500 : if (!config.quiet)
1284 : : {
1473 rhaas@postgresql.org 1285 [ + + ]:GBC 329531 : if (config.stats == true)
1286 : : {
737 jdavis@postgresql.or 1287 : 69156 : XLogRecStoreStats(&stats, xlogreader_state);
864 michael@paquier.xyz 1288 : 69156 : stats.endptr = xlogreader_state->EndRecPtr;
1289 : : }
1290 : : else
1473 rhaas@postgresql.org 1291 : 260375 : XLogDumpDisplayRecord(&config, xlogreader_state);
1292 : : }
1293 : :
1294 : : /* save full pages if requested */
474 michael@paquier.xyz 1295 [ + + ]:CBC 424500 : if (config.save_fullpage_path != NULL)
1296 : 200 : XLogRecordSaveFPWs(xlogreader_state, config.save_fullpage_path);
1297 : :
1298 : : /* check whether we printed enough */
3495 andres@anarazel.de 1299 : 424500 : config.already_displayed_records++;
4069 alvherre@alvh.no-ip. 1300 [ + + ]: 424500 : if (config.stop_after_records > 0 &&
4069 alvherre@alvh.no-ip. 1301 [ + + ]:GBC 6 : config.already_displayed_records >= config.stop_after_records)
1302 : 1 : break;
1303 : : }
1304 : :
1472 rhaas@postgresql.org 1305 [ + + + - ]:CBC 66 : if (config.stats == true && !config.quiet)
3495 andres@anarazel.de 1306 :GBC 2 : XLogDumpDisplayStats(&config, &stats);
1307 : :
864 michael@paquier.xyz 1308 [ - + ]:CBC 66 : if (time_to_stop)
864 michael@paquier.xyz 1309 :UBC 0 : exit(0);
1310 : :
4069 alvherre@alvh.no-ip. 1311 [ + + ]:CBC 66 : if (errormsg)
737 tgl@sss.pgh.pa.us 1312 :GBC 2 : pg_fatal("error in WAL record at %X/%X: %s",
1313 : : LSN_FORMAT_ARGS(xlogreader_state->ReadRecPtr),
1314 : : errormsg);
1315 : :
4069 alvherre@alvh.no-ip. 1316 :CBC 64 : XLogReaderFree(xlogreader_state);
1317 : :
1318 : 64 : return EXIT_SUCCESS;
1319 : :
1320 : 12 : bad_argument:
737 tgl@sss.pgh.pa.us 1321 : 12 : pg_log_error_hint("Try \"%s --help\" for more information.", progname);
4069 alvherre@alvh.no-ip. 1322 : 12 : return EXIT_FAILURE;
1323 : : }
|
