From b8539cb67e302661cf26321d4fa8bf7dbf37f1bd Mon Sep 17 00:00:00 2001
From: Rajesh Kumar Thandapani <rthandapani@microsoft.com>
Date: Thu, 24 Nov 2022 22:40:02 +0530
Subject: [PATCH] Added function comments.

---
 src/backend/distributed/operations/worker_shard_copy.c | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/src/backend/distributed/operations/worker_shard_copy.c b/src/backend/distributed/operations/worker_shard_copy.c
index ce00a2e73..2178c6186 100644
--- a/src/backend/distributed/operations/worker_shard_copy.c
+++ b/src/backend/distributed/operations/worker_shard_copy.c
@@ -288,6 +288,9 @@ ShardCopyDestReceiverStartup(DestReceiver *dest, int operation, TupleDesc
 }
 
 
+/* CreateReplicationOriginIfNotExists creates a replication origin if it does
+ * not already exist already. To make the origin id unique for different nodes,
+ * origin node's id is appended to the prefix citus_cdc_.*/
 static void
 CreateReplicationOriginIfNotExists(ShardCopyDestReceiver *dest)
 {