PostgreSQL Source Code git master
Data Structures | Macros | Typedefs | Functions
standbydefs.h File Reference
#include "access/xlogreader.h"
#include "lib/stringinfo.h"
#include "storage/lockdefs.h"
#include "storage/sinval.h"
Include dependency graph for standbydefs.h:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures

struct   xl_standby_locks
 
struct   xl_running_xacts
 
struct   xl_invalidations
 

Macros

#define  XLOG_STANDBY_LOCK   0x00
 
#define  XLOG_RUNNING_XACTS   0x10
 
#define  XLOG_INVALIDATIONS   0x20
 
#define  MinSizeOfInvalidations   offsetof(xl_invalidations, msgs)
 

Typedefs

typedef struct xl_standby_locks  xl_standby_locks
 
typedef struct xl_running_xacts  xl_running_xacts
 
typedef struct xl_invalidations  xl_invalidations
 

Functions

void  standby_redo (XLogReaderState *record)
 
void  standby_desc (StringInfo buf, XLogReaderState *record)
 
const char *  standby_identify (uint8 info)
 
void  standby_desc_invalidations (StringInfo buf, int nmsgs, SharedInvalidationMessage *msgs, Oid dbId, Oid tsId, bool relcacheInitFileInval)
 

Macro Definition Documentation

◆ MinSizeOfInvalidations

#define MinSizeOfInvalidations   offsetof(xl_invalidations, msgs)

Definition at line 72 of file standbydefs.h.

◆ XLOG_INVALIDATIONS

#define XLOG_INVALIDATIONS   0x20

Definition at line 36 of file standbydefs.h.

◆ XLOG_RUNNING_XACTS

#define XLOG_RUNNING_XACTS   0x10

Definition at line 35 of file standbydefs.h.

◆ XLOG_STANDBY_LOCK

#define XLOG_STANDBY_LOCK   0x00

Definition at line 34 of file standbydefs.h.

Typedef Documentation

◆ xl_invalidations

typedef struct xl_invalidations xl_invalidations

◆ xl_running_xacts

typedef struct xl_running_xacts xl_running_xacts

◆ xl_standby_locks

typedef struct xl_standby_locks xl_standby_locks

Function Documentation

◆ standby_desc()

void standby_desc ( StringInfo  buf,
XLogReaderState *  record 
)

Definition at line 47 of file standbydesc.c.

48{
49 char *rec = XLogRecGetData(record);
50 uint8 info = XLogRecGetInfo(record) & ~XLR_INFO_MASK;
51
52 if (info == XLOG_STANDBY_LOCK)
53 {
54 xl_standby_locks *xlrec = (xl_standby_locks *) rec;
55 int i;
56
57 for (i = 0; i < xlrec->nlocks; i++)
58 appendStringInfo(buf, "xid %u db %u rel %u ",
59 xlrec->locks[i].xid, xlrec->locks[i].dbOid,
60 xlrec->locks[i].relOid);
61 }
62 else if (info == XLOG_RUNNING_XACTS)
63 {
64 xl_running_xacts *xlrec = (xl_running_xacts *) rec;
65
67 }
68 else if (info == XLOG_INVALIDATIONS)
69 {
70 xl_invalidations *xlrec = (xl_invalidations *) rec;
71
73 xlrec->dbId, xlrec->tsId,
75 }
76}
uint8_t uint8
Definition: c.h:536
i
int i
Definition: isn.c:77
static char * buf
Definition: pg_test_fsync.c:72
#define XLOG_INVALIDATIONS
Definition: standbydefs.h:36
#define XLOG_STANDBY_LOCK
Definition: standbydefs.h:34
#define XLOG_RUNNING_XACTS
Definition: standbydefs.h:35
void standby_desc_invalidations(StringInfo buf, int nmsgs, SharedInvalidationMessage *msgs, Oid dbId, Oid tsId, bool relcacheInitFileInval)
Definition: standbydesc.c:101
static void standby_desc_running_xacts(StringInfo buf, xl_running_xacts *xlrec)
Definition: standbydesc.c:20
void appendStringInfo(StringInfo str, const char *fmt,...)
Definition: stringinfo.c:145
Definition: standbydefs.h:64
int nmsgs
Definition: standbydefs.h:68
SharedInvalidationMessage msgs[FLEXIBLE_ARRAY_MEMBER]
Definition: standbydefs.h:69
bool relcacheInitFileInval
Definition: standbydefs.h:67
Oid dbId
Definition: standbydefs.h:65
Oid tsId
Definition: standbydefs.h:66
Definition: standbydefs.h:48
Oid relOid
Definition: lockdefs.h:55
Oid dbOid
Definition: lockdefs.h:54
TransactionId xid
Definition: lockdefs.h:53
Definition: standbydefs.h:39
xl_standby_lock locks[FLEXIBLE_ARRAY_MEMBER]
Definition: standbydefs.h:41
int nlocks
Definition: standbydefs.h:40
#define XLogRecGetInfo(decoder)
Definition: xlogreader.h:410
#define XLogRecGetData(decoder)
Definition: xlogreader.h:415

