#include "postgres.h"
#include "access/transam.h"
#include "access/xact.h"
#include "replication/origin.h"
#include "storage/sinval.h"
#include "storage/standbydefs.h"
#include "utils/timestamp.h"

Include dependency graph for xactdesc.c:

Functions
void	ParseCommitRecord (uint8 info, xl_xact_commit xlrec, xl_xact_parsed_commit parsed)

void	ParseAbortRecord (uint8 info, xl_xact_abort xlrec, xl_xact_parsed_abort parsed)

void	ParsePrepareRecord (uint8 info, xl_xact_prepare xlrec, xl_xact_parsed_prepare parsed)

static void	xact_desc_relations (StringInfo buf, char label, int nrels, RelFileLocator xlocators)

static void	xact_desc_subxacts (StringInfo buf, int nsubxacts, TransactionId *subxacts)

static void	xact_desc_stats (StringInfo buf, const char label, int ndropped, xl_xact_stats_item dropped_stats)

static void	xact_desc_commit (StringInfo buf, uint8 info, xl_xact_commit *xlrec, RepOriginId origin_id)

static void	xact_desc_abort (StringInfo buf, uint8 info, xl_xact_abort *xlrec, RepOriginId origin_id)

static void	xact_desc_prepare (StringInfo buf, uint8 info, xl_xact_prepare *xlrec, RepOriginId origin_id)

static void	xact_desc_assignment (StringInfo buf, xl_xact_assignment *xlrec)

void	xact_desc (StringInfo buf, XLogReaderState *record)

const char *	xact_identify (uint8 info)

Function Documentation

◆ ParseAbortRecord()

void ParseAbortRecord	(	uint8	info,
		xl_xact_abort *	xlrec,
		xl_xact_parsed_abort *	parsed
	)

Definition at line 141 of file xactdesc.c.

 {
     char       *data = ((char *) xlrec) + MinSizeOfXactAbort;
  
     memset(parsed, 0, sizeof(*parsed));
  
     parsed->xinfo = 0;          /* default, if no XLOG_XACT_HAS_INFO is
                                  * present */
  
     parsed->xact_time = xlrec->xact_time;
  
     if (info & XLOG_XACT_HAS_INFO)
     {
         xl_xact_xinfo *xl_xinfo = (xl_xact_xinfo *) data;
  
         parsed->xinfo = xl_xinfo->xinfo;
  
         data += sizeof(xl_xact_xinfo);
     }
  
     if (parsed->xinfo & XACT_XINFO_HAS_DBINFO)
     {
         xl_xact_dbinfo *xl_dbinfo = (xl_xact_dbinfo *) data;
  
         parsed->dbId = xl_dbinfo->dbId;
         parsed->tsId = xl_dbinfo->tsId;
  
         data += sizeof(xl_xact_dbinfo);
     }
  
     if (parsed->xinfo & XACT_XINFO_HAS_SUBXACTS)
     {
         xl_xact_subxacts *xl_subxacts = (xl_xact_subxacts *) data;
  
         parsed->nsubxacts = xl_subxacts->nsubxacts;
         parsed->subxacts = xl_subxacts->subxacts;
  
         data += MinSizeOfXactSubxacts;
         data += parsed->nsubxacts * sizeof(TransactionId);
     }
  
     if (parsed->xinfo & XACT_XINFO_HAS_RELFILELOCATORS)
     {
         xl_xact_relfilelocators *xl_rellocator = (xl_xact_relfilelocators *) data;
  
         parsed->nrels = xl_rellocator->nrels;
         parsed->xlocators = xl_rellocator->xlocators;
  
         data += MinSizeOfXactRelfileLocators;
         data += xl_rellocator->nrels * sizeof(RelFileLocator);
     }
  
     if (parsed->xinfo & XACT_XINFO_HAS_DROPPED_STATS)
     {
         xl_xact_stats_items *xl_drops = (xl_xact_stats_items *) data;
  
         parsed->nstats = xl_drops->nitems;
         parsed->stats = xl_drops->items;
  
         data += MinSizeOfXactStatsItems;
         data += xl_drops->nitems * sizeof(xl_xact_stats_item);
     }
  
     if (parsed->xinfo & XACT_XINFO_HAS_TWOPHASE)
     {
         xl_xact_twophase *xl_twophase = (xl_xact_twophase *) data;
  
         parsed->twophase_xid = xl_twophase->xid;
  
         data += sizeof(xl_xact_twophase);
  
         if (parsed->xinfo & XACT_XINFO_HAS_GID)
         {
             strlcpy(parsed->twophase_gid, data, sizeof(parsed->twophase_gid));
             data += strlen(data) + 1;
         }
     }
  
     /* Note: no alignment is guaranteed after this point */
  
     if (parsed->xinfo & XACT_XINFO_HAS_ORIGIN)
     {
         xl_xact_origin xl_origin;
  
         /* no alignment is guaranteed, so copy onto stack */
         memcpy(&xl_origin, data, sizeof(xl_origin));
  
         parsed->origin_lsn = xl_origin.origin_lsn;
         parsed->origin_timestamp = xl_origin.origin_timestamp;
  
         data += sizeof(xl_xact_origin);
     }
 }

