Commit685a409

committed

Use two phase commit

1 parent07cd7a1 commit685a409Copy full SHA for 685a409

File tree

-2

lines changed

-2

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -632,7 +632,7 @@ static void DtmSetTransactionStatus(TransactionId xid, int nsubxids, Transaction`
`632`	`632`	`LWLockAcquire(dtm->hashLock,LW_EXCLUSIVE);`
`633`	`633`	`hash_search(xid_in_doubt,&DtmNextXid,HASH_ENTER,NULL);`
`634`	`634`	`LWLockRelease(dtm->hashLock);`
`635`		`-DtmGlobalSetTransStatus(xid,status,true);`
	`635`	`+while (DtmGlobalSetTransStatus(xid,status,false)<0);`
`636`	`636`	`XTM_INFO("Commit transaction %d\n",xid);`
`637`	`637`	`}`
`638`	`638`	`}`

Lines changed: 7 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -194,6 +194,12 @@ void* writer(void* arg)`
`194`	`194`	`continue;`
`195`	`195`	`}`
`196`	`196`
	`197`	`+ #if1`
	`198`	`+exec(srcTx,"prepare transaction '%u'", xid);`
	`199`	`+exec(dstTx,"prepare transaction '%u'", xid);`
	`200`	`+exec(srcTx,"commit prepared '%u'", xid);`
	`201`	`+exec(dstTx,"commit prepared '%u'", xid);`
	`202`	`+ #else`
`197`	`203`	`pipeline srcPipe(srcTx);`
`198`	`204`	`pipeline dstPipe(dstTx);`
`199`	`205`
`@@ -202,7 +208,7 @@ void* writer(void* arg)`
`202`	`208`
`203`	`209`	`srcPipe.complete();`
`204`	`210`	`dstPipe.complete();`
`205`		`-`
	`211`	`+ #endif`
`206`	`212`	`t.proceeded +=1;`
`207`	`213`	`}`
`208`	`214`	`returnNULL;`

Comments

(0)