Add assertion for origin id in xact_redo

knizhnik · knizhnik · commit 36b236cd4050 · 2016-10-25T23:12:55.000+03:00
diff --git a/src/backend/access/transam/xact.c b/src/backend/access/transam/xact.c
@@ -5667,6 +5667,7 @@ xact_redo(XLogReaderState *record)
 
 		if (parsed.xinfo & XACT_XINFO_HAS_ORIGIN)
 		{
+			Assert(XLogRecGetOrigin(record) != InvalidRepOriginId);
 			/* recover apply progress */
 			replorigin_advance(XLogRecGetOrigin(record), parsed.origin_lsn,
 						record->EndRecPtr, false /* backward */ , false /* WAL */ );

Original file line number	Diff line number	Diff line change
`@@ -5667,6 +5667,7 @@ xact_redo(XLogReaderState *record)`
`5667`	`5667`
`5668`	`5668`	`if (parsed.xinfo & XACT_XINFO_HAS_ORIGIN)`
`5669`	`5669`	`{`
	`5670`	`+ Assert(XLogRecGetOrigin(record) != InvalidRepOriginId);`
`5670`	`5671`	`/* recover apply progress */`
`5671`	`5672`	`replorigin_advance(XLogRecGetOrigin(record), parsed.origin_lsn,`
`5672`	`5673`	`record->EndRecPtr, false /* backward / , false / WAL */ );`