Referenced by recoveryStopsAfter(), recoveryStopsBefore(), SummarizeXactRecord(), xact_decode(), xact_desc_abort(), and xact_redo().

◆ ParseCommitRecord()

void ParseCommitRecord	(	uint8	info,
		xl_xact_commit *	xlrec,
		xl_xact_parsed_commit *	parsed
	)

Definition at line 35 of file xactdesc.c.

 {
     char       *data = ((char *) xlrec) + MinSizeOfXactCommit;
  
     memset(parsed, 0, sizeof(*parsed));
  
     parsed->xinfo = 0;          /* default, if no XLOG_XACT_HAS_INFO is
                                  * present */
  
     parsed->xact_time = xlrec->xact_time;
  
     if (info & XLOG_XACT_HAS_INFO)
     {
         xl_xact_xinfo *xl_xinfo = (xl_xact_xinfo *) data;
  
         parsed->xinfo = xl_xinfo->xinfo;
  
         data += sizeof(xl_xact_xinfo);
     }
  
     if (parsed->xinfo & XACT_XINFO_HAS_DBINFO)
     {
         xl_xact_dbinfo *xl_dbinfo = (xl_xact_dbinfo *) data;
  
         parsed->dbId = xl_dbinfo->dbId;
         parsed->tsId = xl_dbinfo->tsId;
  
         data += sizeof(xl_xact_dbinfo);
     }
  
     if (parsed->xinfo & XACT_XINFO_HAS_SUBXACTS)
     {
         xl_xact_subxacts *xl_subxacts = (xl_xact_subxacts *) data;
  
         parsed->nsubxacts = xl_subxacts->nsubxacts;
         parsed->subxacts = xl_subxacts->subxacts;
  
         data += MinSizeOfXactSubxacts;
         data += parsed->nsubxacts * sizeof(TransactionId);
     }
  
     if (parsed->xinfo & XACT_XINFO_HAS_RELFILELOCATORS)
     {
         xl_xact_relfilelocators *xl_rellocators = (xl_xact_relfilelocators *) data;
  
         parsed->nrels = xl_rellocators->nrels;
         parsed->xlocators = xl_rellocators->xlocators;
  
         data += MinSizeOfXactRelfileLocators;
         data += xl_rellocators->nrels * sizeof(RelFileLocator);
     }
  
     if (parsed->xinfo & XACT_XINFO_HAS_DROPPED_STATS)
     {
         xl_xact_stats_items *xl_drops = (xl_xact_stats_items *) data;
  
         parsed->nstats = xl_drops->nitems;
         parsed->stats = xl_drops->items;
  
         data += MinSizeOfXactStatsItems;
         data += xl_drops->nitems * sizeof(xl_xact_stats_item);
     }
  
     if (parsed->xinfo & XACT_XINFO_HAS_INVALS)
     {
         xl_xact_invals *xl_invals = (xl_xact_invals *) data;
  
         parsed->nmsgs = xl_invals->nmsgs;
         parsed->msgs = xl_invals->msgs;
  
         data += MinSizeOfXactInvals;
         data += xl_invals->nmsgs * sizeof(SharedInvalidationMessage);
     }
  
     if (parsed->xinfo & XACT_XINFO_HAS_TWOPHASE)
     {
         xl_xact_twophase *xl_twophase = (xl_xact_twophase *) data;
  
         parsed->twophase_xid = xl_twophase->xid;
  
         data += sizeof(xl_xact_twophase);
  
         if (parsed->xinfo & XACT_XINFO_HAS_GID)
         {
             strlcpy(parsed->twophase_gid, data, sizeof(parsed->twophase_gid));
             data += strlen(data) + 1;
         }
     }
  
     /* Note: no alignment is guaranteed after this point */
  
     if (parsed->xinfo & XACT_XINFO_HAS_ORIGIN)
     {
         xl_xact_origin xl_origin;
  
         /* no alignment is guaranteed, so copy onto stack */
         memcpy(&xl_origin, data, sizeof(xl_origin));
  
         parsed->origin_lsn = xl_origin.origin_lsn;
         parsed->origin_timestamp = xl_origin.origin_timestamp;
  
         data += sizeof(xl_xact_origin);
     }
 }

