Commit80fb551

committed

Wait for gen with new node in join_node.

1 parent26db1c2 commit80fb551Copy full SHA for 80fb551

File tree

+13

-0

lines changed

+13

-0

lines changed

Lines changed: 13 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -1428,6 +1428,19 @@ mtm_join_node(PG_FUNCTION_ARGS)`
`1428`	`1428`	`}`
`1429`	`1429`	`PQclear(res);`
`1430`	`1430`
	`1431`	`+/*`
	`1432`	`+ * FIXME: await for new node joining or there is a small probablity of`
	`1433`	`+ * this (alter_sequences) xact commit failure due to gen switch including`
	`1434`	`+ * new node.`
	`1435`	`+ */`
	`1436`	`+while (true)`
	`1437`	`+{`
	`1438`	`+MtmGenerationcurr_gen=MtmGetCurrentGen(false);`
	`1439`	`+`
	`1440`	`+if (BIT_CHECK(curr_gen.members,new_node_id-1))`
	`1441`	`+break;`
	`1442`	`+MtmSleep(USECS_PER_SEC /10);`
	`1443`	`+}`
`1431`	`1444`	`/* call mtm.alter_sequences since n_nodes is changed */`
`1432`	`1445`	`query=psprintf("select mtm.alter_sequences()");`
`1433`	`1446`	`rc=SPI_execute(query, false,0);`

Comments

(0)