xactdesc.c File Reference

#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:

Go to the source code of this file.

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, ReplOriginId origin_id)
static void	xact_desc_abort (StringInfo buf, uint8 info, xl_xact_abort *xlrec, ReplOriginId origin_id)
static void	xact_desc_prepare (StringInfo buf, uint8 info, xl_xact_prepare *xlrec, ReplOriginId 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);
    }
}

References data, xl_xact_dbinfo::dbId, fb(), MinSizeOfXactAbort, MinSizeOfXactRelfileLocators, MinSizeOfXactStatsItems, MinSizeOfXactSubxacts, xl_xact_stats_items::nitems, xl_xact_relfilelocators::nrels, xl_xact_subxacts::nsubxacts, strlcpy(), XACT_XINFO_HAS_DBINFO, XACT_XINFO_HAS_DROPPED_STATS, XACT_XINFO_HAS_GID, XACT_XINFO_HAS_ORIGIN, XACT_XINFO_HAS_RELFILELOCATORS, XACT_XINFO_HAS_SUBXACTS, XACT_XINFO_HAS_TWOPHASE, xl_xact_twophase::xid, xl_xact_xinfo::xinfo, and XLOG_XACT_HAS_INFO.

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);
    }
}

References data, xl_xact_dbinfo::dbId, fb(), MinSizeOfXactCommit, MinSizeOfXactInvals, MinSizeOfXactRelfileLocators, MinSizeOfXactStatsItems, MinSizeOfXactSubxacts, xl_xact_stats_items::nitems, xl_xact_invals::nmsgs, xl_xact_relfilelocators::nrels, xl_xact_subxacts::nsubxacts, strlcpy(), XACT_XINFO_HAS_DBINFO, XACT_XINFO_HAS_DROPPED_STATS, XACT_XINFO_HAS_GID, XACT_XINFO_HAS_INVALS, XACT_XINFO_HAS_ORIGIN, XACT_XINFO_HAS_RELFILELOCATORS, XACT_XINFO_HAS_SUBXACTS, XACT_XINFO_HAS_TWOPHASE, xl_xact_twophase::xid, xl_xact_xinfo::xinfo, and XLOG_XACT_HAS_INFO.

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->nstats = xlrec->ncommitstats;
    parsed->nabortstats = xlrec->nabortstats;
    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));
}

References fb(), and MAXALIGN.

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, fb(), InvalidOid, 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, and XLogRecGetOrigin.

xact_desc_abort()

static void xact_desc_abort ( StringInfo  buf, uint8  info, xl_xact_abort *  xlrec, ReplOriginId  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/%08X, at %s",
                         origin_id,
                         LSN_FORMAT_ARGS(parsed.origin_lsn),
                         timestamptz_to_str(parsed.origin_timestamp));
    }
 
    xact_desc_stats(buf, "", parsed.nstats, parsed.stats);
}

References appendStringInfo(), appendStringInfoString(), buf, fb(), LSN_FORMAT_ARGS, ParseAbortRecord(), timestamptz_to_str(), TransactionIdIsValid, xact_desc_relations(), xact_desc_stats(), xact_desc_subxacts(), and XACT_XINFO_HAS_ORIGIN.

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, fb(), and i.

Referenced by xact_desc().

xact_desc_commit()

static void xact_desc_commit ( StringInfo  buf, uint8  info, xl_xact_commit *  xlrec, ReplOriginId  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/%08X, at %s",
                         origin_id,
                         LSN_FORMAT_ARGS(parsed.origin_lsn),
                         timestamptz_to_str(parsed.origin_timestamp));
    }
}

References appendStringInfo(), appendStringInfoString(), buf, fb(), LSN_FORMAT_ARGS, ParseCommitRecord(), standby_desc_invalidations(), timestamptz_to_str(), TransactionIdIsValid, xact_desc_relations(), xact_desc_stats(), xact_desc_subxacts(), XACT_XINFO_HAS_ORIGIN, XactCompletionApplyFeedback, XactCompletionForceSyncCommit, and XactCompletionRelcacheInitFileInval.

Referenced by xact_desc().

xact_desc_prepare()

static void xact_desc_prepare ( StringInfo  buf, uint8  info, xl_xact_prepare *  xlrec, ReplOriginId  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 != InvalidReplOriginId)
        appendStringInfo(buf, "; origin: node %u, lsn %X/%08X, at %s",
                         origin_id,
                         LSN_FORMAT_ARGS(parsed.origin_lsn),
                         timestamptz_to_str(parsed.origin_timestamp));
}

References appendStringInfo(), appendStringInfoString(), buf, fb(), InvalidReplOriginId, LSN_FORMAT_ARGS, ParsePrepareRecord(), standby_desc_invalidations(), timestamptz_to_str(), xact_desc_relations(), xact_desc_stats(), and xact_desc_subxacts().

Referenced by xact_desc().

xact_desc_relations()

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

static

Definition at line 282 of file xactdesc.c.

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

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

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/%" PRIu64,
                             dropped_stats[i].kind,
                             dropped_stats[i].dboid,
                             objid);
        }
    }
}

References appendStringInfo(), buf, fb(), i, and label.

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 fb(), 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.