try run over farm without MtmFilterTransaction #2

kelvich · kelvich · commit 5c9f89fab771 · 2018-01-29T18:22:07.000+03:00
diff --git a/multimaster.c b/multimaster.c
@@ -3787,8 +3787,8 @@ bool MtmFilterTransaction(char* record, int size)
 		break;
 	}
 
-	// if (event != PGLOGICAL_COMMIT_PREPARED)
-	return false;
+	if (event != PGLOGICAL_COMMIT_PREPARED)
+		return false;
 
 	restart_lsn = origin_node == MtmReplicationNodeId ? end_lsn : origin_lsn;
 	if (Mtm->nodes[origin_node-1].restartLSN < restart_lsn) {
diff --git a/multimaster.h b/multimaster.h
@@ -41,7 +41,7 @@
 #define MTM_LOG4(fmt, ...) fprintf(stderr, fmt "\n", ## __VA_ARGS__)
 #endif
 
-// #define MTM_TXFINISH 1
+#define MTM_TXFINISH 1
 
 #ifndef MTM_TXFINISH
 #define TXFINISH(fmt, ...)

Original file line number	Diff line number	Diff line change
`@@ -3787,8 +3787,8 @@ bool MtmFilterTransaction(char* record, int size)`
`3787`	`3787`	`break;`
`3788`	`3788`	`}`
`3789`	`3789`
`3790`		`- // if (event != PGLOGICAL_COMMIT_PREPARED)`
`3791`		`- return false;`
	`3790`	`+ if (event != PGLOGICAL_COMMIT_PREPARED)`
	`3791`	`+ return false;`
`3792`	`3792`
`3793`	`3793`	`restart_lsn = origin_node == MtmReplicationNodeId ? end_lsn : origin_lsn;`
`3794`	`3794`	`if (Mtm->nodes[origin_node-1].restartLSN < restart_lsn) {`