[PGPRO-11599] TIDBitmap added to rum.

Static functions from TIDBitmap were added to RUM as RumTIDBitmap.
A function has been added to search for tid inside RumTIDBitmap.

Tags: rum

Author: Arseny Kositsyn

Makefile

@@ -5,7 +5,7 @@ EXTENSION = rum
 EXTVERSION = 1.3
 PGFILEDESC = "RUM index access method"
 
-OBJS = src/rumsort.o src/rum_ts_utils.o src/rumtsquery.o \
+OBJS = src/rumtidbitmap.o src/rumsort.o src/rum_ts_utils.o src/rumtsquery.o \
 	src/rumbtree.o src/rumbulk.o src/rumdatapage.o \
 	src/rumentrypage.o src/rumget.o src/ruminsert.o \
 	src/rumscan.o src/rumutil.o src/rumvacuum.o src/rumvalidate.o \
@@ -16,7 +16,7 @@ DATA_updates = rum--1.0--1.1.sql rum--1.1--1.2.sql \
 
 DATA_built = $(EXTENSION)--$(EXTVERSION).sql
 
-INCLUDES = rum.h rumsort.h
+INCLUDES = rum.h rumsort.h rumtidbitmap.h
 RELATIVE_INCLUDES = $(addprefix src/, $(INCLUDES))
 
 LDFLAGS_SL += $(filter -lm, $(LIBS))

src/rumtidbitmap.c

@@ -0,0 +1,114 @@
+/*-------------------------------------------------------------------------
+ *
+ * rumtidbitmap.c
+ *	  PostgreSQL tuple-id (TID) bitmap package
+ *
+ * This module contains copies of static functions from
+ * src/backend/nodes/tidbitmap.c, which are needed to store
+ * and quickly search for tids.
+ *
+ * Portions Copyright (c) 2025, Postgres Professional
+ *
+ *-------------------------------------------------------------------------
+ */
+
+#include "rumtidbitmap.h"
+#include "tidbitmap.c"
+
+RumTIDBitmap *
+rum_tbm_create(long maxbytes, dsa_area *dsa)
+{
+	return tbm_create(maxbytes, dsa);
+}
+
+void
+rum_tbm_free(RumTIDBitmap *tbm)
+{
+	tbm_free(tbm);
+}
+
+void
+rum_tbm_add_tuples(RumTIDBitmap *tbm,
+				   const ItemPointer tids,
+				   int ntids, bool recheck)
+{
+	tbm_add_tuples(tbm, tids, ntids, recheck);
+}
+
+void
+rum_tbm_add_page(RumTIDBitmap *tbm, BlockNumber pageno)
+{
+	tbm_add_page(tbm, pageno);
+}
+
+void
+rum_tbm_union(RumTIDBitmap *a, const RumTIDBitmap *b)
+{
+	tbm_union(a, b);
+}
+
+void rum_tbm_intersect(RumTIDBitmap *a, const RumTIDBitmap *b)
+{
+	tbm_intersect(a, b);
+}
+
+bool
+rum_tbm_is_empty(const RumTIDBitmap *tbm)
+{
+	return tbm_is_empty(tbm);
+}
+
+RumTBMIterator *
+rum_tbm_begin_iterate(RumTIDBitmap *tbm)
+{
+	return tbm_begin_iterate(tbm);
+}
+
+RumTBMIterateResult *
+rum_tbm_iterate(RumTBMIterator *iterator)
+{
+	return tbm_iterate(iterator);
+}
+
+void
+rum_tbm_end_iterate(RumTBMIterator *iterator)
+{
+	tbm_end_iterate(iterator);
+}
+
+long
+rum_tbm_calculate_entries(double maxbytes)
+{
+	return tbm_calculate_entries(maxbytes);
+}
+
+/*
+ * The function is needed to search for tid inside RumTIDBitmap.
+ * If the page is marked as lossy, it writes true to *recheck.
+ */
+bool
+rum_tbm_contains_tid(RumTIDBitmap *tbm, ItemPointer tid, bool *recheck)
+{
+	BlockNumber blkn = ItemPointerGetBlockNumber(tid);
+	OffsetNumber off = ItemPointerGetOffsetNumber(tid);
+
+	const PagetableEntry *page = NULL;
+
+	*recheck = false;
+
+	if (tbm_page_is_lossy(tbm, blkn))
+	{
+		*recheck = true;
+		return true;
+	}
+
+	else if ((page = tbm_find_pageentry(tbm, blkn)) != NULL)
+	{
+		int wn = WORDNUM(off - 1);
+		int bn = BITNUM(off - 1);
+		return (page->words[wn] & ((bitmapword) 1 << bn)) != 0;
+	}
+
+	else
+		return false;
+}

src/rumtidbitmap.h

@@ -0,0 +1,52 @@
+/*-------------------------------------------------------------------------
+ *
+ * rumtidbitmap.h
+ *	  PostgreSQL tuple-id (TID) bitmap package
+ *
+ * This module contains copies of static functions from
+ * src/backend/nodes/tidbitmap.c, which are needed to store
+ * and quickly search for tids.
+ *
+ * Portions Copyright (c) 2025, Postgres Professional
+ *
+ *-------------------------------------------------------------------------
+ */
+#ifndef RUMTIDBITMAP_H
+#define RUMTIDBITMAP_H
+
+#include "postgres.h"
+#include "nodes/tidbitmap.h"
+
+typedef struct TIDBitmap RumTIDBitmap;
+
+/* Likewise, RumTIDBitmap is private */
+typedef struct TBMIterator RumTBMIterator;
+
+/* Result structure for rum_tbm_iterate */
+typedef struct TBMIterateResult RumTBMIterateResult;
+
+/* function prototypes in rumtidbitmap.c */
+
+extern RumTIDBitmap *rum_tbm_create(long maxbytes, dsa_area *dsa);
+extern void rum_tbm_free(RumTIDBitmap *tbm);
+
+extern void rum_tbm_add_tuples(RumTIDBitmap *tbm,
+						   const ItemPointer tids, int ntids,
+						   bool recheck);
+extern void rum_tbm_add_page(RumTIDBitmap *tbm, BlockNumber pageno);
+
+extern void rum_tbm_union(RumTIDBitmap *a, const RumTIDBitmap *b);
+extern void rum_tbm_intersect(RumTIDBitmap *a, const RumTIDBitmap *b);
+
+extern bool rum_tbm_is_empty(const RumTIDBitmap *tbm);
+
+extern RumTBMIterator *rum_tbm_begin_iterate(RumTIDBitmap *tbm);
+extern RumTBMIterateResult *rum_tbm_iterate(RumTBMIterator *iterator);
+extern void rum_tbm_end_iterate(RumTBMIterator *iterator);
+
+extern long rum_tbm_calculate_entries(double maxbytes);
+
+extern bool
+rum_tbm_contains_tid(RumTIDBitmap *tbm, ItemPointer tid, bool *recheck);
+
+#endif							/* RUMTIDBITMAP_H */