for (i = 0, j = 0; i < nmembers; i++)
{
- if (TransactionIdIsInProgress(members[i].xid) ||
+ TransactionIdStatus xidstatus = TransactionIdGetStatus(members[i].xid);
+
+ if (xidstatus == XID_INPROGRESS ||
- ((members[i].status > MultiXactStatusForUpdate) &&
+ (ISUPDATE_from_mxstatus(members[i].status) &&
- TransactionIdDidCommit(members[i].xid)))
+ xidstatus == XID_COMMITTED))
{
newMembers[j].xid = members[i].xid;
newMembers[j++].status = members[i].status;
for(off = 0; off < list_length(files); off++)
{
RewriteMappingFile *f = files_a[off];
- elog(DEBUG1, "applying mapping: %s in %u", f->fname,
+ elog(DEBUG1, "applying mapping: \"%s\" in %u", f->fname,
- snapshot->subxip[0]);
+ snapshot->this_xip[0]);
ApplyLogicalMappingFile(tuplecid_data, relid, f->fname);
pfree(f);
}