Referenced by recoveryStopsAfter(), recoveryStopsBefore(), SummarizeXactRecord(), xact_decode(), xact_desc_commit(), and xact_redo().

◆ ParsePrepareRecord()

void ParsePrepareRecord	(	uint8	info,
		xl_xact_prepare *	xlrec,
		xl_xact_parsed_prepare *	parsed
	)

Definition at line 239 of file xactdesc.c.

 {
     char       *bufptr;
  
     bufptr = ((char *) xlrec) + MAXALIGN(sizeof(xl_xact_prepare));
  
     memset(parsed, 0, sizeof(*parsed));
  
     parsed->xact_time = xlrec->prepared_at;
     parsed->origin_lsn = xlrec->origin_lsn;
     parsed->origin_timestamp = xlrec->origin_timestamp;
     parsed->twophase_xid = xlrec->xid;
     parsed->dbId = xlrec->database;
     parsed->nsubxacts = xlrec->nsubxacts;
     parsed->nrels = xlrec->ncommitrels;
     parsed->nabortrels = xlrec->nabortrels;
     parsed->nmsgs = xlrec->ninvalmsgs;
  
     strncpy(parsed->twophase_gid, bufptr, xlrec->gidlen);
     bufptr += MAXALIGN(xlrec->gidlen);
  
     parsed->subxacts = (TransactionId *) bufptr;
     bufptr += MAXALIGN(xlrec->nsubxacts * sizeof(TransactionId));
  
     parsed->xlocators = (RelFileLocator *) bufptr;
     bufptr += MAXALIGN(xlrec->ncommitrels * sizeof(RelFileLocator));
  
     parsed->abortlocators = (RelFileLocator *) bufptr;
     bufptr += MAXALIGN(xlrec->nabortrels * sizeof(RelFileLocator));
  
     parsed->stats = (xl_xact_stats_item *) bufptr;
     bufptr += MAXALIGN(xlrec->ncommitstats * sizeof(xl_xact_stats_item));
  
     parsed->abortstats = (xl_xact_stats_item *) bufptr;
     bufptr += MAXALIGN(xlrec->nabortstats * sizeof(xl_xact_stats_item));
  
     parsed->msgs = (SharedInvalidationMessage *) bufptr;
     bufptr += MAXALIGN(xlrec->ninvalmsgs * sizeof(SharedInvalidationMessage));
 }

Referenced by xact_decode(), and xact_desc_prepare().

◆ xact_desc()

void xact_desc	(	StringInfo	buf,
		XLogReaderState *	record
	)