References appendStringInfo(), buf, xl_invalidations::dbId, xl_standby_lock::dbOid, i, xl_standby_locks::locks, xl_invalidations::msgs, xl_standby_locks::nlocks, xl_invalidations::nmsgs, xl_invalidations::relcacheInitFileInval, xl_standby_lock::relOid, standby_desc_invalidations(), standby_desc_running_xacts(), xl_invalidations::tsId, xl_standby_lock::xid, XLOG_INVALIDATIONS, XLOG_RUNNING_XACTS, XLOG_STANDBY_LOCK, XLogRecGetData, and XLogRecGetInfo.

◆ standby_desc_invalidations()

void standby_desc_invalidations ( StringInfo  buf,
int  nmsgs,
SharedInvalidationMessage *  msgs,
Oid  dbId,
Oid  tsId,
bool  relcacheInitFileInval 
)

Definition at line 101 of file standbydesc.c.

105{
106 int i;
107
108 /* Do nothing if there are no invalidation messages */
109 if (nmsgs <= 0)
110 return;
111
112 if (relcacheInitFileInval)
113 appendStringInfo(buf, "; relcache init file inval dbid %u tsid %u",
114 dbId, tsId);
115
116 appendStringInfoString(buf, "; inval msgs:");
117 for (i = 0; i < nmsgs; i++)
118 {
119 SharedInvalidationMessage *msg = &msgs[i];
120
121 if (msg->id >= 0)
122 appendStringInfo(buf, " catcache %d", msg->id);
123 else if (msg->id == SHAREDINVALCATALOG_ID)
124 appendStringInfo(buf, " catalog %u", msg->cat.catId);
125 else if (msg->id == SHAREDINVALRELCACHE_ID)
126 appendStringInfo(buf, " relcache %u", msg->rc.relId);
127 /* not expected, but print something anyway */
128 else if (msg->id == SHAREDINVALSMGR_ID)
129 appendStringInfoString(buf, " smgr");
130 /* not expected, but print something anyway */
131 else if (msg->id == SHAREDINVALRELMAP_ID)
132 appendStringInfo(buf, " relmap db %u", msg->rm.dbId);
133 else if (msg->id == SHAREDINVALSNAPSHOT_ID)
134 appendStringInfo(buf, " snapshot %u", msg->sn.relId);
135 else if (msg->id == SHAREDINVALRELSYNC_ID)
136 appendStringInfo(buf, " relsync %u", msg->rs.relid);
137 else
138 appendStringInfo(buf, " unrecognized id %d", msg->id);
139 }
140}
#define SHAREDINVALCATALOG_ID
Definition: sinval.h:68
#define SHAREDINVALRELSYNC_ID
Definition: sinval.h:114
#define SHAREDINVALSMGR_ID
Definition: sinval.h:86
#define SHAREDINVALSNAPSHOT_ID
Definition: sinval.h:105
#define SHAREDINVALRELCACHE_ID
Definition: sinval.h:77
#define SHAREDINVALRELMAP_ID
Definition: sinval.h:97
void appendStringInfoString(StringInfo str, const char *s)
Definition: stringinfo.c:230
SharedInvalRelcacheMsg rc
Definition: sinval.h:129
SharedInvalCatalogMsg cat
Definition: sinval.h:128
SharedInvalRelSyncMsg rs
Definition: sinval.h:133
SharedInvalSnapshotMsg sn
Definition: sinval.h:132
SharedInvalRelmapMsg rm
Definition: sinval.h:131

References appendStringInfo(), appendStringInfoString(), buf, SharedInvalidationMessage::cat, SharedInvalCatalogMsg::catId, SharedInvalRelmapMsg::dbId, i, SharedInvalidationMessage::id, SharedInvalidationMessage::rc, SharedInvalRelcacheMsg::relId, SharedInvalSnapshotMsg::relId, SharedInvalRelSyncMsg::relid, SharedInvalidationMessage::rm, SharedInvalidationMessage::rs, SHAREDINVALCATALOG_ID, SHAREDINVALRELCACHE_ID, SHAREDINVALRELMAP_ID, SHAREDINVALRELSYNC_ID, SHAREDINVALSMGR_ID, SHAREDINVALSNAPSHOT_ID, and SharedInvalidationMessage::sn.

Referenced by heap_desc(), standby_desc(), xact_desc(), xact_desc_commit(), and xact_desc_prepare().

◆ standby_identify()

const char * standby_identify ( uint8  info )

Definition at line 79 of file standbydesc.c.

80{
81 const char *id = NULL;
82
83 switch (info & ~XLR_INFO_MASK)
84 {
86 id = "LOCK";
87 break;
89 id = "RUNNING_XACTS";
90 break;
92 id = "INVALIDATIONS";
93 break;
94 }
95
96 return id;
97}
#define XLR_INFO_MASK
Definition: xlogrecord.h:62

References XLOG_INVALIDATIONS, XLOG_RUNNING_XACTS, XLOG_STANDBY_LOCK, and XLR_INFO_MASK.

◆ standby_redo()

