mtm_broadcast_table: broadcast to all enabled nodes, instead of taking bitmask as a parameter

kelvich · kelvich · commit cb3e70b84fed · 2018-03-27T19:20:08.000+03:00
diff --git a/contrib/mmts/multimaster--1.0.sql b/contrib/mmts/multimaster--1.0.sql
@@ -84,7 +84,7 @@ CREATE FUNCTION mtm.make_table_local(relation regclass) RETURNS void
 AS 'MODULE_PATHNAME','mtm_make_table_local'
 LANGUAGE C;
 
-CREATE FUNCTION mtm.broadcast_table(srcTable regclass, dstNodesMask bigint) RETURNS void
+CREATE FUNCTION mtm.broadcast_table(srcTable regclass) RETURNS void
 AS 'MODULE_PATHNAME','mtm_broadcast_table'
 LANGUAGE C;
 
diff --git a/contrib/mmts/multimaster.c b/contrib/mmts/multimaster.c
@@ -4464,7 +4464,7 @@ Datum mtm_broadcast_table(PG_FUNCTION_ARGS)
 {
 	MtmCopyRequest copy;
 	copy.sourceTable = PG_GETARG_OID(0);
-	copy.targetNodes = PG_GETARG_INT64(1);
+	copy.targetNodes = ~Mtm->disabledNodeMask;
 	LogLogicalMessage("B", (char*)&copy, sizeof(copy), true);
 	MtmTx.containsDML = true;
 	PG_RETURN_VOID();

Original file line number	Diff line number	Diff line change
`@@ -4464,7 +4464,7 @@ Datum mtm_broadcast_table(PG_FUNCTION_ARGS)`
`4464`	`4464`	`{`
`4465`	`4465`	`MtmCopyRequest copy;`
`4466`	`4466`	`copy.sourceTable = PG_GETARG_OID(0);`
`4467`		`- copy.targetNodes = PG_GETARG_INT64(1);`
	`4467`	`+ copy.targetNodes = ~Mtm->disabledNodeMask;`
`4468`	`4468`	`LogLogicalMessage("B", (char*)&copy, sizeof(copy), true);`
`4469`	`4469`	`MtmTx.containsDML = true;`
`4470`	`4470`	`PG_RETURN_VOID();`