Definition at line 439 of file xactdesc.c.

 {
     char       *rec = XLogRecGetData(record);
     uint8       info = XLogRecGetInfo(record) & XLOG_XACT_OPMASK;
  
     if (info == XLOG_XACT_COMMIT || info == XLOG_XACT_COMMIT_PREPARED)
     {
         xl_xact_commit *xlrec = (xl_xact_commit *) rec;
  
         xact_desc_commit(buf, XLogRecGetInfo(record), xlrec,
                          XLogRecGetOrigin(record));
     }
     else if (info == XLOG_XACT_ABORT || info == XLOG_XACT_ABORT_PREPARED)
     {
         xl_xact_abort *xlrec = (xl_xact_abort *) rec;
  
         xact_desc_abort(buf, XLogRecGetInfo(record), xlrec,
                         XLogRecGetOrigin(record));
     }
     else if (info == XLOG_XACT_PREPARE)
     {
         xl_xact_prepare *xlrec = (xl_xact_prepare *) rec;
  
         xact_desc_prepare(buf, XLogRecGetInfo(record), xlrec,
                           XLogRecGetOrigin(record));
     }
     else if (info == XLOG_XACT_ASSIGNMENT)
     {
         xl_xact_assignment *xlrec = (xl_xact_assignment *) rec;
  
         /*
          * Note that we ignore the WAL record's xid, since we're more
          * interested in the top-level xid that issued the record and which
          * xids are being reported here.
          */
         appendStringInfo(buf, "xtop %u: ", xlrec->xtop);
         xact_desc_assignment(buf, xlrec);
     }
     else if (info == XLOG_XACT_INVALIDATIONS)
     {
         xl_xact_invals *xlrec = (xl_xact_invals *) rec;
  
         standby_desc_invalidations(buf, xlrec->nmsgs, xlrec->msgs, InvalidOid,
                                    InvalidOid, false);
     }
 }

References appendStringInfo(), buf, InvalidOid, xl_xact_invals::msgs, xl_xact_invals::nmsgs, standby_desc_invalidations(), xact_desc_abort(), xact_desc_assignment(), xact_desc_commit(), xact_desc_prepare(), XLOG_XACT_ABORT, XLOG_XACT_ABORT_PREPARED, XLOG_XACT_ASSIGNMENT, XLOG_XACT_COMMIT, XLOG_XACT_COMMIT_PREPARED, XLOG_XACT_INVALIDATIONS, XLOG_XACT_OPMASK, XLOG_XACT_PREPARE, XLogRecGetData, XLogRecGetInfo, XLogRecGetOrigin, and xl_xact_assignment::xtop.

◆ xact_desc_abort()

static void xact_desc_abort	(	StringInfo	buf,
		uint8	info,
		xl_xact_abort *	xlrec,
		RepOriginId	origin_id
	)

static

Definition at line 370 of file xactdesc.c.

 {
     xl_xact_parsed_abort parsed;
  
     ParseAbortRecord(info, xlrec, &parsed);
  
     /* If this is a prepared xact, show the xid of the original xact */
     if (TransactionIdIsValid(parsed.twophase_xid))
         appendStringInfo(buf, "%u: ", parsed.twophase_xid);
  
     appendStringInfoString(buf, timestamptz_to_str(xlrec->xact_time));
  
     xact_desc_relations(buf, "rels", parsed.nrels, parsed.xlocators);
     xact_desc_subxacts(buf, parsed.nsubxacts, parsed.subxacts);
  
     if (parsed.xinfo & XACT_XINFO_HAS_ORIGIN)
     {
         appendStringInfo(buf, "; origin: node %u, lsn %X/%X, at %s",
                          origin_id,
                          LSN_FORMAT_ARGS(parsed.origin_lsn),
                          timestamptz_to_str(parsed.origin_timestamp));
     }
  
     xact_desc_stats(buf, "", parsed.nstats, parsed.stats);
 }

Referenced by xact_desc().

◆ xact_desc_assignment()

static void xact_desc_assignment	(	StringInfo	buf,
		xl_xact_assignment *	xlrec
	)

