Commit1200b6a

authored and

committed

More 2PC

1 parent17a908a commit1200b6aCopy full SHA for 1200b6a

File tree

+172

-124

lines changed

+172

-124

lines changed

Lines changed: 1 addition & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -544,7 +544,6 @@ static void MtmTransReceiver(Datum arg)`
`544`	`544`	`intnResponses;`
`545`	`545`	`inti,j,n,rc;`
`546`	`546`	`MtmBufferrxBuffer= (MtmBuffer)palloc(sizeof(MtmBuffer)*nNodes);`
`547`		`-HTAB*xid2state;`
`548`	`547`
`549`	`548`	`#ifUSE_EPOLL`
`550`	`549`	`structepoll_eventevents= (structepoll_event)palloc(sizeof(structepoll_event)*nNodes);`
`@@ -557,7 +556,6 @@ static void MtmTransReceiver(Datum arg)`
`557`	`556`	`ds=MtmGetState();`
`558`	`557`
`559`	`558`	`MtmAcceptIncomingConnections();`
`560`		`-xid2state=MtmCreateHash();`
`561`	`559`
`562`	`560`	`for (i=0;i<nNodes;i++) {`
`563`	`561`	`rxBuffer[i].used=0;`
`@@ -611,7 +609,7 @@ static void MtmTransReceiver(Datum arg)`
`611`	`609`
`612`	`610`	`for (j=0;j<nResponses;j++) {`
`613`	`611`	`MtmArbiterMessage*msg=&rxBuffer[i].data[j];`
`614`		`-MtmTransStatets= (MtmTransState)hash_search(xid2state,&msg->dxid,HASH_FIND,NULL);`
	`612`	`+MtmTransStatets= (MtmTransState)hash_search(MtmXid2State,&msg->dxid,HASH_FIND,NULL);`
`615`	`613`	`Assert(ts!=NULL);`
`616`	`614`	`Assert(msg->node>0&&msg->node <=nNodes&&msg->node!=MtmNodeId);`
`617`	`615`	`Assert (MtmIsCoordinator(ts));`

Comments

(0)