NotificationsYou must be signed in to change notification settings
Fork28
Star151

Commitedc185e

committed

calculate nConnected based on SELF_CONNECTIVITY_MASK instead of EFFECTIVE_CONNECTIVITY_MASK. Old logic jumped from recovery status to disabled when node was cleaning it state on referee.

1 parenta7df540 commitedc185eCopy full SHA for edc185e

File tree

1 file changed

-1

lines changed

contrib/mmts
- state.c

1 file changed

-1

lines changed

`‎contrib/mmts/state.c`

Lines changed: 3 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -71,6 +71,8 @@ MtmSetClusterStatus(MtmNodeStatus status)`
`71`	`71`	`Mtm->recoverySlot=0;`
`72`	`72`	`Mtm->pglogicalReceiverMask=0;`
`73`	`73`	`Mtm->pglogicalSenderMask=0;`
	`74`	`+// XXXX: better to enable, but not now. It requires better testing`
	`75`	`+// Mtm->recoveryCount++; /* this will restart replication connection */`
`74`	`76`	`}`
`75`	`77`
`76`	`78`	`Mtm->status=status;`
`@@ -82,7 +84,7 @@ MtmCheckState(void)`
`82`	`84`	`// int nVotingNodes = MtmGetNumberOfVotingNodes();`
`83`	`85`	`boolisEnabledState;`
`84`	`86`	`intnEnabled=countZeroBits(Mtm->disabledNodeMask,Mtm->nAllNodes);`
`85`		`-intnConnected=countZeroBits(EFFECTIVE_CONNECTIVITY_MASK,Mtm->nAllNodes);`
	`87`	`+intnConnected=countZeroBits(SELF_CONNECTIVITY_MASK,Mtm->nAllNodes);`
`86`	`88`	`intnReceivers=Mtm->nAllNodes-countZeroBits(Mtm->pglogicalReceiverMask,Mtm->nAllNodes);`
`87`	`89`	`intnSenders=Mtm->nAllNodes-countZeroBits(Mtm->pglogicalSenderMask,Mtm->nAllNodes);`
`88`	`90`

0 commit comments

Comments

(0)

Movatterモバイル変換

Navigation Menu

Search code, repositories, users, issues, pull requests...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commitedc185e

File tree

1 file changed

1 file changed

`‎contrib/mmts/state.c`

0 commit comments