@@ -148,7 +148,7 @@ static void MMExecutorFinish(QueryDesc *queryDesc);
148148static bool MMIsDistributedTrans ;
149149
150150static BackgroundWorker DtmWorker = {
151- "DtmWorker " ,
151+ "sockhub " ,
1521520 ,/* do not need connection to the database */
153153BgWorkerStart_PostmasterStart ,
1541541 ,/* restrart in one second (is it possible to restort immediately?) */
@@ -656,13 +656,15 @@ static void DtmSetTransactionStatus(TransactionId xid, int nsubxids, Transaction
656656}
657657else
658658{
659+ XidStatus verdict ;
659660XTM_INFO ("Begin commit transaction %d\n" ,xid );
660661/* Mark transaction as in-doubt in xid_in_doubt hash table */
661662LWLockAcquire (dtm -> hashLock ,LW_EXCLUSIVE );
662663hash_search (xid_in_doubt ,& DtmNextXid ,HASH_ENTER ,NULL );
663664LWLockRelease (dtm -> hashLock );
664- if (DtmGlobalSetTransStatus (xid ,status , true)!= status ) {
665- XTM_INFO ("Commit of transaction %d is rejected by arbiter\n" ,xid );
665+ verdict = DtmGlobalSetTransStatus (xid ,status , true);
666+ if (verdict != status ) {
667+ XTM_INFO ("Commit of transaction %d is rejected by arbiter: staus=%d\n" ,xid ,verdict );
666668DtmNextXid = InvalidTransactionId ;
667669DtmLastSnapshot = NULL ;
668670MMIsDistributedTrans = false;