Use two phase commit

knizhnik · knizhnik · commit 685a409a3113 · 2015-11-18T14:58:07.000+03:00
diff --git a/pg_dtm.c b/pg_dtm.c
@@ -632,7 +632,7 @@ static void DtmSetTransactionStatus(TransactionId xid, int nsubxids, Transaction
 				LWLockAcquire(dtm->hashLock, LW_EXCLUSIVE);
 				hash_search(xid_in_doubt, &DtmNextXid, HASH_ENTER, NULL);
 				LWLockRelease(dtm->hashLock);
-				DtmGlobalSetTransStatus(xid, status, true);
+                while (DtmGlobalSetTransStatus(xid, status, false) < 0);
 				XTM_INFO("Commit transaction %d\n", xid);
 			}
 		}
diff --git a/tests/dtmbench.cpp b/tests/dtmbench.cpp
@@ -194,6 +194,12 @@ void* writer(void* arg)
             continue;
         }
 
+        #if 1
+        exec(srcTx, "prepare transaction '%u'", xid);
+        exec(dstTx, "prepare transaction '%u'", xid);
+        exec(srcTx, "commit prepared '%u'", xid);
+        exec(dstTx, "commit prepared '%u'", xid);
+        #else
         pipeline srcPipe(srcTx);
         pipeline dstPipe(dstTx);
 
@@ -202,7 +208,7 @@ void* writer(void* arg)
 
         srcPipe.complete();
         dstPipe.complete();
-
+        #endif
         t.proceeded += 1;
     }
     return NULL;

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`	`}`