Commit5c26b9d

authored and

committed

Minor refactoring

1 parenta8f07d2 commit5c26b9dCopy full SHA for 5c26b9d

File tree

-4

lines changed

-4

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -529,7 +529,7 @@ static void MtmTransSender(Datum arg)`
`529`	`529`
`530`	`530`	`staticvoidMtmWakeUpBackend(MtmTransState*ts)`
`531`	`531`	`{`
`532`		`-ts->done= true;`
	`532`	`+ts->voteCompleted= true;`
`533`	`533`	`SetLatch(&ProcGlobal->allProcs[ts->procno].procLatch);`
`534`	`534`	`}`
`535`	`535`

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -629,7 +629,7 @@ static void MtmPrecommitTransaction(MtmCurrentTrans* x)`
`629`	`629`	`ts->cmd=MSG_INVALID;`
`630`	`630`	`ts->procno=MyProc->pgprocno;`
`631`	`631`	`ts->nVotes=0;`
`632`		`-ts->done= false;`
	`632`	`+ts->voteCompleted= false;`
`633`	`633`	`dtm->transCount+=1;`
`634`	`634`
`635`	`635`	`if (TransactionIdIsValid(x->gtid.xid)) {`
`@@ -1638,7 +1638,7 @@ MtmVoteForTransaction(MtmTransState* ts)`
`1638`	`1638`	`}`
`1639`	`1639`	`}`
`1640`	`1640`	`MTM_TRACE("%d: Node %d waiting latch...\n",MyProcPid,MtmNodeId);`
`1641`		`-while (!ts->done) {`
	`1641`	`+while (!ts->voteCompleted) {`
`1642`	`1642`	`MtmUnlock();`
`1643`	`1643`	`WaitLatch(&MyProc->procLatch,WL_LATCH_SET,-1);`
`1644`	`1644`	`ResetLatch(&MyProc->procLatch);`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -85,7 +85,7 @@ typedef struct MtmTransState`
`85`	`85`	`intnSubxids;/* Number of subtransanctions */`
`86`	`86`	`structMtmTransStatenextVoting;/ Next element in L1-list of voting transactions. */`
`87`	`87`	`structMtmTransStatenext;/ Next element in L1 list of all finished transaction present in xid2state hash */`
`88`		`-booldone;`
	`88`	`+boolvoteCompleted;/* Responses necessary to make a decision are received by coordinator of transaction */`
`89`	`89`	`TransactionIdxids[1];/* transaction ID at replicas: varying size MtmNodes */`
`90`	`90`	`}MtmTransState;`
`91`	`91`

Comments

(0)