static

Definition at line 428 of file xactdesc.c.

 {
     int         i;
  
     appendStringInfoString(buf, "subxacts:");
  
     for (i = 0; i < xlrec->nsubxacts; i++)
         appendStringInfo(buf, " %u", xlrec->xsub[i]);
 }

References appendStringInfo(), appendStringInfoString(), buf, i, xl_xact_assignment::nsubxacts, and xl_xact_assignment::xsub.

Referenced by xact_desc().

◆ xact_desc_commit()

static void xact_desc_commit	(	StringInfo	buf,
		uint8	info,
		xl_xact_commit *	xlrec,
		RepOriginId	origin_id
	)

static

Definition at line 334 of file xactdesc.c.

 {
     xl_xact_parsed_commit parsed;
  
     ParseCommitRecord(info, xlrec, &parsed);
  
     /* If this is a prepared xact, show the xid of the original xact */
     if (TransactionIdIsValid(parsed.twophase_xid))
         appendStringInfo(buf, "%u: ", parsed.twophase_xid);
  
     appendStringInfoString(buf, timestamptz_to_str(xlrec->xact_time));
  
     xact_desc_relations(buf, "rels", parsed.nrels, parsed.xlocators);
     xact_desc_subxacts(buf, parsed.nsubxacts, parsed.subxacts);
     xact_desc_stats(buf, "", parsed.nstats, parsed.stats);
  
     standby_desc_invalidations(buf, parsed.nmsgs, parsed.msgs, parsed.dbId,
                                parsed.tsId,
                                XactCompletionRelcacheInitFileInval(parsed.xinfo));
  
     if (XactCompletionApplyFeedback(parsed.xinfo))
         appendStringInfoString(buf, "; apply_feedback");
  
     if (XactCompletionForceSyncCommit(parsed.xinfo))
         appendStringInfoString(buf, "; sync");
  
     if (parsed.xinfo & XACT_XINFO_HAS_ORIGIN)
     {
         appendStringInfo(buf, "; origin: node %u, lsn %X/%X, at %s",
                          origin_id,
                          LSN_FORMAT_ARGS(parsed.origin_lsn),
                          timestamptz_to_str(parsed.origin_timestamp));
     }
 }

Referenced by xact_desc().

◆ xact_desc_prepare()

static void xact_desc_prepare	(	StringInfo	buf,
		uint8	info,
		xl_xact_prepare *	xlrec,
		RepOriginId	origin_id
	)

static

Definition at line 397 of file xactdesc.c.

 {
     xl_xact_parsed_prepare parsed;
  
     ParsePrepareRecord(info, xlrec, &parsed);
  
     appendStringInfo(buf, "gid %s: ", parsed.twophase_gid);
     appendStringInfoString(buf, timestamptz_to_str(parsed.xact_time));
  
     xact_desc_relations(buf, "rels(commit)", parsed.nrels, parsed.xlocators);
     xact_desc_relations(buf, "rels(abort)", parsed.nabortrels,
                         parsed.abortlocators);
     xact_desc_stats(buf, "commit ", parsed.nstats, parsed.stats);
     xact_desc_stats(buf, "abort ", parsed.nabortstats, parsed.abortstats);
     xact_desc_subxacts(buf, parsed.nsubxacts, parsed.subxacts);
  
     standby_desc_invalidations(buf, parsed.nmsgs, parsed.msgs, parsed.dbId,
                                parsed.tsId, xlrec->initfileinval);
  
     /*
      * Check if the replication origin has been set in this record in the same
      * way as PrepareRedoAdd().
      */
     if (origin_id != InvalidRepOriginId)
         appendStringInfo(buf, "; origin: node %u, lsn %X/%X, at %s",
                          origin_id,
                          LSN_FORMAT_ARGS(parsed.origin_lsn),
                          timestamptz_to_str(parsed.origin_timestamp));
 }

Referenced by xact_desc().

◆ xact_desc_relations()

