PostgreSQL Source Code git master
|
#include "postgres.h"
#include <fcntl.h>
#include <sys/stat.h>
#include <unistd.h>
#include "access/xact.h"
#include "access/xlog.h"
#include "access/xloginsert.h"
#include "catalog/pg_tablespace.h"
#include "catalog/storage.h"
#include "miscadmin.h"
#include "pgstat.h"
#include "storage/fd.h"
#include "storage/lwlock.h"
#include "utils/inval.h"
#include "utils/relmapper.h"
Go to the source code of this file.
Data Structures | |
struct | RelMapping |
struct | RelMapFile |
struct | SerializedActiveRelMaps |
Macros | |
#define | RELMAPPER_FILENAME "pg_filenode.map" |
#define | RELMAPPER_TEMP_FILENAME "pg_filenode.map.tmp" |
#define | RELMAPPER_FILEMAGIC 0x592717 /* version ID value */ |
#define | MAX_MAPPINGS 64 |
Typedefs | |
typedef struct RelMapping | RelMapping |
typedef struct RelMapFile | RelMapFile |
typedef struct SerializedActiveRelMaps | SerializedActiveRelMaps |
Functions | |
static void | apply_map_update (RelMapFile *map, Oid relationId, RelFileNumber fileNumber, bool add_okay) |
static void | merge_map_updates (RelMapFile *map, const RelMapFile *updates, bool add_okay) |
static void | load_relmap_file (bool shared, bool lock_held) |
static void | read_relmap_file (RelMapFile *map, char *dbpath, bool lock_held, int elevel) |
static void | write_relmap_file (RelMapFile *newmap, bool write_wal, bool send_sinval, bool preserve_files, Oid dbid, Oid tsid, const char *dbpath) |
static void | perform_relmap_update (bool shared, const RelMapFile *updates) |
RelFileNumber | RelationMapOidToFilenumber (Oid relationId, bool shared) |
Oid | RelationMapFilenumberToOid (RelFileNumber filenumber, bool shared) |
RelFileNumber | RelationMapOidToFilenumberForDatabase (char *dbpath, Oid relationId) |
void | RelationMapCopy (Oid dbid, Oid tsid, char *srcdbpath, char *dstdbpath) |
void | RelationMapUpdateMap (Oid relationId, RelFileNumber fileNumber, bool shared, bool immediate) |
void | RelationMapRemoveMapping (Oid relationId) |
void | RelationMapInvalidate (bool shared) |
void | RelationMapInvalidateAll (void) |
void | AtCCI_RelationMap (void) |
void | AtEOXact_RelationMap (bool isCommit, bool isParallelWorker) |
void | AtPrepare_RelationMap (void) |
void | CheckPointRelationMap (void) |
void | RelationMapFinishBootstrap (void) |
void | RelationMapInitialize (void) |
void | RelationMapInitializePhase2 (void) |
void | RelationMapInitializePhase3 (void) |
Size | EstimateRelationMapSpace (void) |
void | SerializeRelationMap (Size maxSize, char *startAddress) |
void | RestoreRelationMap (char *startAddress) |
void | relmap_redo (XLogReaderState *record) |
Variables | |
static RelMapFile | shared_map |
static RelMapFile | local_map |
static RelMapFile | active_shared_updates |
static RelMapFile | active_local_updates |
static RelMapFile | pending_shared_updates |
static RelMapFile | pending_local_updates |
#define MAX_MAPPINGS 64 |
Definition at line 81 of file relmapper.c.
#define RELMAPPER_FILEMAGIC 0x592717 /* version ID value */ |
Definition at line 73 of file relmapper.c.
#define RELMAPPER_FILENAME "pg_filenode.map" |
Definition at line 70 of file relmapper.c.
#define RELMAPPER_TEMP_FILENAME "pg_filenode.map.tmp" |
Definition at line 71 of file relmapper.c.
typedef struct RelMapFile RelMapFile |
typedef struct RelMapping RelMapping |
typedef struct SerializedActiveRelMaps SerializedActiveRelMaps |
|
static |
Definition at line 383 of file relmapper.c.
References elog, ERROR, i, RelMapping::mapfilenumber, RelMapping::mapoid, RelMapFile::mappings, MAX_MAPPINGS, and RelMapFile::num_mappings.
Referenced by merge_map_updates(), and RelationMapUpdateMap().
void AtCCI_RelationMap | ( | void | ) |
Definition at line 504 of file relmapper.c.
References active_local_updates, active_shared_updates, merge_map_updates(), RelMapFile::num_mappings, pending_local_updates, and pending_shared_updates.
Referenced by AtCCI_LocalCache().
void AtEOXact_RelationMap | ( | bool | isCommit, |
bool | isParallelWorker | ||
) |
Definition at line 541 of file relmapper.c.
References active_local_updates, active_shared_updates, Assert, RelMapFile::num_mappings, pending_local_updates, pending_shared_updates, and perform_relmap_update().
Referenced by AbortTransaction(), and CommitTransaction().
void AtPrepare_RelationMap | ( | void | ) |
Definition at line 588 of file relmapper.c.
References active_local_updates, active_shared_updates, ereport, errcode(), errmsg(), ERROR, RelMapFile::num_mappings, pending_local_updates, and pending_shared_updates.
Referenced by PrepareTransaction().
void CheckPointRelationMap | ( | void | ) |
Definition at line 611 of file relmapper.c.
References LW_SHARED, LWLockAcquire(), and LWLockRelease().
Referenced by CheckPointGuts().
Size EstimateRelationMapSpace | ( | void | ) |
Definition at line 713 of file relmapper.c.
Referenced by InitializeParallelDSM(), and SerializeRelationMap().
|
static |
Definition at line 765 of file relmapper.c.
References DatabasePath, FATAL, local_map, read_relmap_file(), and shared_map.
Referenced by perform_relmap_update(), RelationMapInitializePhase2(), RelationMapInitializePhase3(), RelationMapInvalidate(), and RelationMapInvalidateAll().
|
static |
Definition at line 416 of file relmapper.c.
References apply_map_update(), i, RelMapping::mapfilenumber, RelMapping::mapoid, RelMapFile::mappings, and RelMapFile::num_mappings.
Referenced by AtCCI_RelationMap(), and perform_relmap_update().
|
static |
Definition at line 1039 of file relmapper.c.
References allowSystemTableMods, DatabasePath, InvalidOid, load_relmap_file(), local_map, LW_EXCLUSIVE, LWLockAcquire(), LWLockRelease(), merge_map_updates(), MyDatabaseId, MyDatabaseTableSpace, shared_map, and write_relmap_file().
Referenced by AtEOXact_RelationMap().
|
static |
Definition at line 784 of file relmapper.c.
References Assert, CloseTransientFile(), COMP_CRC32C, RelMapFile::crc, crc, EQ_CRC32C, ereport, errcode(), ERRCODE_DATA_CORRUPTED, errcode_for_file_access(), errmsg(), ERROR, fd(), FIN_CRC32C, INIT_CRC32C, LW_SHARED, LWLockAcquire(), LWLockRelease(), RelMapFile::magic, MAX_MAPPINGS, MAXPGPATH, RelMapFile::num_mappings, OpenTransientFile(), PG_BINARY, pgstat_report_wait_end(), pgstat_report_wait_start(), read, RELMAPPER_FILEMAGIC, RELMAPPER_FILENAME, and snprintf.
Referenced by load_relmap_file(), RelationMapCopy(), and RelationMapOidToFilenumberForDatabase().
Definition at line 292 of file relmapper.c.
References ERROR, LW_EXCLUSIVE, LWLockAcquire(), LWLockRelease(), read_relmap_file(), and write_relmap_file().
Referenced by CreateDatabaseUsingWalLog().
Oid RelationMapFilenumberToOid | ( | RelFileNumber | filenumber, |
bool | shared | ||
) |
Definition at line 218 of file relmapper.c.
References active_local_updates, active_shared_updates, i, InvalidOid, local_map, RelMapping::mapfilenumber, RelMapping::mapoid, RelMapFile::mappings, RelMapFile::num_mappings, and shared_map.
Referenced by RelidByRelfilenumber().
void RelationMapFinishBootstrap | ( | void | ) |
Definition at line 625 of file relmapper.c.
References active_local_updates, active_shared_updates, Assert, DatabasePath, InvalidOid, IsBootstrapProcessingMode, local_map, LW_EXCLUSIVE, LWLockAcquire(), LWLockRelease(), MyDatabaseId, MyDatabaseTableSpace, RelMapFile::num_mappings, pending_local_updates, pending_shared_updates, shared_map, and write_relmap_file().
Referenced by BootstrapModeMain().
void RelationMapInitialize | ( | void | ) |
Definition at line 651 of file relmapper.c.
References active_local_updates, active_shared_updates, local_map, RelMapFile::magic, RelMapFile::num_mappings, pending_local_updates, pending_shared_updates, and shared_map.
Referenced by RelationCacheInitialize().
void RelationMapInitializePhase2 | ( | void | ) |
Definition at line 671 of file relmapper.c.
References IsBootstrapProcessingMode, and load_relmap_file().
Referenced by RelationCacheInitializePhase2().
void RelationMapInitializePhase3 | ( | void | ) |
Definition at line 692 of file relmapper.c.
References IsBootstrapProcessingMode, and load_relmap_file().
Referenced by RelationCacheInitializePhase3().
void RelationMapInvalidate | ( | bool | shared | ) |
Definition at line 468 of file relmapper.c.
References load_relmap_file(), local_map, RelMapFile::magic, RELMAPPER_FILEMAGIC, and shared_map.
Referenced by LocalExecuteInvalidationMessage().
void RelationMapInvalidateAll | ( | void | ) |
Definition at line 490 of file relmapper.c.
References load_relmap_file(), local_map, RelMapFile::magic, RELMAPPER_FILEMAGIC, and shared_map.
Referenced by RelationCacheInvalidate().
RelFileNumber RelationMapOidToFilenumber | ( | Oid | relationId, |
bool | shared | ||
) |
Definition at line 165 of file relmapper.c.
References active_local_updates, active_shared_updates, i, InvalidRelFileNumber, local_map, RelMapping::mapfilenumber, RelMapping::mapoid, RelMapFile::mappings, RelMapFile::num_mappings, and shared_map.
Referenced by pg_relation_filenode(), pg_relation_filepath(), RelationInitPhysicalAddr(), and swap_relation_files().
RelFileNumber RelationMapOidToFilenumberForDatabase | ( | char * | dbpath, |
Oid | relationId | ||
) |
Definition at line 265 of file relmapper.c.
References ERROR, i, InvalidRelFileNumber, RelMapping::mapfilenumber, RelMapping::mapoid, RelMapFile::mappings, RelMapFile::num_mappings, and read_relmap_file().
Referenced by ScanSourceDatabasePgClass(), and ScanSourceDatabasePgClassTuple().
void RelationMapRemoveMapping | ( | Oid | relationId | ) |
Definition at line 438 of file relmapper.c.
References active_local_updates, elog, ERROR, i, RelMapping::mapoid, RelMapFile::mappings, and RelMapFile::num_mappings.
Referenced by finish_heap_swap().
void RelationMapUpdateMap | ( | Oid | relationId, |
RelFileNumber | fileNumber, | ||
bool | shared, | ||
bool | immediate | ||
) |
Definition at line 325 of file relmapper.c.
References active_local_updates, active_shared_updates, apply_map_update(), elog, ERROR, GetCurrentTransactionNestLevel(), IsBootstrapProcessingMode, IsInParallelMode(), local_map, pending_local_updates, pending_shared_updates, and shared_map.
Referenced by formrdesc(), RelationBuildLocalRelation(), RelationSetNewRelfilenumber(), and swap_relation_files().
void relmap_redo | ( | XLogReaderState * | record | ) |
Definition at line 1096 of file relmapper.c.
References Assert, xl_relmap_update::data, xl_relmap_update::dbid, elog, GetDatabasePath(), LW_EXCLUSIVE, LWLockAcquire(), LWLockRelease(), xl_relmap_update::nbytes, PANIC, pfree(), xl_relmap_update::tsid, write_relmap_file(), XLOG_RELMAP_UPDATE, XLogRecGetData, XLogRecGetInfo, and XLogRecHasAnyBlockRefs.
void RestoreRelationMap | ( | char * | startAddress | ) |
Definition at line 741 of file relmapper.c.
References SerializedActiveRelMaps::active_local_updates, active_local_updates, SerializedActiveRelMaps::active_shared_updates, active_shared_updates, elog, ERROR, RelMapFile::num_mappings, pending_local_updates, and pending_shared_updates.
Referenced by ParallelWorkerMain().
void SerializeRelationMap | ( | Size | maxSize, |
char * | startAddress | ||
) |
Definition at line 724 of file relmapper.c.
References SerializedActiveRelMaps::active_local_updates, active_local_updates, SerializedActiveRelMaps::active_shared_updates, active_shared_updates, Assert, and EstimateRelationMapSpace().
Referenced by InitializeParallelDSM().
|
static |
Definition at line 889 of file relmapper.c.
References Assert, CacheInvalidateRelmap(), CloseTransientFile(), COMP_CRC32C, RelMapFile::crc, crc, xl_relmap_update::dbid, RelFileLocator::dbOid, durable_rename(), elog, END_CRIT_SECTION, ereport, errcode_for_file_access(), errmsg(), ERROR, fd(), FIN_CRC32C, i, INIT_CRC32C, LW_EXCLUSIVE, LWLockHeldByMeInMode(), RelMapFile::magic, RelMapping::mapfilenumber, RelMapFile::mappings, MAX_MAPPINGS, MAXPGPATH, MinSizeOfRelmapUpdate, xl_relmap_update::nbytes, RelMapFile::num_mappings, OpenTransientFile(), PG_BINARY, pgstat_report_wait_end(), pgstat_report_wait_start(), RelationPreserveStorage(), RELMAPPER_FILEMAGIC, RELMAPPER_FILENAME, RELMAPPER_TEMP_FILENAME, RelFileLocator::relNumber, snprintf, RelFileLocator::spcOid, START_CRIT_SECTION, xl_relmap_update::tsid, write, XLOG_RELMAP_UPDATE, XLogBeginInsert(), XLogFlush(), XLogInsert(), and XLogRegisterData().
Referenced by perform_relmap_update(), RelationMapCopy(), RelationMapFinishBootstrap(), and relmap_redo().
|
static |
Definition at line 132 of file relmapper.c.
Referenced by AtCCI_RelationMap(), AtEOXact_RelationMap(), AtPrepare_RelationMap(), RelationMapFilenumberToOid(), RelationMapFinishBootstrap(), RelationMapInitialize(), RelationMapOidToFilenumber(), RelationMapRemoveMapping(), RelationMapUpdateMap(), RestoreRelationMap(), and SerializeRelationMap().
|
static |
Definition at line 131 of file relmapper.c.
Referenced by AtCCI_RelationMap(), AtEOXact_RelationMap(), AtPrepare_RelationMap(), RelationMapFilenumberToOid(), RelationMapFinishBootstrap(), RelationMapInitialize(), RelationMapOidToFilenumber(), RelationMapUpdateMap(), RestoreRelationMap(), and SerializeRelationMap().
|
static |
Definition at line 113 of file relmapper.c.
Referenced by load_relmap_file(), perform_relmap_update(), RelationMapFilenumberToOid(), RelationMapFinishBootstrap(), RelationMapInitialize(), RelationMapInvalidate(), RelationMapInvalidateAll(), RelationMapOidToFilenumber(), and RelationMapUpdateMap().
|
static |
Definition at line 134 of file relmapper.c.
Referenced by AtCCI_RelationMap(), AtEOXact_RelationMap(), AtPrepare_RelationMap(), RelationMapFinishBootstrap(), RelationMapInitialize(), RelationMapUpdateMap(), and RestoreRelationMap().
|
static |
Definition at line 133 of file relmapper.c.
Referenced by AtCCI_RelationMap(), AtEOXact_RelationMap(), AtPrepare_RelationMap(), RelationMapFinishBootstrap(), RelationMapInitialize(), RelationMapUpdateMap(), and RestoreRelationMap().
|
static |
Definition at line 112 of file relmapper.c.
Referenced by load_relmap_file(), perform_relmap_update(), RelationMapFilenumberToOid(), RelationMapFinishBootstrap(), RelationMapInitialize(), RelationMapInvalidate(), RelationMapInvalidateAll(), RelationMapOidToFilenumber(), and RelationMapUpdateMap().