#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/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 "fmgr.h"
#include "funcapi.h"
#include "miscadmin.h"
#include "replication/decode.h"
#include "replication/message.h"
#include "replication/origin.h"
#include "storage/standby.h"
#include "utils/builtins.h"
#include "utils/relmapper.h"
#include "access/rmgrlist.h"

Include dependency graph for rmgr.c:

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

#define	PG_GET_RESOURCE_MANAGERS_COLS 3

Functions
void	RmgrStartup (void)

void	RmgrCleanup (void)

void	RmgrNotFound (RmgrId rmid)

void	RegisterCustomRmgr (RmgrId rmid, const RmgrData *rmgr)

Datum	pg_get_wal_resource_managers (PG_FUNCTION_ARGS)

Variables
RmgrData	RmgrTable [RM_MAX_ID+1]

Macro Definition Documentation

◆ PG_GET_RESOURCE_MANAGERS_COLS

#define PG_GET_RESOURCE_MANAGERS_COLS 3

◆ PG_RMGR

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

Definition at line 38 of file rmgr.c.

Function Documentation

◆ pg_get_wal_resource_managers()

Datum pg_get_wal_resource_managers ( PG_FUNCTION_ARGS )

Definition at line 141 of file rmgr.c.

 {
 #define PG_GET_RESOURCE_MANAGERS_COLS 3
     ReturnSetInfo *rsinfo = (ReturnSetInfo *) fcinfo->resultinfo;
     Datum       values[PG_GET_RESOURCE_MANAGERS_COLS];
     bool        nulls[PG_GET_RESOURCE_MANAGERS_COLS] = {0};
  
     InitMaterializedSRF(fcinfo, 0);
  
     for (int rmid = 0; rmid <= RM_MAX_ID; rmid++)
     {
         if (!RmgrIdExists(rmid))
             continue;
         values[0] = Int32GetDatum(rmid);
         values[1] = CStringGetTextDatum(GetRmgr(rmid).rm_name);
         values[2] = BoolGetDatum(RmgrIdIsBuiltin(rmid));
         tuplestore_putvalues(rsinfo->setResult, rsinfo->setDesc, values, nulls);
     }
  
     return (Datum) 0;
 }

References PG_GET_RESOURCE_MANAGERS_COLS, and values.

◆ RegisterCustomRmgr()

void RegisterCustomRmgr	(	RmgrId	rmid,
		const RmgrData *	rmgr
	)

Definition at line 98 of file rmgr.c.

 {
     if (rmgr->rm_name == NULL || strlen(rmgr->rm_name) == 0)
         ereport(ERROR, (errmsg("custom resource manager name is invalid"),
                         errhint("Provide a non-empty name for the custom resource manager.")));
  
     if (!RmgrIdIsCustom(rmid))
         ereport(ERROR, (errmsg("custom resource manager ID %d is out of range", rmid),
                         errhint("Provide a custom resource manager ID between %d and %d.",
                                 RM_MIN_CUSTOM_ID, RM_MAX_CUSTOM_ID)));
  
     if (!process_shared_preload_libraries_in_progress)
         ereport(ERROR,
                 (errmsg("failed to register custom resource manager \"%s\" with ID %d", rmgr->rm_name, rmid),
                  errdetail("Custom resource manager must be registered while initializing modules in shared_preload_libraries.")));
  
     if (RmgrTable[rmid].rm_name != NULL)
         ereport(ERROR,
                 (errmsg("failed to register custom resource manager \"%s\" with ID %d", rmgr->rm_name, rmid),
                  errdetail("Custom resource manager \"%s\" already registered with the same ID.",
                            RmgrTable[rmid].rm_name)));
  
     /* check for existing rmgr with the same name */
     for (int existing_rmid = 0; existing_rmid <= RM_MAX_ID; existing_rmid++)
     {
         if (!RmgrIdExists(existing_rmid))
             continue;
  
         if (!pg_strcasecmp(RmgrTable[existing_rmid].rm_name, rmgr->rm_name))
             ereport(ERROR,
                     (errmsg("failed to register custom resource manager \"%s\" with ID %d", rmgr->rm_name, rmid),
                      errdetail("Existing resource manager with ID %d has the same name.", existing_rmid)));
     }
  
     /* register it */
     RmgrTable[rmid] = *rmgr;
     ereport(LOG,
             (errmsg("registered custom resource manager \"%s\" with ID %d",
                     rmgr->rm_name, rmid)));
 }

References ereport, errdetail(), errhint(), errmsg(), ERROR, LOG, pg_strcasecmp(), process_shared_preload_libraries_in_progress, RM_MAX_CUSTOM_ID, RM_MAX_ID, RM_MIN_CUSTOM_ID, RmgrData::rm_name, RmgrIdExists(), RmgrIdIsCustom(), and RmgrTable.

Referenced by _PG_init().

◆ RmgrCleanup()

void RmgrCleanup ( void )

Definition at line 65 of file rmgr.c.

 {
     for (int rmid = 0; rmid <= RM_MAX_ID; rmid++)
     {
         if (!RmgrIdExists(rmid))
             continue;
  
         if (RmgrTable[rmid].rm_cleanup != NULL)
             RmgrTable[rmid].rm_cleanup();
     }
 }

References RmgrData::rm_cleanup, RM_MAX_ID, RmgrIdExists(), and RmgrTable.

Referenced by PerformWalRecovery().

◆ RmgrNotFound()

void RmgrNotFound ( RmgrId rmid )

Definition at line 82 of file rmgr.c.

 {
     ereport(ERROR, (errmsg("resource manager with ID %d not registered", rmid),
                     errhint("Include the extension module that implements this resource manager in shared_preload_libraries.")));
 }

References ereport, errhint(), errmsg(), and ERROR.

Referenced by GetRmgr().

◆ RmgrStartup()

void RmgrStartup ( void )

Definition at line 49 of file rmgr.c.

 {
     for (int rmid = 0; rmid <= RM_MAX_ID; rmid++)
     {
         if (!RmgrIdExists(rmid))
             continue;
  
         if (RmgrTable[rmid].rm_startup != NULL)
             RmgrTable[rmid].rm_startup();
     }
 }