Add asserts for origin

Author: knizhnik

src/backend/replication/logical/decode.c

@@ -643,7 +643,7 @@ DecodePrepare(LogicalDecodingContext *ctx, XLogRecordBuffer *buf,
 {
 	XLogRecPtr	origin_lsn = InvalidXLogRecPtr;
 	TimestampTz	commit_time = 0;
-	XLogRecPtr	origin_id = XLogRecGetOrigin(buf->record);
+	RepOriginId	origin_id = XLogRecGetOrigin(buf->record);
 	int			i;
 	TransactionId xid = parsed->twophase_xid;
 
@@ -659,8 +659,10 @@ DecodePrepare(LogicalDecodingContext *ctx, XLogRecordBuffer *buf,
 	if (parsed->xinfo & XACT_XINFO_HAS_ORIGIN)
 	{
 		origin_lsn = parsed->origin_lsn;
-		elog(LOG, "DecodePrepate: xid=%d (%s), origin_lsn=%ld", xid, parsed->twophase_gid, origin_lsn);
+		elog(LOG, "DecodePrepare: xid=%d (%s), origin_lsn=%ld", xid, parsed->twophase_gid, origin_lsn);
 		commit_time = parsed->origin_timestamp;
+	} else { 
+		Assert(origin_id == InvalidRepOriginId);
 	}
 
 	strcpy(ctx->reorder->gid, parsed->twophase_gid);
@@ -716,7 +718,7 @@ DecodeAbort(LogicalDecodingContext *ctx, XLogRecordBuffer *buf,
 	int			i;
 	XLogRecPtr	origin_lsn = InvalidXLogRecPtr;
 	XLogRecPtr	commit_time = InvalidXLogRecPtr;
-	XLogRecPtr	origin_id = XLogRecGetOrigin(buf->record);
+	RepOriginId	origin_id = XLogRecGetOrigin(buf->record);
 
 	/*
 	 * If that is ROLLBACK PREPARED than send that to callbacks.