void standby_redo ( XLogReaderState *  record )

Definition at line 1163 of file standby.c.

1164{
1165 uint8 info = XLogRecGetInfo(record) & ~XLR_INFO_MASK;
1166
1167 /* Backup blocks are not used in standby records */
1169
1170 /* Do nothing if we're not in hot standby mode */
1172 return;
1173
1174 if (info == XLOG_STANDBY_LOCK)
1175 {
1177 int i;
1178
1179 for (i = 0; i < xlrec->nlocks; i++)
1181 xlrec->locks[i].dbOid,
1182 xlrec->locks[i].relOid);
1183 }
1184 else if (info == XLOG_RUNNING_XACTS)
1185 {
1188
1189 running.xcnt = xlrec->xcnt;
1190 running.subxcnt = xlrec->subxcnt;
1192 running.nextXid = xlrec->nextXid;
1193 running.latestCompletedXid = xlrec->latestCompletedXid;
1194 running.oldestRunningXid = xlrec->oldestRunningXid;
1195 running.xids = xlrec->xids;
1196
1198
1199 /*
1200 * The startup process currently has no convenient way to schedule
1201 * stats to be reported. XLOG_RUNNING_XACTS records issued at a
1202 * regular cadence, making this a convenient location to report stats.
1203 * While these records aren't generated with wal_level=minimal, stats
1204 * also cannot be accessed during WAL replay.
1205 */
1206 pgstat_report_stat(true);
1207 }
1208 else if (info == XLOG_INVALIDATIONS)
1209 {
1211
1213 xlrec->nmsgs,
1214 xlrec->relcacheInitFileInval,
1215 xlrec->dbId,
1216 xlrec->tsId);
1217 }
1218 else
1219 elog(PANIC, "standby_redo: unknown op code %u", info);
1220}
#define PANIC
Definition: elog.h:42
#define elog(elevel,...)
Definition: elog.h:226
Assert(PointerIsAligned(start, uint64))
void ProcessCommittedInvalidationMessages(SharedInvalidationMessage *msgs, int nmsgs, bool RelcacheInitFileInval, Oid dbid, Oid tsid)
Definition: inval.c:1135
long pgstat_report_stat(bool force)
Definition: pgstat.c:692
void ProcArrayApplyRecoveryInfo(RunningTransactions running)
Definition: procarray.c:1054
void StandbyAcquireAccessExclusiveLock(TransactionId xid, Oid dbOid, Oid relOid)
Definition: standby.c:986
@ SUBXIDS_MISSING
Definition: standby.h:81
@ SUBXIDS_IN_ARRAY
Definition: standby.h:80
TransactionId oldestRunningXid
Definition: standby.h:92
TransactionId nextXid
Definition: standby.h:91
TransactionId latestCompletedXid
Definition: standby.h:95
subxids_array_status subxid_status
Definition: standby.h:90
TransactionId * xids
Definition: standby.h:97
int subxcnt
Definition: standbydefs.h:50
TransactionId latestCompletedXid
Definition: standbydefs.h:54
TransactionId oldestRunningXid
Definition: standbydefs.h:53
TransactionId xids[FLEXIBLE_ARRAY_MEMBER]
Definition: standbydefs.h:56
bool subxid_overflow
Definition: standbydefs.h:51
int xcnt
Definition: standbydefs.h:49
TransactionId nextXid
Definition: standbydefs.h:52
#define XLogRecHasAnyBlockRefs(decoder)
Definition: xlogreader.h:417
HotStandbyState standbyState
Definition: xlogutils.c:53
@ STANDBY_DISABLED
Definition: xlogutils.h:52

References Assert(), xl_invalidations::dbId, xl_standby_lock::dbOid, elog, i, RunningTransactionsData::latestCompletedXid, xl_running_xacts::latestCompletedXid, xl_standby_locks::locks, xl_invalidations::msgs, RunningTransactionsData::nextXid, xl_running_xacts::nextXid, xl_standby_locks::nlocks, xl_invalidations::nmsgs, RunningTransactionsData::oldestRunningXid, xl_running_xacts::oldestRunningXid, PANIC, pgstat_report_stat(), ProcArrayApplyRecoveryInfo(), ProcessCommittedInvalidationMessages(), xl_invalidations::relcacheInitFileInval, xl_standby_lock::relOid, STANDBY_DISABLED, StandbyAcquireAccessExclusiveLock(), standbyState, RunningTransactionsData::subxcnt, xl_running_xacts::subxcnt, xl_running_xacts::subxid_overflow, RunningTransactionsData::subxid_status, SUBXIDS_IN_ARRAY, SUBXIDS_MISSING, xl_invalidations::tsId, RunningTransactionsData::xcnt, xl_running_xacts::xcnt, xl_standby_lock::xid, RunningTransactionsData::xids, xl_running_xacts::xids, XLOG_INVALIDATIONS, XLOG_RUNNING_XACTS, XLOG_STANDBY_LOCK, XLogRecGetData, XLogRecGetInfo, and XLogRecHasAnyBlockRefs.

AltStyle によって変換されたページ (->オリジナル) /