Commit1fe0f5b

committed

Temporary disable in-progress check for setting tuple hint bits

1 parent20afa29 commit1fe0f5bCopy full SHA for 1fe0f5b

File tree

+15

-9

lines changed

+15

-9

lines changed

Lines changed: 2 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -101,7 +101,7 @@ typedef enum`
`101`	`101`	`#defineMTM_MAP_SIZE MTM_HASH_SIZE`
`102`	`102`	`#defineMIN_WAIT_TIMEOUT 1000`
`103`	`103`	`#defineMAX_WAIT_TIMEOUT 100000`
`104`		`-#defineMAX_WAIT_LOOPS100 // 1000000`
	`104`	`+#defineMAX_WAIT_LOOPS10000 // 1000000`
`105`	`105`	`#defineSTATUS_POLL_DELAY USECS_PER_SEC`
`106`	`106`
`107`	`107`	`void_PG_init(void);`
`@@ -2913,6 +2913,7 @@ void MtmDropNode(int nodeId, bool dropSlot)`
`2913`	`2913`
`2914`	`2914`	`MtmUnlock();`
`2915`	`2915`	`}`
	`2916`	`+`
`2916`	`2917`	`staticvoid`
`2917`	`2918`	`MtmOnProcExit(intcode,Datumarg)`
`2918`	`2919`	`{`
`@@ -3076,9 +3077,7 @@ void MtmSetupReplicationHooks(struct PGLogicalHooks* hooks)`
`3076`	`3077`
`3077`	`3078`	`voidMtmBeginSession(intnodeId)`
`3078`	`3079`	`{`
`3079`		`-charslot_name[MULTIMASTER_MAX_SLOT_NAME_SIZE];`
`3080`	`3080`	`MtmLockNode(nodeId,LW_EXCLUSIVE);`
`3081`		`-sprintf(slot_name,MULTIMASTER_SLOT_PATTERN,nodeId);`
`3082`	`3081`	`Assert(replorigin_session_origin==InvalidRepOriginId);`
`3083`	`3082`	`replorigin_session_origin=Mtm->nodes[nodeId-1].originId;`
`3084`	`3083`	`Assert(replorigin_session_origin!=InvalidRepOriginId);`

Lines changed: 8 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -602,7 +602,14 @@ process_remote_commit(StringInfo in)`
`602`	`602`
`603`	`603`	`origin_node=pq_getmsgbyte(in);`
`604`	`604`	`origin_lsn=pq_getmsgint64(in);`
`605`		`-Mtm->nodes[origin_node-1].restartLsn=origin_lsn;`
	`605`	`+`
	`606`	`+if (Mtm->nodes[origin_node-1].restartLsn<origin_lsn) {`
	`607`	`+Mtm->nodes[origin_node-1].restartLsn=origin_lsn;`
	`608`	`+}`
	`609`	`+if (origin_node!=MtmReplicationNodeId) {`
	`610`	`+replorigin_advance(Mtm->nodes[origin_node-1].originId,origin_lsn,GetXLogInsertRecPtr(),`
	`611`	`+ false/* backward / , false/ WAL */ );`
	`612`	`+}`
`606`	`613`
`607`	`614`	`Assert(replorigin_session_origin==InvalidRepOriginId);`
`608`	`615`

Lines changed: 3 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -1,5 +1,5 @@`
`1`	`1`	`./dtmbench \`
`2`		`--c"dbname=postgres host=localhost port=5432 sslmode=disable" \`
`3`		`--c"dbname=postgres host=localhost port=5433 sslmode=disable" \`
`4`		`--c"dbname=postgres host=localhost port=5434 sslmode=disable" \`
	`2`	`+-c"dbname=regression host=localhost port=5432 sslmode=disable" \`
	`3`	`+-c"dbname=regression host=localhost port=5433 sslmode=disable" \`
	`4`	`+-c"dbname=regression host=localhost port=5434 sslmode=disable" \`
`5`	`5`	`-n 1000 -a 1000 -w 10 -r 1$*`

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -1065,7 +1065,7 @@ HeapTupleSatisfiesMVCC(HeapTuple htup, Snapshot snapshot,`
`1065`	`1065`	`else`
`1066`	`1066`	`{`
`1067`	`1067`	`/* it must have aborted or crashed */`
`1068`		`-if (!TransactionIdIsInProgress(HeapTupleHeaderGetRawXmin(tuple)))`
	`1068`	`+//if (!TransactionIdIsInProgress(HeapTupleHeaderGetRawXmin(tuple)))`
`1069`	`1069`	`SetHintBits(tuple,buffer,HEAP_XMIN_INVALID,`
`1070`	`1070`	`InvalidTransactionId);`
`1071`	`1071`	`return false;`
`@@ -1130,7 +1130,7 @@ HeapTupleSatisfiesMVCC(HeapTuple htup, Snapshot snapshot,`
`1130`	`1130`	`if (!TransactionIdDidCommit(HeapTupleHeaderGetRawXmax(tuple)))`
`1131`	`1131`	`{`
`1132`	`1132`	`/* it must have aborted or crashed */`
`1133`		`-if (!TransactionIdIsInProgress(HeapTupleHeaderGetRawXmax(tuple)))`
	`1133`	`+//if (!TransactionIdIsInProgress(HeapTupleHeaderGetRawXmax(tuple)))`
`1134`	`1134`	`SetHintBits(tuple,buffer,HEAP_XMAX_INVALID,`
`1135`	`1135`	`InvalidTransactionId);`
`1136`	`1136`	`return true;`

Comments

(0)