diff --git a/src/backend/utils/time/snapmgr.c b/src/backend/utils/time/snapmgr.c index f232c84..a46a73e 100644 --- a/src/backend/utils/time/snapmgr.c +++ b/src/backend/utils/time/snapmgr.c @@ -2013,7 +2013,7 @@ EstimateSnapshotSpace(Snapshot snap) * memory location at start_address. */ void -SerializeSnapshot(Snapshot snapshot, char *start_address) +SerializeSnapshot(Snapshot snapshot, int64 *start_address) { SerializedSnapshotData *serialized_snapshot; @@ -2069,7 +2069,7 @@ SerializeSnapshot(Snapshot snapshot, char *start_address) * to 0. The returned snapshot has the copied flag set. */ Snapshot -RestoreSnapshot(char *start_address) +RestoreSnapshot(int64 *start_address) { SerializedSnapshotData *serialized_snapshot; Size size; diff --git a/src/include/access/relscan.h b/src/include/access/relscan.h index ce3ca8d..3a5c5c9 100644 --- a/src/include/access/relscan.h +++ b/src/include/access/relscan.h @@ -38,7 +38,7 @@ typedef struct ParallelHeapScanDescData slock_t phs_mutex; /* mutual exclusion for block number fields */ BlockNumber phs_startblock; /* starting block number */ BlockNumber phs_cblock; /* current block number */ - char phs_snapshot_data[FLEXIBLE_ARRAY_MEMBER]; + int64 phs_snapshot_data[FLEXIBLE_ARRAY_MEMBER]; } ParallelHeapScanDescData; typedef struct HeapScanDescData @@ -138,7 +138,7 @@ typedef struct ParallelIndexScanDescData Oid ps_relid; Oid ps_indexid; Size ps_offset; /* Offset in bytes of am specific structure */ - char ps_snapshot_data[FLEXIBLE_ARRAY_MEMBER]; + int64 ps_snapshot_data[FLEXIBLE_ARRAY_MEMBER]; } ParallelIndexScanDescData; /* Struct for heap-or-index scans of system tables */ diff --git a/src/include/utils/snapmgr.h b/src/include/utils/snapmgr.h index ab95366..4b5feb7 100644 --- a/src/include/utils/snapmgr.h +++ b/src/include/utils/snapmgr.h @@ -106,8 +106,8 @@ extern void TeardownHistoricSnapshot(bool is_error); extern bool HistoricSnapshotActive(void); extern Size EstimateSnapshotSpace(Snapshot snapshot); -extern void SerializeSnapshot(Snapshot snapshot, char *start_address); -extern Snapshot RestoreSnapshot(char *start_address); +extern void SerializeSnapshot(Snapshot snapshot, int64 *start_address); +extern Snapshot RestoreSnapshot(int64 *start_address); extern void RestoreTransactionSnapshot(Snapshot snapshot, void *master_pgproc); #endif /* SNAPMGR_H */