NotificationsYou must be signed in to change notification settings
Fork28
Star151

Commit9e8de2e

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 parent83054dc commit9e8de2eCopy full SHA for 9e8de2e

File tree

1 file changed

-1

lines changed

state.c

1 file changed

-1

lines changed

`‎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!

Commit9e8de2e

File tree

1 file changed

1 file changed

`‎state.c`

0 commit comments