#include "postgres.h"
#include "access/brin_xlog.h"
#include "access/clog.h"
#include "access/commit_ts.h"
#include "access/generic_xlog.h"
#include "access/ginxlog.h"
#include "access/gistxlog.h"
#include "access/hash_xlog.h"
#include "access/heapam_xlog.h"
#include "access/multixact.h"
#include "access/nbtxlog.h"
#include "access/rmgr.h"
#include "access/spgxlog.h"
#include "access/xact.h"
#include "access/xlog_internal.h"
#include "catalog/storage_xlog.h"
#include "commands/dbcommands_xlog.h"
#include "commands/sequence.h"
#include "commands/tablespace.h"
#include "replication/message.h"
#include "replication/origin.h"
#include "rmgrdesc.h"
#include "storage/standbydefs.h"
#include "utils/relmapper.h"
#include "access/rmgrlist.h"

Include dependency graph for rmgrdesc.c:

Macros
#define	FRONTEND 1

#define	PG_RMGR(symname, name, redo, desc, identify, startup, cleanup, mask, decode) { name, desc, identify},

#define	CUSTOM_NUMERIC_NAME_LEN sizeof("custom###")

Functions
static void	default_desc (StringInfo buf, XLogReaderState *record)

static const char *	default_identify (uint8 info)

static void	initialize_custom_rmgrs (void)

const RmgrDescData *	GetRmgrDesc (RmgrId rmid)

Variables
static const RmgrDescData	RmgrDescTable [RM_N_BUILTIN_IDS]

static char	CustomNumericNames [RM_N_CUSTOM_IDS][CUSTOM_NUMERIC_NAME_LEN] = {0}

static RmgrDescData	CustomRmgrDesc [RM_N_CUSTOM_IDS] = {0}

static bool	CustomRmgrDescInitialized = false

Macro Definition Documentation

◆ CUSTOM_NUMERIC_NAME_LEN

#define CUSTOM_NUMERIC_NAME_LEN sizeof("custom###")

Definition at line 42 of file rmgrdesc.c.

◆ FRONTEND

#define FRONTEND 1

Definition at line 8 of file rmgrdesc.c.

◆ PG_RMGR

#define PG_RMGR	(	symname,
		name,
		redo,
		desc,
		identify,
		startup,
		cleanup,
		mask,
		decode
	)	{ name, desc, identify},

Definition at line 35 of file rmgrdesc.c.

Function Documentation

◆ default_desc()

static void default_desc	(	StringInfo	buf,
		XLogReaderState *	record
	)

static

Definition at line 52 of file rmgrdesc.c.

{
    appendStringInfo(buf, "rmid: %d", XLogRecGetRmid(record));
}

References appendStringInfo(), buf, and XLogRecGetRmid.

Referenced by initialize_custom_rmgrs().

◆ default_identify()

static const char * default_identify ( uint8 info )

static

Definition at line 62 of file rmgrdesc.c.

{
    return NULL;
}

Referenced by initialize_custom_rmgrs().

◆ GetRmgrDesc()

const RmgrDescData * GetRmgrDesc ( RmgrId rmid )

Definition at line 87 of file rmgrdesc.c.

{
    Assert(RmgrIdIsValid(rmid));
 
    if (RmgrIdIsBuiltin(rmid))
        return &RmgrDescTable[rmid];
    else
    {
        if (!CustomRmgrDescInitialized)
            initialize_custom_rmgrs();
        return &CustomRmgrDesc[rmid - RM_MIN_CUSTOM_ID];
    }
}

References Assert(), CustomRmgrDesc, CustomRmgrDescInitialized, initialize_custom_rmgrs(), RM_MIN_CUSTOM_ID, RmgrDescTable, RmgrIdIsBuiltin(), and RmgrIdIsValid.

Referenced by main(), print_rmgr_list(), XLogDumpDisplayRecord(), and XLogDumpDisplayStats().

◆ initialize_custom_rmgrs()

static void initialize_custom_rmgrs ( void )

static

Definition at line 73 of file rmgrdesc.c.

{
    for (int i = 0; i < RM_N_CUSTOM_IDS; i++)
    {
        snprintf(CustomNumericNames[i], CUSTOM_NUMERIC_NAME_LEN,
                 "custom%03d", i + RM_MIN_CUSTOM_ID);
        CustomRmgrDesc[i].rm_name = CustomNumericNames[i];
        CustomRmgrDesc[i].rm_desc = default_desc;
        CustomRmgrDesc[i].rm_identify = default_identify;
    }
    CustomRmgrDescInitialized = true;
}