v7_amit_1.patch.txt

diff --git a/src/backend/replication/logical/sequencesync.c b/src/backend/replication/logical/sequencesync.c
index ffbbd1257d0..3898b315bb8 100644
--- a/src/backend/replication/logical/sequencesync.c
+++ b/src/backend/replication/logical/sequencesync.c
@@ -111,8 +111,8 @@ static MemoryContext SequenceSyncContext = NULL;
  * unsynchronized after it exits, a new worker can be started in the next
  * iteration.
  *
- * The pointer to the sequencesync worker is cached to avoid acquiring an
- * LWLock and scanning the workers array each time via logicalrep_worker_find().
+ * The pointer to the sequencesync worker is cached to avoid scanning the
+ * workers array each time via logicalrep_worker_find().
  */
 void
 MaybeLaunchSequenceSyncWorker(void)
@@ -137,7 +137,7 @@ MaybeLaunchSequenceSyncWorker(void)
 	LWLockAcquire(LogicalRepWorkerLock, LW_SHARED);
 
 	/*
-	 * Return if the sequence sync worker for the current subscription is
+	 * Quick exit if the sequence sync worker for the current subscription is
 	 * already alive.
 	 */
 	if (sequencesync_worker &&
@@ -586,9 +586,8 @@ copy_sequences(WalReceiverConn *conn, List *seqinfos)
 			{
 				case COPYSEQ_SUCCESS:
 					elog(DEBUG1,
-						 "logical replication synchronizatio for subscription \"%s\", sequence \"%s.%s\" has been updated",
-						 MySubscription->name, seqinfo->nspname,
-						 seqinfo->seqname);
+						 "logical replication synchronization has updated sequence \"%s.%s\" in subscription \"%s\"",
+						 seqinfo->nspname, seqinfo->seqname, MySubscription->name);
 					batch_succeeded_count++;
 					sequence_copied = true;
 					break;
@@ -765,14 +764,12 @@ LogicalRepSyncSequences(WalReceiverConn *conn)
 		 * allocate them under SequenceSyncContext.
 		 */
 		oldctx = MemoryContextSwitchTo(SequenceSyncContext);
-
 		seq = palloc0_object(LogicalRepSequenceInfo);
 		seq->localrelid = subrel->srrelid;
 		seq->nspname = get_namespace_name(RelationGetNamespace(sequence_rel));
 		seq->seqname = pstrdup(RelationGetRelationName(sequence_rel));
 		seq->relstate = relstate;
 		seqinfos = lappend(seqinfos, seq);
-
 		MemoryContextSwitchTo(oldctx);
 
 		table_close(sequence_rel, NoLock);
@@ -860,7 +857,6 @@ start_sequence_sync(void)
 
 			/* Process any invalidation messages that might have accumulated */
 			AcceptInvalidationMessages();
-
 			maybe_reread_subscription();
 
 			/*
@@ -875,7 +871,6 @@ start_sequence_sync(void)
 			}
 			else
 			{
-
 				/*
 				 * Double the sleep time, but not beyond
 				 * the maximum allowable value.