Commitc3b857a

committed

commit recovered prepared tx that were produced by a sible major

1 parent6247ad7 commitc3b857aCopy full SHA for c3b857a

File tree

+15

-1

lines changed

+15

-1

lines changed

Lines changed: 12 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -1687,7 +1687,19 @@ void MtmSend2PCMessage(MtmTransState* ts, MtmMessageCode cmd)`
`1687`	`1687`	`staticvoidMtmBroadcastPollMessage(MtmTransState*ts)`
`1688`	`1688`	`{`
`1689`	`1689`	`inti;`
	`1690`	`+intnparts;`
`1690`	`1691`	`MtmArbiterMessagemsg;`
	`1692`	`+`
	`1693`	`+nparts=Mtm->nAllNodes-countZeroBits(ts->participantsMask,Mtm->nAllNodes);`
	`1694`	`+MTM_LOG1("MtmBroadcastPollMessage: %s %lld %d",ts->gid,ts->participantsMask,nparts);`
	`1695`	`+`
	`1696`	`+if (nparts==1)`
	`1697`	`+{`
	`1698`	`+/* we were in major mode and there nobody to ask about status */`
	`1699`	`+MtmFinishPreparedTransaction(ts, true);`
	`1700`	`+return;`
	`1701`	`+}`
	`1702`	`+`
`1691`	`1703`	`MtmInitMessage(&msg,MSG_POLL_REQUEST);`
`1692`	`1704`	`memcpy(msg.gid,ts->gid,MULTIMASTER_MAX_GID_SIZE);`
`1693`	`1705`	`ts->votedMask=0;`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -41,7 +41,7 @@ maskToString(nodemask_t mask, int nNodes)`
`41`	`41`	`returnstrMask;`
`42`	`42`	`}`
`43`	`43`
`44`		`-staticint`
	`44`	`+int`
`45`	`45`	`countZeroBits(nodemask_tmask,intnNodes)`
`46`	`46`	`{`
`47`	`47`	`inti,count=0;`

Lines changed: 2 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -31,3 +31,5 @@ extern void MtmOnNodeConnect(int nodeId);`
`31`	`31`	`externvoidMtmReconnectNode(intnodeId);`
`32`	`32`
`33`	`33`	`externvoidMtmRefreshClusterStatus(void);`
	`34`	`+`
	`35`	`+externintcountZeroBits(nodemask_tmask,intnNodes);`

Comments

(0)