diff options
| -rw-r--r-- | src/backend/replication/slot.c | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/backend/replication/slot.c b/src/backend/replication/slot.c index e4f5c6fb362..90ba9b417df 100644 --- a/src/backend/replication/slot.c +++ b/src/backend/replication/slot.c @@ -77,11 +77,11 @@ typedef struct ReplicationSlotOnDisk #define ReplicationSlotOnDiskConstantSize \ offsetof(ReplicationSlotOnDisk, slotdata) /* size of the part of the slot not covered by the checksum */ -#define SnapBuildOnDiskNotChecksummedSize \ +#define ReplicationSlotOnDiskNotChecksummedSize \ offsetof(ReplicationSlotOnDisk, version) /* size of the part covered by the checksum */ -#define SnapBuildOnDiskChecksummedSize \ - sizeof(ReplicationSlotOnDisk) - SnapBuildOnDiskNotChecksummedSize +#define ReplicationSlotOnDiskChecksummedSize \ + sizeof(ReplicationSlotOnDisk) - ReplicationSlotOnDiskNotChecksummedSize /* size of the slot data that is version dependent */ #define ReplicationSlotOnDiskV2Size \ sizeof(ReplicationSlotOnDisk) - ReplicationSlotOnDiskConstantSize @@ -1571,8 +1571,8 @@ SaveSlotToPath(ReplicationSlot *slot, const char *dir, int elevel) SpinLockRelease(&slot->mutex); COMP_CRC32C(cp.checksum, - (char *) (&cp) + SnapBuildOnDiskNotChecksummedSize, - SnapBuildOnDiskChecksummedSize); + (char *) (&cp) + ReplicationSlotOnDiskNotChecksummedSize, + ReplicationSlotOnDiskChecksummedSize); FIN_CRC32C(cp.checksum); errno = 0; @@ -1787,8 +1787,8 @@ RestoreSlotFromDisk(const char *name) /* now verify the CRC */ INIT_CRC32C(checksum); COMP_CRC32C(checksum, - (char *) &cp + SnapBuildOnDiskNotChecksummedSize, - SnapBuildOnDiskChecksummedSize); + (char *) &cp + ReplicationSlotOnDiskNotChecksummedSize, + ReplicationSlotOnDiskChecksummedSize); FIN_CRC32C(checksum); if (!EQ_CRC32C(checksum, cp.checksum)) |