/src/postgres/src/backend/access/rmgrdesc/hashdesc.c

Source
/*-------------------------------------------------------------------------
 *
 * hashdesc.c
 *    rmgr descriptor routines for access/hash/hash.c
 *
 * Portions Copyright (c) 1996-2025, PostgreSQL Global Development Group
 * Portions Copyright (c) 1994, Regents of the University of California
 *
 *
 * IDENTIFICATION
 *    src/backend/access/rmgrdesc/hashdesc.c
 *
 *-------------------------------------------------------------------------
 */
#include "postgres.h"

#include "access/hash_xlog.h"

void
hash_desc(StringInfo buf, XLogReaderState *record)
{
  char     *rec = XLogRecGetData(record);
  uint8   info = XLogRecGetInfo(record) & ~XLR_INFO_MASK;

  switch (info)
  {
    case XLOG_HASH_INIT_META_PAGE:
      {
        xl_hash_init_meta_page *xlrec = (xl_hash_init_meta_page *) rec;

        appendStringInfo(buf, "num_tuples %g, procid %u, fillfactor %d",
                 xlrec->num_tuples,
                 xlrec->procid,
                 xlrec->ffactor);
        break;
      }
    case XLOG_HASH_INIT_BITMAP_PAGE:
      {
        xl_hash_init_bitmap_page *xlrec = (xl_hash_init_bitmap_page *) rec;

        appendStringInfo(buf, "bmsize %d", xlrec->bmsize);
        break;
      }
    case XLOG_HASH_INSERT:
      {
        xl_hash_insert *xlrec = (xl_hash_insert *) rec;

        appendStringInfo(buf, "off %u", xlrec->offnum);
        break;
      }
    case XLOG_HASH_ADD_OVFL_PAGE:
      {
        xl_hash_add_ovfl_page *xlrec = (xl_hash_add_ovfl_page *) rec;

        appendStringInfo(buf, "bmsize %d, bmpage_found %c",
                 xlrec->bmsize, (xlrec->bmpage_found) ? 'T' : 'F');
        break;
      }
    case XLOG_HASH_SPLIT_ALLOCATE_PAGE:
      {
        xl_hash_split_allocate_page *xlrec = (xl_hash_split_allocate_page *) rec;

        appendStringInfo(buf, "new_bucket %u, old_bucket_flag %u, new_bucket_flag %u, meta_page_masks_updated %c, issplitpoint_changed %c",
                 xlrec->new_bucket,
                 xlrec->old_bucket_flag,
                 xlrec->new_bucket_flag,
                 (xlrec->flags & XLH_SPLIT_META_UPDATE_MASKS) ? 'T' : 'F',
                 (xlrec->flags & XLH_SPLIT_META_UPDATE_SPLITPOINT) ? 'T' : 'F');
        break;
      }
    case XLOG_HASH_SPLIT_COMPLETE:
      {
        xl_hash_split_complete *xlrec = (xl_hash_split_complete *) rec;

        appendStringInfo(buf, "old_bucket_flag %u, new_bucket_flag %u",
                 xlrec->old_bucket_flag, xlrec->new_bucket_flag);
        break;
      }
    case XLOG_HASH_MOVE_PAGE_CONTENTS:
      {
        xl_hash_move_page_contents *xlrec = (xl_hash_move_page_contents *) rec;

        appendStringInfo(buf, "ntups %d, is_primary %c",
                 xlrec->ntups,
                 xlrec->is_prim_bucket_same_wrt ? 'T' : 'F');
        break;
      }
    case XLOG_HASH_SQUEEZE_PAGE:
      {
        xl_hash_squeeze_page *xlrec = (xl_hash_squeeze_page *) rec;

        appendStringInfo(buf, "prevblkno %u, nextblkno %u, ntups %d, is_primary %c, is_previous %c",
                 xlrec->prevblkno,
                 xlrec->nextblkno,
                 xlrec->ntups,
                 xlrec->is_prim_bucket_same_wrt ? 'T' : 'F',
                 xlrec->is_prev_bucket_same_wrt ? 'T' : 'F');
        break;
      }
    case XLOG_HASH_DELETE:
      {
        xl_hash_delete *xlrec = (xl_hash_delete *) rec;

        appendStringInfo(buf, "clear_dead_marking %c, is_primary %c",
                 xlrec->clear_dead_marking ? 'T' : 'F',
                 xlrec->is_primary_bucket_page ? 'T' : 'F');
        break;
      }
    case XLOG_HASH_UPDATE_META_PAGE:
      {
        xl_hash_update_meta_page *xlrec = (xl_hash_update_meta_page *) rec;

        appendStringInfo(buf, "ntuples %g",
                 xlrec->ntuples);
        break;
      }
    case XLOG_HASH_VACUUM_ONE_PAGE:
      {
        xl_hash_vacuum_one_page *xlrec = (xl_hash_vacuum_one_page *) rec;

        appendStringInfo(buf, "ntuples %d, snapshotConflictHorizon %u, isCatalogRel %c",
                 xlrec->ntuples,
                 xlrec->snapshotConflictHorizon,
                 xlrec->isCatalogRel ? 'T' : 'F');
        break;
      }
  }
}

