From 87a4fcd75bef661c6121da324dda545233280d2f Mon Sep 17 00:00:00 2001 From: Suhas Thalanki Date: Fri, 12 Dec 2025 18:40:41 +0530 Subject: [PATCH 1/3] added log statements --- src/backend/replication/slot.c | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/backend/replication/slot.c b/src/backend/replication/slot.c index 47a1e23d27d..1bcf3f62c64 100644 --- a/src/backend/replication/slot.c +++ b/src/backend/replication/slot.c @@ -502,9 +502,10 @@ SearchNamedReplicationSlot(const char *name, bool need_lock) for (i = 0; i < max_replication_slots; i++) { ReplicationSlot *s = &ReplicationSlotCtl->replication_slots[i]; - + elog(INFO, "ReplicationSlot: %s", NameStr(s->data.name)); if (s->in_use && strcmp(name, NameStr(s->data.name)) == 0) { + elog(INFO, "ReplicationSlot: found %s", NameStr(s->data.name)); slot = s; break; } From 78e665a20e915a8831f0289ce50f7f01d6d58a31 Mon Sep 17 00:00:00 2001 From: Suhas Thalanki Date: Mon, 5 Jan 2026 14:45:42 +0530 Subject: [PATCH 2/3] add one more log line --- src/backend/replication/slot.c | 1 + 1 file changed, 1 insertion(+) diff --git a/src/backend/replication/slot.c b/src/backend/replication/slot.c index 1bcf3f62c64..76b259729e3 100644 --- a/src/backend/replication/slot.c +++ b/src/backend/replication/slot.c @@ -1929,6 +1929,7 @@ StartupReplicationSlots(void) continue; snprintf(path, sizeof(path), "pg_replslot/%s", replication_de->d_name); + elog(INFO, "restoring replication slot from \"%s\"", replication_de->d_name); de_type = get_dirent_type(path, replication_de, false, DEBUG1); /* we're only creating directories here, skip if it's not our's */ From 77b7fba36a6d9da01a7145a9ffd2fcf96b5bf873 Mon Sep 17 00:00:00 2001 From: Suhas Thalanki Date: Mon, 5 Jan 2026 15:00:41 +0530 Subject: [PATCH 3/3] update log level to warning --- src/backend/replication/slot.c | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/backend/replication/slot.c b/src/backend/replication/slot.c index 76b259729e3..23e16b08980 100644 --- a/src/backend/replication/slot.c +++ b/src/backend/replication/slot.c @@ -502,10 +502,10 @@ SearchNamedReplicationSlot(const char *name, bool need_lock) for (i = 0; i < max_replication_slots; i++) { ReplicationSlot *s = &ReplicationSlotCtl->replication_slots[i]; - elog(INFO, "ReplicationSlot: %s", NameStr(s->data.name)); + elog(WARNING, "ReplicationSlot: %s", NameStr(s->data.name)); if (s->in_use && strcmp(name, NameStr(s->data.name)) == 0) { - elog(INFO, "ReplicationSlot: found %s", NameStr(s->data.name)); + elog(WARNING, "ReplicationSlot: found %s", NameStr(s->data.name)); slot = s; break; } @@ -1929,7 +1929,7 @@ StartupReplicationSlots(void) continue; snprintf(path, sizeof(path), "pg_replslot/%s", replication_de->d_name); - elog(INFO, "restoring replication slot from \"%s\"", replication_de->d_name); + elog(WARNING, "restoring replication slot from \"%s\"", replication_de->d_name); de_type = get_dirent_type(path, replication_de, false, DEBUG1); /* we're only creating directories here, skip if it's not our's */