Commitc8ac9e4

authored and

committed

Disable DDD

1 parente12b5b4 commitc8ac9e4Copy full SHA for c8ac9e4

File tree

-3

lines changed

-3

lines changed

Lines changed: 2 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -529,7 +529,8 @@ static void MtmTransSender(Datum arg)`
`529`	`529`
`530`	`530`	`staticvoidMtmWakeUpBackend(MtmTransState*ts)`
`531`	`531`	`{`
`532`		`-ts->voteCompleted= true;`
	`532`	`+ts->voteCompleted= true;`
	`533`	`+MTM_TRACE("Wakeup backed procno=%d, pid=%d\n",ts->procno,ProcGlobal->allProcs[ts->procno].pid);`
`533`	`534`	`SetLatch(&ProcGlobal->allProcs[ts->procno].procLatch);`
`534`	`535`	`}`
`535`	`536`

Lines changed: 3 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -511,7 +511,7 @@ MtmXactCallback(XactEvent event, void *arg)`
`511`	`511`	`staticbool`
`512`	`512`	`MtmIsUserTransaction()`
`513`	`513`	`{`
`514`		`-returnIsNormalProcessingMode()&&MtmDoReplication&& !am_walsender&& !IsBackgroundWorker&& !IsAutoVacuumWorkerProcess();`
	`514`	`+return!IsAutoVacuumLauncherProcess()&&IsNormalProcessingMode()&&MtmDoReplication&& !am_walsender&& !IsBackgroundWorker&& !IsAutoVacuumWorkerProcess();`
`515`	`515`	`}`
`516`	`516`
`517`	`517`	`staticvoid`
`@@ -525,6 +525,7 @@ MtmBeginTransaction(MtmCurrentTrans* x)`
`525`	`525`	`if (x->isDistributed&&dtm->status!=MTM_ONLINE) {`
`526`	`526`	`/* reject all user's transactions at offline cluster */`
`527`	`527`	`MtmUnlock();`
	`528`	`+Assert(dtm->status==MTM_ONLINE);`
`528`	`529`	`elog(ERROR,"Multimaster node is not online: current status %s",MtmNodeStatusMnem[dtm->status]);`
`529`	`530`	`}`
`530`	`531`	`x->containsDML= false;`
`@@ -1765,7 +1766,7 @@ MtmDetectGlobalDeadLock(PGPROC* proc)`
`1765`	`1766`	`intsize;`
`1766`	`1767`	`void*data=PaxosGet(psprintf("lock-graph-%d",i+1),&size,NULL, true);`
`1767`	`1768`	`if (data==NULL) {`
`1768`		`-hasDeadlock= true;/* Just temporary hack until no Paxos */`
	`1769`	`+return true;/* Just temporary hack until no Paxos */`
`1769`	`1770`	`}else {`
`1770`	`1771`	`MtmGraphAdd(&graph, (GlobalTransactionId*)data,size/sizeof(GlobalTransactionId));`
`1771`	`1772`	`}`

Comments

(0)