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

kelvich · kelvich · commit 43612f1c1603 · 2018-08-17T15:56:01.000+03:00
diff --git a/multimaster--1.0.sql b/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/multimaster.c b/multimaster.c
@@ -4459,7 +4459,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
`@@ -4459,7 +4459,7 @@ Datum mtm_broadcast_table(PG_FUNCTION_ARGS)`
`4459`	`4459`	`{`
`4460`	`4460`	`MtmCopyRequest copy;`
`4461`	`4461`	`copy.sourceTable = PG_GETARG_OID(0);`
`4462`		`- copy.targetNodes = PG_GETARG_INT64(1);`
	`4462`	`+ copy.targetNodes = ~Mtm->disabledNodeMask;`
`4463`	`4463`	`LogLogicalMessage("B", (char*)&copy, sizeof(copy), true);`
`4464`	`4464`	`MtmTx.containsDML = true;`
`4465`	`4465`	`PG_RETURN_VOID();`