lsn mapper

wader · Jul 20, 2022 · 8d317dd · 8d317dd
1 parent 2b1bdfb
commit 8d317dd
Show file tree

Hide file tree

Showing 4 changed files with 16 additions and 6 deletions.
diff --git a/format/postgres/common/common.go b/format/postgres/common/common.go
@@ -50,3 +50,13 @@ func (m icuVersionMapper) MapScalar(s scalar.S) (scalar.S, error) {
 }
 
 var IcuVersionMapper = icuVersionMapper{}
+
+type xLogRecPtrMapper struct{}
+
+func (m xLogRecPtrMapper) MapScalar(s scalar.S) (scalar.S, error) {
+	lsn := s.ActualU()
+	s.Sym = fmt.Sprintf("%X/%X", lsn>>32, uint32(lsn))
+	return s, nil
+}
+
+var XLogRecPtrMapper = xLogRecPtrMapper{}
diff --git a/format/postgres/flavours/pgproee14/pg_control.go b/format/postgres/flavours/pgproee14/pg_control.go
@@ -95,14 +95,14 @@ func DecodePgControl(d *decode.D, in any) any {
 	/*   32      |     8 */ // XLogRecPtr checkPoint;
 	/*   40      |   120 */ // CheckPoint checkPointCopy;
 	d.FieldS64("time")
-	d.FieldU64("checkPoint")
+	d.FieldU64("checkPoint", common.XLogRecPtrMapper)
 	d.FieldStruct("checkPointCopy", func(d *decode.D) {
 		/*    0      |     8 */ // XLogRecPtr redo;
 		/*    8      |     4 */ // TimeLineID ThisTimeLineID;
 		/*   12      |     4 */ // TimeLineID PrevTimeLineID;
 		/*   16      |     1 */ // _Bool fullPageWrites;
 		/* XXX  7-byte hole  */
-		d.FieldU64("redo")
+		d.FieldU64("redo", common.XLogRecPtrMapper)
 		d.FieldU32("ThisTimeLineID")
 		d.FieldU32("PrevTimeLineID")
 		d.FieldU8("fullPageWrites")

diff --git a/format/postgres/flavours/postgres11/pg_control.go b/format/postgres/flavours/postgres11/pg_control.go
@@ -93,14 +93,14 @@ func DecodePgControl(d *decode.D, in any) any {
 	/*   32      |     8 */ // XLogRecPtr checkPoint;
 	/*   40      |    80 */ // CheckPoint checkPointCopy;
 	d.FieldS64("time")
-	d.FieldU64("checkPoint")
+	d.FieldU64("checkPoint", common.XLogRecPtrMapper)
 	d.FieldStruct("checkPointCopy", func(d *decode.D) {
 		/*    0      |     8 */ // XLogRecPtr redo;
 		/*    8      |     4 */ // TimeLineID ThisTimeLineID;
 		/*   12      |     4 */ // TimeLineID PrevTimeLineID;
 		/*   16      |     1 */ // _Bool fullPageWrites;
 		/* XXX  3-byte hole */
-		d.FieldU64("redo")
+		d.FieldU64("redo", common.XLogRecPtrMapper)
 		d.FieldU32("ThisTimeLineID")
 		d.FieldU32("PrevTimeLineID")
 		d.FieldU8("fullPageWrites")

diff --git a/format/postgres/flavours/postgres14/pg_control.go b/format/postgres/flavours/postgres14/pg_control.go
@@ -91,14 +91,14 @@ func DecodePgControl(d *decode.D, in any) any {
 	/*   32      |     8 */ // XLogRecPtr checkPoint;
 	/*   40      |    88 */ // CheckPoint checkPointCopy;
 	d.FieldS64("time")
-	d.FieldU64("checkPoint")
+	d.FieldU64("checkPoint", common.XLogRecPtrMapper)
 	d.FieldStruct("checkPointCopy", func(d *decode.D) {
 		/*    0      |     8 */ // XLogRecPtr redo;
 		/*    8      |     4 */ // TimeLineID ThisTimeLineID;
 		/*   12      |     4 */ // TimeLineID PrevTimeLineID;
 		/*   16      |     1 */ // _Bool fullPageWrites;
 		/* XXX  7-byte hole  */
-		d.FieldU64("redo")
+		d.FieldU64("redo", common.XLogRecPtrMapper)
 		d.FieldU32("ThisTimeLineID")
 		d.FieldU32("PrevTimeLineID")
 		d.FieldU8("fullPageWrites")