1 files changed, 19 insertions, 19 deletions

diff --git a/src/backend/replication/logical/proto.c b/src/backend/replication/logical/proto.c
index adc62a0f3bb..ff348ff2a8c 100644
--- a/src/backend/replication/logical/proto.c
+++ b/src/backend/replication/logical/proto.c
@@ -28,7 +28,7 @@
 
 static void logicalrep_write_attrs(StringInfo out, Relation rel);
 static void logicalrep_write_tuple(StringInfo out, Relation rel,
-								   HeapTuple tuple);
+					   HeapTuple tuple);
 
 static void logicalrep_read_attrs(StringInfo in, LogicalRepRelation *rel);
 static void logicalrep_read_tuple(StringInfo in, LogicalRepTupleData *tuple);
@@ -72,7 +72,7 @@ void
 logicalrep_write_commit(StringInfo out, ReorderBufferTXN *txn,
 						XLogRecPtr commit_lsn)
 {
-	uint8 flags = 0;
+	uint8		flags = 0;
 
 	pq_sendbyte(out, 'C');		/* sending COMMIT */
 
@@ -92,7 +92,7 @@ void
 logicalrep_read_commit(StringInfo in, LogicalRepCommitData *commit_data)
 {
 	/* read flags (unused for now) */
-	uint8   flags = pq_getmsgbyte(in);
+	uint8		flags = pq_getmsgbyte(in);
 
 	if (flags != 0)
 		elog(ERROR, "unrecognized flags %u in commit message", flags);
@@ -136,7 +136,7 @@ logicalrep_read_origin(StringInfo in, XLogRecPtr *origin_lsn)
  * Write INSERT to the output stream.
  */
 void
-logicalrep_write_insert(StringInfo out,	Relation rel, HeapTuple newtuple)
+logicalrep_write_insert(StringInfo out, Relation rel, HeapTuple newtuple)
 {
 	pq_sendbyte(out, 'I');		/* action INSERT */
 
@@ -160,7 +160,7 @@ LogicalRepRelId
 logicalrep_read_insert(StringInfo in, LogicalRepTupleData *newtup)
 {
 	char		action;
-	LogicalRepRelId		relid;
+	LogicalRepRelId relid;
 
 	/* read the relation id */
 	relid = pq_getmsgint(in, 4);
@@ -180,7 +180,7 @@ logicalrep_read_insert(StringInfo in, LogicalRepTupleData *newtup)
  */
 void
 logicalrep_write_update(StringInfo out, Relation rel, HeapTuple oldtuple,
-					   HeapTuple newtuple)
+						HeapTuple newtuple)
 {
 	pq_sendbyte(out, 'U');		/* action UPDATE */
 
@@ -194,9 +194,9 @@ logicalrep_write_update(StringInfo out, Relation rel, HeapTuple oldtuple,
 	if (oldtuple != NULL)
 	{
 		if (rel->rd_rel->relreplident == REPLICA_IDENTITY_FULL)
-			pq_sendbyte(out, 'O');	/* old tuple follows */
+			pq_sendbyte(out, 'O');		/* old tuple follows */
 		else
-			pq_sendbyte(out, 'K');	/* old key follows */
+			pq_sendbyte(out, 'K');		/* old key follows */
 		logicalrep_write_tuple(out, rel, oldtuple);
 	}
 
@@ -213,7 +213,7 @@ logicalrep_read_update(StringInfo in, bool *has_oldtuple,
 					   LogicalRepTupleData *newtup)
 {
 	char		action;
-	LogicalRepRelId		relid;
+	LogicalRepRelId relid;
 
 	/* read the relation id */
 	relid = pq_getmsgint(in, 4);
@@ -277,7 +277,7 @@ LogicalRepRelId
 logicalrep_read_delete(StringInfo in, LogicalRepTupleData *oldtup)
 {
 	char		action;
-	LogicalRepRelId		relid;
+	LogicalRepRelId relid;
 
 	/* read the relation id */
 	relid = pq_getmsgint(in, 4);
@@ -323,7 +323,7 @@ logicalrep_write_rel(StringInfo out, Relation rel)
 LogicalRepRelation *
 logicalrep_read_rel(StringInfo in)
 {
-	LogicalRepRelation	*rel = palloc(sizeof(LogicalRepRelation));
+	LogicalRepRelation *rel = palloc(sizeof(LogicalRepRelation));
 
 	rel->remoteid = pq_getmsgint(in, 4);
 
@@ -424,12 +424,12 @@ logicalrep_write_tuple(StringInfo out, Relation rel, HeapTuple tuple)
 
 		if (isnull[i])
 		{
-			pq_sendbyte(out, 'n');	/* null column */
+			pq_sendbyte(out, 'n');		/* null column */
 			continue;
 		}
 		else if (att->attlen == -1 && VARATT_IS_EXTERNAL_ONDISK(values[i]))
 		{
-			pq_sendbyte(out, 'u');	/* unchanged toast column */
+			pq_sendbyte(out, 'u');		/* unchanged toast column */
 			continue;
 		}
 
@@ -473,21 +473,21 @@ logicalrep_read_tuple(StringInfo in, LogicalRepTupleData *tuple)
 
 		switch (kind)
 		{
-			case 'n': /* null */
+			case 'n':			/* null */
 				tuple->values[i] = NULL;
 				tuple->changed[i] = true;
 				break;
-			case 'u': /* unchanged column */
+			case 'u':			/* unchanged column */
 				/* we don't receive the value of an unchanged column */
 				tuple->values[i] = NULL;
 				break;
-			case 't': /* text formatted value */
+			case 't':			/* text formatted value */
 				{
 					int			len;
 
 					tuple->changed[i] = true;
 
-					len = pq_getmsgint(in, 4); /* read length */
+					len = pq_getmsgint(in, 4);	/* read length */
 
 					/* and data */
 					tuple->values[i] = palloc(len + 1);
@@ -534,7 +534,7 @@ logicalrep_write_attrs(StringInfo out, Relation rel)
 	for (i = 0; i < desc->natts; i++)
 	{
 		Form_pg_attribute att = desc->attrs[i];
-		uint8			flags = 0;
+		uint8		flags = 0;
 
 		if (att->attisdropped)
 			continue;
@@ -612,7 +612,7 @@ logicalrep_write_namespace(StringInfo out, Oid nspid)
 		pq_sendbyte(out, '\0');
 	else
 	{
-		char *nspname = get_namespace_name(nspid);
+		char	   *nspname = get_namespace_name(nspid);
 
 		if (nspname == NULL)
 			elog(ERROR, "cache lookup failed for namespace %u",