Resolve conflicts in xact.h, xactdesc.c, twophase.c, and partially in…

src/backend/access/rmgrdesc/xactdesc.c

@@ -490,7 +490,13 @@ xact_desc(StringInfo buf, XLogReaderState *record)
 		appendStringInfo(buf, "xtop %u: ", xlrec->xtop);
 		xact_desc_assignment(buf, xlrec);
 	}
-<<<<<<< HEAD
+	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);
+	}
 	else if (info == XLOG_XACT_DISTRIBUTED_COMMIT)
 	{
 		xl_xact_commit *xlrec = (xl_xact_commit *) rec;
@@ -505,14 +511,6 @@ xact_desc(StringInfo buf, XLogReaderState *record)
 
 		appendStringInfo(buf, "distributed forget ");
 		xact_desc_distributed_forget(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);
->>>>>>> d259afa7365165760004c2fdbe2520a94ddf2600
 	}
 }
 
@@ -541,16 +539,14 @@ xact_identify(uint8 info)
 		case XLOG_XACT_ASSIGNMENT:
 			id = "ASSIGNMENT";
 			break;
-<<<<<<< HEAD
+		case XLOG_XACT_INVALIDATIONS:
+			id = "INVALIDATION";
+			break;
 		case XLOG_XACT_DISTRIBUTED_COMMIT:
 			id = "DISTRIBUTED_COMMIT";
 			break;
 		case XLOG_XACT_DISTRIBUTED_FORGET:
 			id = "DISTRIBUTED_FORGET";
-=======
-		case XLOG_XACT_INVALIDATIONS:
-			id = "INVALIDATION";
->>>>>>> d259afa7365165760004c2fdbe2520a94ddf2600
 			break;
 	}
 

src/backend/access/transam/twophase.c

@@ -2383,12 +2383,8 @@ RecordTransactionCommitPrepared(TransactionId xid,
 								 GetPendingTablespaceForDeletionForCommit(),
 								 nchildren, children, nrels, rels,
 								 ninvalmsgs, invalmsgs,
-<<<<<<< HEAD
 								 ndeldbs, deldbs,
-								 initfileinval, false,
-=======
 								 initfileinval,
->>>>>>> d259afa7365165760004c2fdbe2520a94ddf2600
 								 MyXactFlags | XACT_FLAGS_ACQUIREDACCESSEXCLUSIVELOCK,
 								 xid, gid);
 

src/backend/access/transam/xact.c

@@ -1661,12 +1661,8 @@ RecordTransactionCommit(void)
 							GetPendingTablespaceForDeletionForCommit(),
 							nchildren, children, nrels, rels,
 							nmsgs, invalMessages,
-<<<<<<< HEAD
 							ndeldbs, deldbs,
-							RelcacheInitFileInval, forceSyncCommit,
-=======
 							RelcacheInitFileInval,
->>>>>>> d259afa7365165760004c2fdbe2520a94ddf2600
 							MyXactFlags,
 							InvalidTransactionId, NULL /* plain commit */ );
 
@@ -6797,12 +6793,8 @@ XactLogCommitRecord(TimestampTz commit_time,
 					int nsubxacts, TransactionId *subxacts,
 					int nrels, RelFileNodePendingDelete *rels,
 					int nmsgs, SharedInvalidationMessage *msgs,
-<<<<<<< HEAD
 					int ndeldbs, DbDirNode *deldbs,
-					bool relcacheInval, bool forceSync,
-=======
 					bool relcacheInval,
->>>>>>> d259afa7365165760004c2fdbe2520a94ddf2600
 					int xactflags, TransactionId twophase_xid,
 					const char *twophase_gid)
 {

src/include/access/xact.h

@@ -21,11 +21,7 @@
 #include "nodes/pg_list.h"
 #include "storage/relfilenode.h"
 #include "storage/sinval.h"
-<<<<<<< HEAD
 #include "storage/dbdirnode.h"
-#include "utils/datetime.h"
-=======
->>>>>>> d259afa7365165760004c2fdbe2520a94ddf2600
 
 #include "cdb/cdbpublic.h"
 #include "cdb/cdbtm.h"
@@ -161,20 +157,16 @@ typedef void (*SubXactCallback) (SubXactEvent event, SubTransactionId mySubid,
 #define XLOG_XACT_COMMIT_PREPARED	0x30
 #define XLOG_XACT_ABORT_PREPARED	0x40
 #define XLOG_XACT_ASSIGNMENT		0x50
-<<<<<<< HEAD
-/* GPDB takes the last available three opcodes */
-#define XLOG_XACT_DISTRIBUTED_COMMIT 0x60
-#define XLOG_XACT_DISTRIBUTED_FORGET 0x70
-=======
 #define XLOG_XACT_INVALIDATIONS		0x60
-/* free opcode 0x70 */
->>>>>>> d259afa7365165760004c2fdbe2520a94ddf2600
+/* GPDB takes the last available three opcodes */
+#define XLOG_XACT_DISTRIBUTED_COMMIT 0x70
+#define XLOG_XACT_DISTRIBUTED_FORGET 0x80
 
 /* mask for filtering opcodes out of xl_info */
-#define XLOG_XACT_OPMASK			0x70
+#define XLOG_XACT_OPMASK			0x80
 
 /* does this record have a 'xinfo' field or not */
-#define XLOG_XACT_HAS_INFO			0x80
+#define XLOG_XACT_HAS_INFO			0x90
 
 /*
  * The following flags, stored in xinfo, determine which information is
@@ -508,12 +500,9 @@ extern void UnregisterXactCallbackOnce(XactCallback callback, void *arg);
 extern void RegisterSubXactCallback(SubXactCallback callback, void *arg);
 extern void UnregisterSubXactCallback(SubXactCallback callback, void *arg);
 
-<<<<<<< HEAD
 extern void RecordDistributedForgetCommitted(DistributedTransactionId gxid);
-=======
 extern bool IsSubTransactionAssignmentPending(void);
 extern void MarkSubTransactionAssigned(void);
->>>>>>> d259afa7365165760004c2fdbe2520a94ddf2600
 
 extern int	xactGetCommittedChildren(TransactionId **ptr);
 
@@ -522,15 +511,9 @@ extern XLogRecPtr XactLogCommitRecord(TimestampTz commit_time,
 									  int nsubxacts, TransactionId *subxacts,
 									  int nrels, RelFileNodePendingDelete *rels,
 									  int nmsgs, SharedInvalidationMessage *msgs,
-<<<<<<< HEAD
 									  int ndeldbs, DbDirNode *deldbs,
-									  bool relcacheInval, bool forceSync,
-									  int xactflags, TransactionId twophase_xid,
-=======
-									  bool relcacheInval,
-									  int xactflags,
+									  bool relcacheInval, int xactflags,
 									  TransactionId twophase_xid,
->>>>>>> d259afa7365165760004c2fdbe2520a94ddf2600
 									  const char *twophase_gid);
 
 extern XLogRecPtr XactLogAbortRecord(TimestampTz abort_time,