Renamed variable which is not specific to partitioning.

Author: Antonin Houska

concurrent.c

@@ -161,12 +161,12 @@ pg_rewrite_decode_concurrent_changes(LogicalDecodingContext *ctx,
 			 */
 			end_lsn = ctx->reader->EndRecPtr;
 			XLByteToSeg(end_lsn, segno_new, wal_segment_size);
-			if (segno_new != part_current_segment)
+			if (segno_new != rewrite_current_segment)
 			{
 				LogicalConfirmReceivedLocation(end_lsn);
 				elog(DEBUG1, "pg_rewrite: confirmed receive location %X/%X",
 					 (uint32) (end_lsn >> 32), (uint32) end_lsn);
-				part_current_segment = segno_new;
+				rewrite_current_segment = segno_new;
 			}
 
 			pg_rewrite_exit_if_requested();

pg_rewrite.c

@@ -77,7 +77,7 @@ static void partition_table_impl(Oid dbid, Oid roleid, char *relschema_src,
 static int	index_cat_info_compare(const void *arg1, const void *arg2);
 
 /* The WAL segment being decoded. */
-XLogSegNo	part_current_segment = 0;
+XLogSegNo	rewrite_current_segment = 0;
 
 /*
  * Information on a single constraint, needed to compare constraints of the
@@ -1466,7 +1466,7 @@ setup_decoding(Oid relid, TupleDesc tup_desc)
 	/* Some WAL records should have been read. */
 	Assert(ctx->reader->EndRecPtr != InvalidXLogRecPtr);
 
-	XLByteToSeg(ctx->reader->EndRecPtr, part_current_segment,
+	XLByteToSeg(ctx->reader->EndRecPtr, rewrite_current_segment,
 				wal_segment_size);
 
 	/*

pg_rewrite.h

@@ -93,7 +93,7 @@ typedef struct DecodingOutputState
 } DecodingOutputState;
 
 /* The WAL segment being decoded. */
-extern XLogSegNo part_current_segment;
+extern XLogSegNo rewrite_current_segment;
 
 extern void _PG_init(void);