diff options
Diffstat (limited to 'src/backend/access/transam/xact.c')
| -rw-r--r-- | src/backend/access/transam/xact.c | 173 |
1 files changed, 0 insertions, 173 deletions
diff --git a/src/backend/access/transam/xact.c b/src/backend/access/transam/xact.c index 10386dadce5..349bdbcd929 100644 --- a/src/backend/access/transam/xact.c +++ b/src/backend/access/transam/xact.c @@ -4825,176 +4825,3 @@ xact_redo(XLogRecPtr lsn, XLogRecord *record) else elog(PANIC, "xact_redo: unknown op code %u", info); } - -static void -xact_desc_commit(StringInfo buf, xl_xact_commit *xlrec) -{ - int i; - TransactionId *subxacts; - - subxacts = (TransactionId *) &xlrec->xnodes[xlrec->nrels]; - - appendStringInfoString(buf, timestamptz_to_str(xlrec->xact_time)); - - if (xlrec->nrels > 0) - { - appendStringInfo(buf, "; rels:"); - for (i = 0; i < xlrec->nrels; i++) - { - char *path = relpathperm(xlrec->xnodes[i], MAIN_FORKNUM); - - appendStringInfo(buf, " %s", path); - pfree(path); - } - } - if (xlrec->nsubxacts > 0) - { - appendStringInfo(buf, "; subxacts:"); - for (i = 0; i < xlrec->nsubxacts; i++) - appendStringInfo(buf, " %u", subxacts[i]); - } - if (xlrec->nmsgs > 0) - { - SharedInvalidationMessage *msgs; - - msgs = (SharedInvalidationMessage *) &subxacts[xlrec->nsubxacts]; - - if (XactCompletionRelcacheInitFileInval(xlrec->xinfo)) - appendStringInfo(buf, "; relcache init file inval dbid %u tsid %u", - xlrec->dbId, xlrec->tsId); - - appendStringInfo(buf, "; inval msgs:"); - for (i = 0; i < xlrec->nmsgs; i++) - { - SharedInvalidationMessage *msg = &msgs[i]; - - if (msg->id >= 0) - appendStringInfo(buf, " catcache %d", msg->id); - else if (msg->id == SHAREDINVALCATALOG_ID) - appendStringInfo(buf, " catalog %u", msg->cat.catId); - else if (msg->id == SHAREDINVALRELCACHE_ID) - appendStringInfo(buf, " relcache %u", msg->rc.relId); - /* remaining cases not expected, but print something anyway */ - else if (msg->id == SHAREDINVALSMGR_ID) - appendStringInfo(buf, " smgr"); - else if (msg->id == SHAREDINVALRELMAP_ID) - appendStringInfo(buf, " relmap"); - else - appendStringInfo(buf, " unknown id %d", msg->id); - } - } -} - -static void -xact_desc_commit_compact(StringInfo buf, xl_xact_commit_compact *xlrec) -{ - int i; - - appendStringInfoString(buf, timestamptz_to_str(xlrec->xact_time)); - - if (xlrec->nsubxacts > 0) - { - appendStringInfo(buf, "; subxacts:"); - for (i = 0; i < xlrec->nsubxacts; i++) - appendStringInfo(buf, " %u", xlrec->subxacts[i]); - } -} - -static void -xact_desc_abort(StringInfo buf, xl_xact_abort *xlrec) -{ - int i; - - appendStringInfoString(buf, timestamptz_to_str(xlrec->xact_time)); - if (xlrec->nrels > 0) - { - appendStringInfo(buf, "; rels:"); - for (i = 0; i < xlrec->nrels; i++) - { - char *path = relpathperm(xlrec->xnodes[i], MAIN_FORKNUM); - - appendStringInfo(buf, " %s", path); - pfree(path); - } - } - if (xlrec->nsubxacts > 0) - { - TransactionId *xacts = (TransactionId *) - &xlrec->xnodes[xlrec->nrels]; - - appendStringInfo(buf, "; subxacts:"); - for (i = 0; i < xlrec->nsubxacts; i++) - appendStringInfo(buf, " %u", xacts[i]); - } -} - -static void -xact_desc_assignment(StringInfo buf, xl_xact_assignment *xlrec) -{ - int i; - - appendStringInfo(buf, "subxacts:"); - - for (i = 0; i < xlrec->nsubxacts; i++) - appendStringInfo(buf, " %u", xlrec->xsub[i]); -} - -void -xact_desc(StringInfo buf, uint8 xl_info, char *rec) -{ - uint8 info = xl_info & ~XLR_INFO_MASK; - - if (info == XLOG_XACT_COMMIT_COMPACT) - { - xl_xact_commit_compact *xlrec = (xl_xact_commit_compact *) rec; - - appendStringInfo(buf, "commit: "); - xact_desc_commit_compact(buf, xlrec); - } - else if (info == XLOG_XACT_COMMIT) - { - xl_xact_commit *xlrec = (xl_xact_commit *) rec; - - appendStringInfo(buf, "commit: "); - xact_desc_commit(buf, xlrec); - } - else if (info == XLOG_XACT_ABORT) - { - xl_xact_abort *xlrec = (xl_xact_abort *) rec; - - appendStringInfo(buf, "abort: "); - xact_desc_abort(buf, xlrec); - } - else if (info == XLOG_XACT_PREPARE) - { - appendStringInfo(buf, "prepare"); - } - else if (info == XLOG_XACT_COMMIT_PREPARED) - { - xl_xact_commit_prepared *xlrec = (xl_xact_commit_prepared *) rec; - - appendStringInfo(buf, "commit prepared %u: ", xlrec->xid); - xact_desc_commit(buf, &xlrec->crec); - } - else if (info == XLOG_XACT_ABORT_PREPARED) - { - xl_xact_abort_prepared *xlrec = (xl_xact_abort_prepared *) rec; - - appendStringInfo(buf, "abort prepared %u: ", xlrec->xid); - xact_desc_abort(buf, &xlrec->arec); - } - 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, "xid assignment xtop %u: ", xlrec->xtop); - xact_desc_assignment(buf, xlrec); - } - else - appendStringInfo(buf, "UNKNOWN"); -} |