Commit79aafd9

committed

Use two phase commit

1 parent685a409 commit79aafd9Copy full SHA for 79aafd9

File tree

-1

lines changed

-1

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`		`-while (DtmGlobalSetTransStatus(xid,status,false)<0);`
	`635`	`+while (DtmGlobalSetTransStatus(xid,status,true)<0);`
`636`	`636`	`XTM_INFO("Commit transaction %d\n",xid);`
`637`	`637`	`}`
`638`	`638`	`}`

Comments

(0)