Skip to content

Commit aeb9712

Browse files
tomasCommitfest Bot
authored andcommitted
Log checksum version during checkpoints etc.
log data_checksum_version, when: - reading/writing the control file - on every checkpoint - setting ControlFile->data_checksum_version
1 parent 1a80b7d commit aeb9712

File tree

1 file changed

+26
-4
lines changed
  • src/backend/access/transam

1 file changed

+26
-4
lines changed

src/backend/access/transam/xlog.c

Lines changed: 26 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -4447,6 +4447,9 @@ WriteControlFile(void)
44474447
(errcode_for_file_access(),
44484448
errmsg("could not close file \"%s\": %m",
44494449
XLOG_CONTROL_FILE)));
4450+
4451+
elog(LOG, "WriteControlFile ControlFile->data_checksum_version = %d ControlFile->checkPointCopy.data_checksum_version = %d",
4452+
ControlFile->data_checksum_version, ControlFile->checkPointCopy.data_checksum_version);
44504453
}
44514454

44524455
static void
@@ -4665,6 +4668,9 @@ ReadControlFile(void)
46654668
elog(LOG, "ReadControlFile checkpoint %X/%08X redo %X/%08X",
46664669
LSN_FORMAT_ARGS(ControlFile->checkPoint),
46674670
LSN_FORMAT_ARGS(ControlFile->checkPointCopy.redo));
4671+
4672+
elog(LOG, "ReadControlFile ControlFile->data_checksum_version = %d ControlFile->checkPointCopy.data_checksum_version = %d",
4673+
ControlFile->data_checksum_version, ControlFile->checkPointCopy.data_checksum_version);
46684674
}
46694675

46704676
/*
@@ -5569,6 +5575,9 @@ XLOGShmemInit(void)
55695575
/* Use the checksum info from control file */
55705576
XLogCtl->data_checksum_version = ControlFile->data_checksum_version;
55715577

5578+
elog(LOG, "XLOGShmemInit ControlFile->data_checksum_version = %d ControlFile->checkPointCopy.data_checksum_version = %d",
5579+
ControlFile->data_checksum_version, ControlFile->checkPointCopy.data_checksum_version);
5580+
55725581
SetLocalDataChecksumVersion(XLogCtl->data_checksum_version);
55735582

55745583
SpinLockInit(&XLogCtl->Insert.insertpos_lck);
@@ -7338,7 +7347,7 @@ LogCheckpointEnd(bool restartpoint)
73387347
"%d removed, %d recycled; write=%ld.%03d s, "
73397348
"sync=%ld.%03d s, total=%ld.%03d s; sync files=%d, "
73407349
"longest=%ld.%03d s, average=%ld.%03d s; distance=%d kB, "
7341-
"estimate=%d kB; lsn=%X/%08X, redo lsn=%X/%08X",
7350+
"estimate=%d kB; lsn=%X/%08X, redo lsn=%X/%08X, checksums=%d (%d)",
73427351
CheckpointStats.ckpt_bufs_written,
73437352
(double) CheckpointStats.ckpt_bufs_written * 100 / NBuffers,
73447353
CheckpointStats.ckpt_slru_written,
@@ -7354,15 +7363,17 @@ LogCheckpointEnd(bool restartpoint)
73547363
(int) (PrevCheckPointDistance / 1024.0),
73557364
(int) (CheckPointDistanceEstimate / 1024.0),
73567365
LSN_FORMAT_ARGS(ControlFile->checkPoint),
7357-
LSN_FORMAT_ARGS(ControlFile->checkPointCopy.redo))));
7366+
LSN_FORMAT_ARGS(ControlFile->checkPointCopy.redo),
7367+
ControlFile->data_checksum_version,
7368+
ControlFile->checkPointCopy.data_checksum_version)));
73587369
else
73597370
ereport(LOG,
73607371
(errmsg("checkpoint complete: wrote %d buffers (%.1f%%), "
73617372
"wrote %d SLRU buffers; %d WAL file(s) added, "
73627373
"%d removed, %d recycled; write=%ld.%03d s, "
73637374
"sync=%ld.%03d s, total=%ld.%03d s; sync files=%d, "
73647375
"longest=%ld.%03d s, average=%ld.%03d s; distance=%d kB, "
7365-
"estimate=%d kB; lsn=%X/%08X, redo lsn=%X/%08X",
7376+
"estimate=%d kB; lsn=%X/%08X, redo lsn=%X/%08X, checksums=%d (%d)",
73667377
CheckpointStats.ckpt_bufs_written,
73677378
(double) CheckpointStats.ckpt_bufs_written * 100 / NBuffers,
73687379
CheckpointStats.ckpt_slru_written,
@@ -7378,7 +7389,9 @@ LogCheckpointEnd(bool restartpoint)
73787389
(int) (PrevCheckPointDistance / 1024.0),
73797390
(int) (CheckPointDistanceEstimate / 1024.0),
73807391
LSN_FORMAT_ARGS(ControlFile->checkPoint),
7381-
LSN_FORMAT_ARGS(ControlFile->checkPointCopy.redo))));
7392+
LSN_FORMAT_ARGS(ControlFile->checkPointCopy.redo),
7393+
ControlFile->data_checksum_version,
7394+
ControlFile->checkPointCopy.data_checksum_version)));
73827395
}
73837396

73847397
/*
@@ -7872,6 +7885,9 @@ CreateCheckPoint(int flags)
78727885
/* make sure we start with the checksum version as of the checkpoint */
78737886
ControlFile->data_checksum_version = checkPoint.data_checksum_version;
78747887

7888+
elog(LOG, "CreateCheckPoint ControlFile->data_checksum_version = %d ControlFile->checkPointCopy.data_checksum_version = %d",
7889+
ControlFile->data_checksum_version, ControlFile->checkPointCopy.data_checksum_version);
7890+
78757891
/*
78767892
* Persist unloggedLSN value. It's reset on crash recovery, so this goes
78777893
* unused on non-shutdown checkpoints, but seems useful to store it always
@@ -8019,6 +8035,9 @@ CreateEndOfRecoveryRecord(void)
80198035
/* start with the latest checksum version (as of the end of recovery) */
80208036
ControlFile->data_checksum_version = XLogCtl->data_checksum_version;
80218037

8038+
elog(LOG, "CreateEndOfRecoveryRecord ControlFile->data_checksum_version = %d ControlFile->checkPointCopy.data_checksum_version = %d",
8039+
ControlFile->data_checksum_version, ControlFile->checkPointCopy.data_checksum_version);
8040+
80228041
UpdateControlFile();
80238042
LWLockRelease(ControlFileLock);
80248043

@@ -8364,6 +8383,9 @@ CreateRestartPoint(int flags)
83648383
/* we shall start with the latest checksum version */
83658384
ControlFile->data_checksum_version = lastCheckPoint.data_checksum_version;
83668385

8386+
elog(LOG, "CreateRestartPoint ControlFile->data_checksum_version = %d ControlFile->checkPointCopy.data_checksum_version = %d",
8387+
ControlFile->data_checksum_version, ControlFile->checkPointCopy.data_checksum_version);
8388+
83678389
UpdateControlFile();
83688390
}
83698391
LWLockRelease(ControlFileLock);

0 commit comments

Comments
 (0)