fix wrong parsing of logical messages header

kelvich · kelvich · commit c4d84e834962 · 2016-12-05T14:31:15.000+03:00
diff --git a/contrib/mmts/pglogical_receiver.c b/contrib/mmts/pglogical_receiver.c
@@ -533,7 +533,7 @@ pglogical_receiver_main(Datum main_arg)
 						MtmSpillToFile(spill_file, buf.data, buf.used);
 						ByteBufferReset(&buf);
 					}
-					if (stmt[0] == 'M' && (stmt[1] == 'L' || stmt[1] == 'C' || stmt[1] == 'A')) {
+					if (stmt[0] == 'M' && (stmt[1] == 'L' || stmt[1] == 'A')) {
 						MTM_LOG3("Process '%c' message from %d", stmt[1], nodeId);
 						MtmExecutor(stmt, rc - hdr_len);
 					} else { 

Original file line number	Diff line number	Diff line change
`@@ -533,7 +533,7 @@ pglogical_receiver_main(Datum main_arg)`
`533`	`533`	`MtmSpillToFile(spill_file, buf.data, buf.used);`
`534`	`534`	`ByteBufferReset(&buf);`
`535`	`535`	`}`
`536`		`- if (stmt[0] == 'M' && (stmt[1] == 'L' \|\| stmt[1] == 'C' \|\| stmt[1] == 'A')) {`
	`536`	`+ if (stmt[0] == 'M' && (stmt[1] == 'L' \|\| stmt[1] == 'A')) {`
`537`	`537`	`MTM_LOG3("Process '%c' message from %d", stmt[1], nodeId);`
`538`	`538`	`MtmExecutor(stmt, rc - hdr_len);`
`539`	`539`	`} else {`