const char *
hash_identify(uint8 info)
{
  const char *id = NULL;

  switch (info & ~XLR_INFO_MASK)
  {
    case XLOG_HASH_INIT_META_PAGE:
      id = "INIT_META_PAGE";
      break;
    case XLOG_HASH_INIT_BITMAP_PAGE:
      id = "INIT_BITMAP_PAGE";
      break;
    case XLOG_HASH_INSERT:
      id = "INSERT";
      break;
    case XLOG_HASH_ADD_OVFL_PAGE:
      id = "ADD_OVFL_PAGE";
      break;
    case XLOG_HASH_SPLIT_ALLOCATE_PAGE:
      id = "SPLIT_ALLOCATE_PAGE";
      break;
    case XLOG_HASH_SPLIT_PAGE:
      id = "SPLIT_PAGE";
      break;
    case XLOG_HASH_SPLIT_COMPLETE:
      id = "SPLIT_COMPLETE";
      break;
    case XLOG_HASH_MOVE_PAGE_CONTENTS:
      id = "MOVE_PAGE_CONTENTS";
      break;
    case XLOG_HASH_SQUEEZE_PAGE:
      id = "SQUEEZE_PAGE";
      break;
    case XLOG_HASH_DELETE:
      id = "DELETE";
      break;
    case XLOG_HASH_SPLIT_CLEANUP:
      id = "SPLIT_CLEANUP";
      break;
    case XLOG_HASH_UPDATE_META_PAGE:
      id = "UPDATE_META_PAGE";
      break;
    case XLOG_HASH_VACUUM_ONE_PAGE:
      id = "VACUUM_ONE_PAGE";
  }

  return id;
}