static void xact_desc_relations	(	StringInfo	buf,
		char *	label,
		int	nrels,
		RelFileLocator *	xlocators
	)

static

Definition at line 280 of file xactdesc.c.

 {
     int         i;
  
     if (nrels > 0)
     {
         appendStringInfo(buf, "; %s:", label);
         for (i = 0; i < nrels; i++)
         {
             char       *path = relpathperm(xlocators[i], MAIN_FORKNUM);
  
             appendStringInfo(buf, " %s", path);
             pfree(path);
         }
     }
 }

References appendStringInfo(), buf, i, label, MAIN_FORKNUM, pfree(), and relpathperm.

Referenced by xact_desc_abort(), xact_desc_commit(), and xact_desc_prepare().

◆ xact_desc_stats()

static void xact_desc_stats	(	StringInfo	buf,
		const char *	label,
		int	ndropped,
		xl_xact_stats_item *	dropped_stats
	)

static

Definition at line 312 of file xactdesc.c.

 {
     int         i;
  
     if (ndropped > 0)
     {
         appendStringInfo(buf, "; %sdropped stats:", label);
         for (i = 0; i < ndropped; i++)
         {
             uint64      objid =
                 ((uint64) dropped_stats[i].objid_hi) << 32 | dropped_stats[i].objid_lo;
  
             appendStringInfo(buf, " %d/%u/%llu",
                              dropped_stats[i].kind,
                              dropped_stats[i].dboid,
                              (unsigned long long) objid);
         }
     }
 }

References appendStringInfo(), buf, i, label, and xl_xact_stats_item::objid_lo.

Referenced by xact_desc_abort(), xact_desc_commit(), and xact_desc_prepare().

◆ xact_desc_subxacts()

static void xact_desc_subxacts	(	StringInfo	buf,
		int	nsubxacts,
		TransactionId *	subxacts
	)

static

Definition at line 299 of file xactdesc.c.

 {
     int         i;
  
     if (nsubxacts > 0)
     {
         appendStringInfoString(buf, "; subxacts:");
         for (i = 0; i < nsubxacts; i++)
             appendStringInfo(buf, " %u", subxacts[i]);
     }
 }

References appendStringInfo(), appendStringInfoString(), buf, and i.

Referenced by xact_desc_abort(), xact_desc_commit(), and xact_desc_prepare().

◆ xact_identify()

const char* xact_identify ( uint8 info )

Definition at line 487 of file xactdesc.c.

 {
     const char *id = NULL;
  
     switch (info & XLOG_XACT_OPMASK)
     {
         case XLOG_XACT_COMMIT:
             id = "COMMIT";
             break;
         case XLOG_XACT_PREPARE:
             id = "PREPARE";
             break;
         case XLOG_XACT_ABORT:
             id = "ABORT";
             break;
         case XLOG_XACT_COMMIT_PREPARED:
             id = "COMMIT_PREPARED";
             break;
         case XLOG_XACT_ABORT_PREPARED:
             id = "ABORT_PREPARED";
             break;
         case XLOG_XACT_ASSIGNMENT:
             id = "ASSIGNMENT";
             break;
         case XLOG_XACT_INVALIDATIONS:
             id = "INVALIDATION";
             break;
     }
  
     return id;
 }

References XLOG_XACT_ABORT, XLOG_XACT_ABORT_PREPARED, XLOG_XACT_ASSIGNMENT, XLOG_XACT_COMMIT, XLOG_XACT_COMMIT_PREPARED, XLOG_XACT_INVALIDATIONS, XLOG_XACT_OPMASK, and XLOG_XACT_PREPARE.

Functions

Function Documentation

◆ ParseAbortRecord()

◆ ParseCommitRecord()

◆ ParsePrepareRecord()

◆ xact_desc()

◆ xact_desc_abort()

◆ xact_desc_assignment()

◆ xact_desc_commit()

◆ xact_desc_prepare()

◆ xact_desc_relations()

◆ xact_desc_stats()

◆ xact_desc_subxacts()

◆ xact_identify()