Commitc144b05

authored and

committed

Add pooling of all nodes

1 parent2e82abe commitc144b05Copy full SHA for c144b05

File tree

-1

lines changed

-1

lines changed

Lines changed: 3 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -2267,7 +2267,9 @@ mtm_poll_node(PG_FUNCTION_ARGS)`
`2267`	`2267`	`intnodeId=PG_GETARG_INT32(0);`
`2268`	`2268`	`boolnowait=PG_GETARG_BOOL(1);`
`2269`	`2269`	`boolonline= true;`
`2270`		`-while (BIT_CHECK(Mtm->disabledNodeMask,nodeId-1)) {`
	`2270`	`+while ((nodeId==MtmNodeId&&Mtm->status!=MTM_ONLINE)`
	`2271`	`+\|\| (nodeId=!MtmNodeId&&BIT_CHECK(Mtm->disabledNodeMask,nodeId-1)))`
	`2272`	`+{`
`2271`	`2273`	`if (nowait) {`
`2272`	`2274`	`online= false;`
`2273`	`2275`	`break;`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -64,6 +64,7 @@`
`64`	`64`
`65`	`65`	`$cluster->psql(0,'postgres',"select mtm.poll_node(3);");`
`66`	`66`	`$cluster->psql(1,'postgres',"select mtm.poll_node(3);");`
	`67`	`+$cluster->psql(2,'postgres',"select mtm.poll_node(3);");`
`67`	`68`	`diag("inserting 3");`
`68`	`69`
`69`	`70`	`$cluster->psql(0,'postgres',"insert into t values(3, 30);");`

Comments

(0)