Commitc5776fb

committed

Support adding new node

1 parentbbf83b2 commitc5776fbCopy full SHA for c5776fb

File tree

-7

lines changed

-7

lines changed

Lines changed: 3 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -13,10 +13,9 @@ CREATE FUNCTION mtm.drop_node(node integer, drop_slot bool default false) RETURN`
`13`	`13`	`AS'MODULE_PATHNAME','mtm_drop_node'`
`14`	`14`	`LANGUAGE C;`
`15`	`15`
`16`		`--- -- XXX: cstring as an argument breaks sanity check`
`17`		`--- CREATE FUNCTION mtm.add_node(conn_str cstring) RETURNS void`
`18`		`--- AS 'MODULE_PATHNAME','mtm_add_node'`
`19`		`--- LANGUAGE C;`
	`16`	`+CREATEFUNCTIONmtm.add_node(conn_str cstring) RETURNS void`
	`17`	`+AS'MODULE_PATHNAME','mtm_add_node'`
	`18`	`+LANGUAGE C;`
`20`	`19`
`21`	`20`	`-- Create replication slot for the node which was previously dropped together with it's slot`
`22`	`21`	`CREATEFUNCTIONmtm.recover_node(nodeinteger) RETURNS void`

Lines changed: 3 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -1933,7 +1933,7 @@ static void MtmCheckControlFile(void)`
`1933`	`1933`	`if (f==NULL) {`
`1934`	`1934`	`elog(FATAL,"Failed to create mmts_control file: %m");`
`1935`	`1935`	`}`
`1936`		`-Mtm->donorNodeId=-1;`
	`1936`	`+Mtm->donorNodeId=MtmNodeId;`
`1937`	`1937`	`fprintf(f,"%s:%d\n",MtmClusterName,Mtm->donorNodeId);`
`1938`	`1938`	`fclose(f);`
`1939`	`1939`	`}`
`@@ -2707,7 +2707,7 @@ MtmReplicationMode MtmGetReplicationMode(int nodeId, sig_atomic_t volatile* shut`
`2707`	`2707`	`MtmLock(LW_EXCLUSIVE);`
`2708`	`2708`	`if (Mtm->status==MTM_RECOVERY) {`
`2709`	`2709`	`recovery= true;`
`2710`		`-if ((Mtm->recoverySlot==0&& (Mtm->donorNodeId<0\|\|Mtm->donorNodeId==nodeId))`
	`2710`	`+if ((Mtm->recoverySlot==0&& (Mtm->donorNodeId==MtmNodeId\|\|Mtm->donorNodeId==nodeId))`
`2711`	`2711`	`\|\|Mtm->recoverySlot==nodeId)`
`2712`	`2712`	`{`
`2713`	`2713`	`/* Choose for recovery first available slot or slot of donor node (if any) */`
`@@ -2820,7 +2820,7 @@ MtmReplicationStartupHook(struct PGLogicalStartupHookArgs* args)`
`2820`	`2820`	`}`
`2821`	`2821`	`}elseif (strcmp("mtm_restart_pos",elem->defname)==0) {`
`2822`	`2822`	`if (elem->arg!=NULL&&strVal(elem->arg)!=NULL) {`
`2823`		`-recoveryStartPos=intVal(elem->arg);`
	`2823`	`+sscanf(strVal(elem->arg),"%lx",&recoveryStartPos);`
`2824`	`2824`	`}else {`
`2825`	`2825`	`elog(ERROR,"Restart position is not specified");`
`2826`	`2826`	`}`

Comments

(0)