Add VacuumHorizonHook instead of just hint bits horizon

Author: akorotkov

src/backend/access/heap/heapam_visibility.c

@@ -78,7 +78,7 @@
 #include "utils/builtins.h"
 #include "utils/snapmgr.h"
 
-static TransactionId hint_bit_horizon = InvalidTransactionId;
+VacuumHorizonHookType VacuumHorizonHook = NULL;
 
 
 /*
@@ -129,10 +129,14 @@ SetHintBits(HeapTupleHeader tuple, Buffer buffer,
 		}
 	}
 
-	if (TransactionIdIsValid(hint_bit_horizon) &&
-		TransactionIdIsValid(xid) &&
-		TransactionIdFollows(xid, hint_bit_horizon))
-		return;
+	if (TransactionIdIsValid(xid) && VacuumHorizonHook)
+	{
+		TransactionId horizon = VacuumHorizonHook();
+
+		if (TransactionIdIsValid(horizon) &&
+			TransactionIdFollows(xid, horizon))
+			return;
+	}
 
 	tuple->t_infomask |= infomask;
 	MarkBufferDirtyHint(buffer, true);
@@ -1793,9 +1797,3 @@ HeapTupleSatisfiesVisibility(HeapTuple htup, Snapshot snapshot, Buffer buffer)
 
 	return false;				/* keep compiler quiet */
 }
-
-void
-SetHintBitsHorizon(TransactionId new_horizon)
-{
-	hint_bit_horizon = new_horizon;
-}

src/backend/commands/vacuum.c

@@ -1106,6 +1106,14 @@ vacuum_get_cutoffs(Relation rel, const VacuumParams *params,
 	 * any time, and that each vacuum is always an independent transaction.
 	 */
 	cutoffs->OldestXmin = GetOldestNonRemovableTransactionId(rel);
+	if (VacuumHorizonHook)
+	{
+		TransactionId horizon = VacuumHorizonHook();
+
+		if (TransactionIdIsValid(horizon) &&
+			TransactionIdFollows(cutoffs->OldestXmin, horizon))
+			cutoffs->OldestXmin = horizon;
+	}
 
 	Assert(TransactionIdIsNormal(cutoffs->OldestXmin));
 
@@ -1593,6 +1601,14 @@ vac_update_datfrozenxid(void)
 	 * cannot produce a wrong minimum by starting with this.
 	 */
 	newFrozenXid = GetOldestNonRemovableTransactionId(NULL);
+	if (VacuumHorizonHook)
+	{
+		TransactionId horizon = VacuumHorizonHook();
+
+		if (TransactionIdIsValid(horizon) &&
+			TransactionIdFollows(newFrozenXid, horizon))
+			newFrozenXid = horizon;
+	}
 
 	/*
 	 * Similarly, initialize the MultiXact "min" with the value that would be

src/include/access/heapam.h

@@ -398,6 +398,10 @@ extern void heap_vacuum_rel(Relation rel,
 							struct VacuumParams *params, BufferAccessStrategy bstrategy);
 
 /* in heap/heapam_visibility.c */
+typedef TransactionId (*VacuumHorizonHookType) (void);
+
+extern VacuumHorizonHookType VacuumHorizonHook;
+
 extern bool HeapTupleSatisfiesVisibility(HeapTuple htup, Snapshot snapshot,
 										 Buffer buffer);
 extern TM_Result HeapTupleSatisfiesUpdate(HeapTuple htup, CommandId curcid,
@@ -412,8 +416,6 @@ extern bool HeapTupleHeaderIsOnlyLocked(HeapTupleHeader tuple);
 extern bool HeapTupleIsSurelyDead(HeapTuple htup,
 								  struct GlobalVisState *vistest);
 
-extern void SetHintBitsHorizon(TransactionId new_horizon);
-
 /*
  * To avoid leaking too much knowledge about reorderbuffer implementation
  * details this is implemented in reorderbuffer.c not heapam_visibility.c