|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
*
|
|
|
|
|
* syscache.h
|
|
|
|
|
* System catalog cache definitions.
|
|
|
|
|
*
|
|
|
|
|
* See also lsyscache.h, which provides convenience routines for
|
|
|
|
|
* common cache-lookup operations.
|
|
|
|
|
*
|
|
|
|
|
* Portions Copyright (c) 1996-2015, PostgreSQL Global Development Group
|
|
|
|
|
* Portions Copyright (c) 1994, Regents of the University of California
|
|
|
|
|
*
|
|
|
|
|
* src/include/utils/syscache.h
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
#ifndef SYSCACHE_H
|
|
|
|
|
#define SYSCACHE_H
|
|
|
|
|
|
|
|
|
|
#include "access/attnum.h"
|
|
|
|
|
#include "access/htup.h"
|
|
|
|
|
/* we purposedly do not include utils/catcache.h here */
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
* SysCache identifiers.
|
|
|
|
|
*
|
|
|
|
|
* The order of these identifiers must match the order
|
|
|
|
|
* of the entries in the array cacheinfo[] in syscache.c.
|
|
|
|
|
* Keep them in alphabetical order (renumbering only costs a
|
|
|
|
|
* backend rebuild).
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
enum SysCacheIdentifier
|
|
|
|
|
{
|
|
|
|
|
AGGFNOID = 0,
|
|
|
|
|
AMNAME,
|
|
|
|
|
AMOID,
|
|
|
|
|
AMOPOPID,
|
|
|
|
|
AMOPSTRATEGY,
|
|
|
|
|
AMPROCNUM,
|
|
|
|
|
ATTNAME,
|
|
|
|
|
ATTNUM,
|
|
|
|
|
AUTHMEMMEMROLE,
|
|
|
|
|
AUTHMEMROLEMEM,
|
|
|
|
|
AUTHNAME,
|
|
|
|
|
AUTHOID,
|
|
|
|
|
CASTSOURCETARGET,
|
|
|
|
|
CLAAMNAMENSP,
|
|
|
|
|
CLAOID,
|
|
|
|
|
COLLNAMEENCNSP,
|
|
|
|
|
COLLOID,
|
|
|
|
|
CONDEFAULT,
|
|
|
|
|
CONNAMENSP,
|
|
|
|
|
CONSTROID,
|
|
|
|
|
CONVOID,
|
|
|
|
|
DATABASEOID,
|
|
|
|
|
DEFACLROLENSPOBJ,
|
|
|
|
|
ENUMOID,
|
|
|
|
|
ENUMTYPOIDNAME,
|
|
|
|
|
EVENTTRIGGERNAME,
|
|
|
|
|
EVENTTRIGGEROID,
|
|
|
|
|
FOREIGNDATAWRAPPERNAME,
|
|
|
|
|
FOREIGNDATAWRAPPEROID,
|
|
|
|
|
FOREIGNSERVERNAME,
|
|
|
|
|
FOREIGNSERVEROID,
|
|
|
|
|
FOREIGNTABLEREL,
|
|
|
|
|
INDEXRELID,
|
|
|
|
|
LANGNAME,
|
|
|
|
|
LANGOID,
|
|
|
|
|
NAMESPACENAME,
|
|
|
|
|
NAMESPACEOID,
|
|
|
|
|
OPERNAMENSP,
|
|
|
|
|
OPEROID,
|
|
|
|
|
OPFAMILYAMNAMENSP,
|
|
|
|
|
OPFAMILYOID,
|
|
|
|
|
PROCNAMEARGSNSP,
|
|
|
|
|
PROCOID,
|
|
|
|
|
RANGETYPE,
|
|
|
|
|
RELNAMENSP,
|
|
|
|
|
RELOID,
|
Introduce replication progress tracking infrastructure.
When implementing a replication solution ontop of logical decoding, two
related problems exist:
* How to safely keep track of replication progress
* How to change replication behavior, based on the origin of a row;
e.g. to avoid loops in bi-directional replication setups
The solution to these problems, as implemented here, consist out of
three parts:
1) 'replication origins', which identify nodes in a replication setup.
2) 'replication progress tracking', which remembers, for each
replication origin, how far replay has progressed in a efficient and
crash safe manner.
3) The ability to filter out changes performed on the behest of a
replication origin during logical decoding; this allows complex
replication topologies. E.g. by filtering all replayed changes out.
Most of this could also be implemented in "userspace", e.g. by inserting
additional rows contain origin information, but that ends up being much
less efficient and more complicated. We don't want to require various
replication solutions to reimplement logic for this independently. The
infrastructure is intended to be generic enough to be reusable.
This infrastructure also replaces the 'nodeid' infrastructure of commit
timestamps. It is intended to provide all the former capabilities,
except that there's only 2^16 different origins; but now they integrate
with logical decoding. Additionally more functionality is accessible via
SQL. Since the commit timestamp infrastructure has also been introduced
in 9.5 (commit 73c986add) changing the API is not a problem.
For now the number of origins for which the replication progress can be
tracked simultaneously is determined by the max_replication_slots
GUC. That GUC is not a perfect match to configure this, but there
doesn't seem to be sufficient reason to introduce a separate new one.
Bumps both catversion and wal page magic.
Author: Andres Freund, with contributions from Petr Jelinek and Craig Ringer
Reviewed-By: Heikki Linnakangas, Petr Jelinek, Robert Haas, Steve Singer
Discussion: 20150216002155.GI15326@awork2.anarazel.de,
20140923182422.GA15776@alap3.anarazel.de,
20131114172632.GE7522@alap2.anarazel.de
11 years ago
|
|
|
REPLORIGIDENT,
|
|
|
|
|
REPLORIGNAME,
|
|
|
|
|
RULERELNAME,
|
|
|
|
|
STATRELATTINH,
|
|
|
|
|
TABLESAMPLEMETHODNAME,
|
|
|
|
|
TABLESAMPLEMETHODOID,
|
|
|
|
|
TABLESPACEOID,
|
|
|
|
|
TRFOID,
|
|
|
|
|
TRFTYPELANG,
|
|
|
|
|
TSCONFIGMAP,
|
|
|
|
|
TSCONFIGNAMENSP,
|
|
|
|
|
TSCONFIGOID,
|
|
|
|
|
TSDICTNAMENSP,
|
|
|
|
|
TSDICTOID,
|
|
|
|
|
TSPARSERNAMENSP,
|
|
|
|
|
TSPARSEROID,
|
|
|
|
|
TSTEMPLATENAMENSP,
|
|
|
|
|
TSTEMPLATEOID,
|
|
|
|
|
TYPENAMENSP,
|
|
|
|
|
TYPEOID,
|
|
|
|
|
USERMAPPINGOID,
|
|
|
|
|
USERMAPPINGUSERSERVER
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
extern void InitCatalogCache(void);
|
|
|
|
|
extern void InitCatalogCachePhase2(void);
|
|
|
|
|
|
|
|
|
|
extern HeapTuple SearchSysCache(int cacheId,
|
|
|
|
|
Datum key1, Datum key2, Datum key3, Datum key4);
|
|
|
|
|
extern void ReleaseSysCache(HeapTuple tuple);
|
|
|
|
|
|
|
|
|
|
/* convenience routines */
|
|
|
|
|
extern HeapTuple SearchSysCacheCopy(int cacheId,
|
|
|
|
|
Datum key1, Datum key2, Datum key3, Datum key4);
|
|
|
|
|
extern bool SearchSysCacheExists(int cacheId,
|
|
|
|
|
Datum key1, Datum key2, Datum key3, Datum key4);
|
|
|
|
|
extern Oid GetSysCacheOid(int cacheId,
|
|
|
|
|
Datum key1, Datum key2, Datum key3, Datum key4);
|
|
|
|
|
|
|
|
|
|
extern HeapTuple SearchSysCacheAttName(Oid relid, const char *attname);
|
|
|
|
|
extern HeapTuple SearchSysCacheCopyAttName(Oid relid, const char *attname);
|
|
|
|
|
extern bool SearchSysCacheExistsAttName(Oid relid, const char *attname);
|
|
|
|
|
|
|
|
|
|
extern Datum SysCacheGetAttr(int cacheId, HeapTuple tup,
|
|
|
|
|
AttrNumber attributeNumber, bool *isNull);
|
|
|
|
|
|
|
|
|
|
extern uint32 GetSysCacheHashValue(int cacheId,
|
|
|
|
|
Datum key1, Datum key2, Datum key3, Datum key4);
|
|
|
|
|
|
|
|
|
|
/* list-search interface. Users of this must import catcache.h too */
|
|
|
|
|
struct catclist;
|
|
|
|
|
extern struct catclist *SearchSysCacheList(int cacheId, int nkeys,
|
|
|
|
|
Datum key1, Datum key2, Datum key3, Datum key4);
|
|
|
|
|
|
Use an MVCC snapshot, rather than SnapshotNow, for catalog scans.
SnapshotNow scans have the undesirable property that, in the face of
concurrent updates, the scan can fail to see either the old or the new
versions of the row. In many cases, we work around this by requiring
DDL operations to hold AccessExclusiveLock on the object being
modified; in some cases, the existing locking is inadequate and random
failures occur as a result. This commit doesn't change anything
related to locking, but will hopefully pave the way to allowing lock
strength reductions in the future.
The major issue has held us back from making this change in the past
is that taking an MVCC snapshot is significantly more expensive than
using a static special snapshot such as SnapshotNow. However, testing
of various worst-case scenarios reveals that this problem is not
severe except under fairly extreme workloads. To mitigate those
problems, we avoid retaking the MVCC snapshot for each new scan;
instead, we take a new snapshot only when invalidation messages have
been processed. The catcache machinery already requires that
invalidation messages be sent before releasing the related heavyweight
lock; else other backends might rely on locally-cached data rather
than scanning the catalog at all. Thus, making snapshot reuse
dependent on the same guarantees shouldn't break anything that wasn't
already subtly broken.
Patch by me. Review by Michael Paquier and Andres Freund.
13 years ago
|
|
|
extern bool RelationInvalidatesSnapshotsOnly(Oid);
|
|
|
|
|
extern bool RelationHasSysCache(Oid);
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
* The use of the macros below rather than direct calls to the corresponding
|
|
|
|
|
* functions is encouraged, as it insulates the caller from changes in the
|
|
|
|
|
* maximum number of keys.
|
|
|
|
|
*/
|
|
|
|
|
#define SearchSysCache1(cacheId, key1) \
|
|
|
|
|
SearchSysCache(cacheId, key1, 0, 0, 0)
|
|
|
|
|
#define SearchSysCache2(cacheId, key1, key2) \
|
|
|
|
|
SearchSysCache(cacheId, key1, key2, 0, 0)
|
|
|
|
|
#define SearchSysCache3(cacheId, key1, key2, key3) \
|
|
|
|
|
SearchSysCache(cacheId, key1, key2, key3, 0)
|
|
|
|
|
#define SearchSysCache4(cacheId, key1, key2, key3, key4) \
|
|
|
|
|
SearchSysCache(cacheId, key1, key2, key3, key4)
|
|
|
|
|
|
|
|
|
|
#define SearchSysCacheCopy1(cacheId, key1) \
|
|
|
|
|
SearchSysCacheCopy(cacheId, key1, 0, 0, 0)
|
|
|
|
|
#define SearchSysCacheCopy2(cacheId, key1, key2) \
|
|
|
|
|
SearchSysCacheCopy(cacheId, key1, key2, 0, 0)
|
|
|
|
|
#define SearchSysCacheCopy3(cacheId, key1, key2, key3) \
|
|
|
|
|
SearchSysCacheCopy(cacheId, key1, key2, key3, 0)
|
|
|
|
|
#define SearchSysCacheCopy4(cacheId, key1, key2, key3, key4) \
|
|
|
|
|
SearchSysCacheCopy(cacheId, key1, key2, key3, key4)
|
|
|
|
|
|
|
|
|
|
#define SearchSysCacheExists1(cacheId, key1) \
|
|
|
|
|
SearchSysCacheExists(cacheId, key1, 0, 0, 0)
|
|
|
|
|
#define SearchSysCacheExists2(cacheId, key1, key2) \
|
|
|
|
|
SearchSysCacheExists(cacheId, key1, key2, 0, 0)
|
|
|
|
|
#define SearchSysCacheExists3(cacheId, key1, key2, key3) \
|
|
|
|
|
SearchSysCacheExists(cacheId, key1, key2, key3, 0)
|
|
|
|
|
#define SearchSysCacheExists4(cacheId, key1, key2, key3, key4) \
|
|
|
|
|
SearchSysCacheExists(cacheId, key1, key2, key3, key4)
|
|
|
|
|
|
|
|
|
|
#define GetSysCacheOid1(cacheId, key1) \
|
|
|
|
|
GetSysCacheOid(cacheId, key1, 0, 0, 0)
|
|
|
|
|
#define GetSysCacheOid2(cacheId, key1, key2) \
|
|
|
|
|
GetSysCacheOid(cacheId, key1, key2, 0, 0)
|
|
|
|
|
#define GetSysCacheOid3(cacheId, key1, key2, key3) \
|
|
|
|
|
GetSysCacheOid(cacheId, key1, key2, key3, 0)
|
|
|
|
|
#define GetSysCacheOid4(cacheId, key1, key2, key3, key4) \
|
|
|
|
|
GetSysCacheOid(cacheId, key1, key2, key3, key4)
|
|
|
|
|
|
|
|
|
|
#define GetSysCacheHashValue1(cacheId, key1) \
|
|
|
|
|
GetSysCacheHashValue(cacheId, key1, 0, 0, 0)
|
|
|
|
|
#define GetSysCacheHashValue2(cacheId, key1, key2) \
|
|
|
|
|
GetSysCacheHashValue(cacheId, key1, key2, 0, 0)
|
|
|
|
|
#define GetSysCacheHashValue3(cacheId, key1, key2, key3) \
|
|
|
|
|
GetSysCacheHashValue(cacheId, key1, key2, key3, 0)
|
|
|
|
|
#define GetSysCacheHashValue4(cacheId, key1, key2, key3, key4) \
|
|
|
|
|
GetSysCacheHashValue(cacheId, key1, key2, key3, key4)
|
|
|
|
|
|
|
|
|
|
#define SearchSysCacheList1(cacheId, key1) \
|
|
|
|
|
SearchSysCacheList(cacheId, 1, key1, 0, 0, 0)
|
|
|
|
|
#define SearchSysCacheList2(cacheId, key1, key2) \
|
|
|
|
|
SearchSysCacheList(cacheId, 2, key1, key2, 0, 0)
|
|
|
|
|
#define SearchSysCacheList3(cacheId, key1, key2, key3) \
|
|
|
|
|
SearchSysCacheList(cacheId, 3, key1, key2, key3, 0)
|
|
|
|
|
#define SearchSysCacheList4(cacheId, key1, key2, key3, key4) \
|
|
|
|
|
SearchSysCacheList(cacheId, 4, key1, key2, key3, key4)
|
|
|
|
|
|
|
|
|
|
#define ReleaseSysCacheList(x) ReleaseCatCacheList(x)
|
|
|
|
|
|
|
|
|
|
#endif /* SYSCACHE_H */
|