Line	Count	Source
1		/*-------------------------------------------------------------------------
2		*
3		* hashdesc.c
4		* rmgr descriptor routines for access/hash/hash.c
5		*
6		* Portions Copyright (c) 1996-2025, PostgreSQL Global Development Group
7		* Portions Copyright (c) 1994, Regents of the University of California
8		*
9		*
10		* IDENTIFICATION
11		* src/backend/access/rmgrdesc/hashdesc.c
12		*
13		*-------------------------------------------------------------------------
14		*/
15		#include "postgres.h"
16
17		#include "access/hash_xlog.h"
18
19		void
20		hash_desc(StringInfo buf, XLogReaderState *record)
21	0	{
22	0	char *rec = XLogRecGetData(record);
23	0	uint8 info = XLogRecGetInfo(record) & ~XLR_INFO_MASK;
24
25	0	switch (info)
26	0	{
27	0	case XLOG_HASH_INIT_META_PAGE:
28	0	{
29	0	xl_hash_init_meta_page xlrec = (xl_hash_init_meta_page ) rec;
30
31	0	appendStringInfo(buf, "num_tuples %g, procid %u, fillfactor %d",
32	0	xlrec->num_tuples,
33	0	xlrec->procid,
34	0	xlrec->ffactor);
35	0	break;
36	0	}
37	0	case XLOG_HASH_INIT_BITMAP_PAGE:
38	0	{
39	0	xl_hash_init_bitmap_page xlrec = (xl_hash_init_bitmap_page ) rec;
40
41	0	appendStringInfo(buf, "bmsize %d", xlrec->bmsize);
42	0	break;
43	0	}
44	0	case XLOG_HASH_INSERT:
45	0	{
46	0	xl_hash_insert xlrec = (xl_hash_insert ) rec;
47
48	0	appendStringInfo(buf, "off %u", xlrec->offnum);
49	0	break;
50	0	}
51	0	case XLOG_HASH_ADD_OVFL_PAGE:
52	0	{
53	0	xl_hash_add_ovfl_page xlrec = (xl_hash_add_ovfl_page ) rec;
54
55	0	appendStringInfo(buf, "bmsize %d, bmpage_found %c",
56	0	xlrec->bmsize, (xlrec->bmpage_found) ? 'T' : 'F');
57	0	break;
58	0	}
59	0	case XLOG_HASH_SPLIT_ALLOCATE_PAGE:
60	0	{
61	0	xl_hash_split_allocate_page xlrec = (xl_hash_split_allocate_page ) rec;
62
63	0	appendStringInfo(buf, "new_bucket %u, old_bucket_flag %u, new_bucket_flag %u, meta_page_masks_updated %c, issplitpoint_changed %c",
64	0	xlrec->new_bucket,
65	0	xlrec->old_bucket_flag,
66	0	xlrec->new_bucket_flag,
67	0	(xlrec->flags & XLH_SPLIT_META_UPDATE_MASKS) ? 'T' : 'F',
68	0	(xlrec->flags & XLH_SPLIT_META_UPDATE_SPLITPOINT) ? 'T' : 'F');
69	0	break;
70	0	}
71	0	case XLOG_HASH_SPLIT_COMPLETE:
72	0	{
73	0	xl_hash_split_complete xlrec = (xl_hash_split_complete ) rec;
74
75	0	appendStringInfo(buf, "old_bucket_flag %u, new_bucket_flag %u",
76	0	xlrec->old_bucket_flag, xlrec->new_bucket_flag);
77	0	break;
78	0	}
79	0	case XLOG_HASH_MOVE_PAGE_CONTENTS:
80	0	{
81	0	xl_hash_move_page_contents xlrec = (xl_hash_move_page_contents ) rec;
82
83	0	appendStringInfo(buf, "ntups %d, is_primary %c",
84	0	xlrec->ntups,
85	0	xlrec->is_prim_bucket_same_wrt ? 'T' : 'F');
86	0	break;
87	0	}
88	0	case XLOG_HASH_SQUEEZE_PAGE:
89	0	{
90	0	xl_hash_squeeze_page xlrec = (xl_hash_squeeze_page ) rec;
91
92	0	appendStringInfo(buf, "prevblkno %u, nextblkno %u, ntups %d, is_primary %c, is_previous %c",
93	0	xlrec->prevblkno,
94	0	xlrec->nextblkno,
95	0	xlrec->ntups,
96	0	xlrec->is_prim_bucket_same_wrt ? 'T' : 'F',
97	0	xlrec->is_prev_bucket_same_wrt ? 'T' : 'F');
98	0	break;
99	0	}
100	0	case XLOG_HASH_DELETE:
101	0	{
102	0	xl_hash_delete xlrec = (xl_hash_delete ) rec;
103
104	0	appendStringInfo(buf, "clear_dead_marking %c, is_primary %c",
105	0	xlrec->clear_dead_marking ? 'T' : 'F',
106	0	xlrec->is_primary_bucket_page ? 'T' : 'F');
107	0	break;
108	0	}
109	0	case XLOG_HASH_UPDATE_META_PAGE:
110	0	{
111	0	xl_hash_update_meta_page xlrec = (xl_hash_update_meta_page ) rec;
112
113	0	appendStringInfo(buf, "ntuples %g",
114	0	xlrec->ntuples);
115	0	break;
116	0	}
117	0	case XLOG_HASH_VACUUM_ONE_PAGE:
118	0	{
119	0	xl_hash_vacuum_one_page xlrec = (xl_hash_vacuum_one_page ) rec;
120
121	0	appendStringInfo(buf, "ntuples %d, snapshotConflictHorizon %u, isCatalogRel %c",
122	0	xlrec->ntuples,
123	0	xlrec->snapshotConflictHorizon,
124	0	xlrec->isCatalogRel ? 'T' : 'F');
125	0	break;
126	0	}
127	0	}
128	0	}
129
130		const char *
131		hash_identify(uint8 info)
132	0	{
133	0	const char *id = NULL;
134
135	0	switch (info & ~XLR_INFO_MASK)
136	0	{
137	0	case XLOG_HASH_INIT_META_PAGE:
138	0	id = "INIT_META_PAGE";
139	0	break;
140	0	case XLOG_HASH_INIT_BITMAP_PAGE:
141	0	id = "INIT_BITMAP_PAGE";
142	0	break;
143	0	case XLOG_HASH_INSERT:
144	0	id = "INSERT";
145	0	break;
146	0	case XLOG_HASH_ADD_OVFL_PAGE:
147	0	id = "ADD_OVFL_PAGE";
148	0	break;
149	0	case XLOG_HASH_SPLIT_ALLOCATE_PAGE:
150	0	id = "SPLIT_ALLOCATE_PAGE";
151	0	break;
152	0	case XLOG_HASH_SPLIT_PAGE:
153	0	id = "SPLIT_PAGE";
154	0	break;
155	0	case XLOG_HASH_SPLIT_COMPLETE:
156	0	id = "SPLIT_COMPLETE";
157	0	break;
158	0	case XLOG_HASH_MOVE_PAGE_CONTENTS:
159	0	id = "MOVE_PAGE_CONTENTS";
160	0	break;
161	0	case XLOG_HASH_SQUEEZE_PAGE:
162	0	id = "SQUEEZE_PAGE";
163	0	break;
164	0	case XLOG_HASH_DELETE:
165	0	id = "DELETE";
166	0	break;
167	0	case XLOG_HASH_SPLIT_CLEANUP:
168	0	id = "SPLIT_CLEANUP";
169	0	break;
170	0	case XLOG_HASH_UPDATE_META_PAGE:
171	0	id = "UPDATE_META_PAGE";
172	0	break;
173	0	case XLOG_HASH_VACUUM_ONE_PAGE:
174	0	id = "VACUUM_ONE_PAGE";
175	0	}
176
177	0	return id;
178	0	}

Coverage Report

Created: 2025-10-09 06:07