Commita6417d0

authored and

committed

Exclude node from cluster on non-recoverable error

1 parentbfd72af commita6417d0Copy full SHA for a6417d0

File tree

+10

-5

lines changed

+10

-5

lines changed

Lines changed: 7 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -166,7 +166,8 @@ char const* const MtmNodeStatusMnem[] =`
`166`	`166`	`"Connected",`
`167`	`167`	`"Online",`
`168`	`168`	`"Recovery",`
`169`		`-"InMinor"`
	`169`	`+"InMinor",`
	`170`	`+"OutOfService"`
`170`	`171`	`};`
`171`	`172`
`172`	`173`	`boolMtmDoReplication;`
`@@ -1025,8 +1026,11 @@ void MtmHandleApplyError(void)`
`1025`	`1026`	`caseERRCODE_INDEX_CORRUPTED:`
`1026`	`1027`	`caseERRCODE_SYSTEM_ERROR:`
`1027`	`1028`	`caseERRCODE_INTERNAL_ERROR:`
`1028`		`-caseERRCODE_OUT_OF_MEMORY:`
`1029`		`-break;`
	`1029`	`+caseERRCODE_OUT_OF_MEMORY:`
	`1030`	`+elog(WARNING,"Node is excluded from cluster because of non-recoverable error %d",edata->sqlerrcode);`
	`1031`	`+MtmSwitchClusterMode(MTM_OUT_OF_SERVICE);`
	`1032`	`+kill(PostmasterPid,SIGQUIT);`
	`1033`	`+break;`
`1030`	`1034`	`}`
`1031`	`1035`	`}`
`1032`	`1036`

Lines changed: 3 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -97,11 +97,12 @@ typedef enum`
`97`	`97`	`typedefenum`
`98`	`98`	`{`
`99`	`99`	`MTM_INITIALIZATION,/* Initial status */`
`100`		`-MTM_OFFLINE,/* Node isout of quorum */`
	`100`	`+MTM_OFFLINE,/* Node isexcluded from cluster */`
`101`	`101`	`MTM_CONNECTED,/* Arbiter is established connections with other nodes */`
`102`	`102`	`MTM_ONLINE,/* Ready to receive client's queries */`
`103`	`103`	`MTM_RECOVERY,/* Node is in recovery process */`
`104`		`-MTM_IN_MINORITY/* Node is out of quorum */`
	`104`	`+MTM_IN_MINORITY,/* Node is out of quorum */`
	`105`	`+MTM_OUT_OF_SERVICE/* Node is not avaiable to to critical, non-recoverable error */`
`105`	`106`	`}MtmNodeStatus;`
`106`	`107`
`107`	`108`	`typedefenum`

Comments

(0)