From 377ee0e93aed30aaa36efdfa9a3033ee109e9b01 Mon Sep 17 00:00:00 2001 From: Robert Haas Date: Tue, 28 Jan 2014 14:55:54 -0500 Subject: [PATCH] Tidy up comments, includes. --- src/backend/replication/slot.c | 14 ++++---------- src/backend/replication/slotfuncs.c | 7 ------- 2 files changed, 4 insertions(+), 17 deletions(-) diff --git a/src/backend/replication/slot.c b/src/backend/replication/slot.c index 322b79a9c9..6ebd59a363 100644 --- a/src/backend/replication/slot.c +++ b/src/backend/replication/slot.c @@ -502,10 +502,7 @@ ReplicationSlotSave(void) } /* - * Compute the xmin between all of the decoding slots and store it in - * ReplicationSlotCtlData. - * - * If already_locked is passed in ProcArrayLock is already held exlusively. + * Compute the oldest xmin across all slots and store it in the ProcArray. */ void ReplicationSlotsComputeRequiredXmin(void) @@ -544,8 +541,7 @@ ReplicationSlotsComputeRequiredXmin(void) } /* - * Compute the xmin between all of the decoding slots and store it in - * ReplicationSlotCtlData. + * Compute the oldest restart LSN across all slots and inform xlog module. */ void ReplicationSlotsComputeRequiredLSN(void) @@ -584,8 +580,7 @@ ReplicationSlotsComputeRequiredLSN(void) /* * Check whether the server's configuration supports using replication - * slots. Usage or creating a replication slot might still fail, even if this - * function doesn't error out. + * slots. */ void CheckSlotRequirements(void) @@ -630,8 +625,7 @@ StartupReplicationSlots(XLogRecPtr checkPointRedo) struct dirent *replication_de; ereport(DEBUG1, - (errmsg("starting up replication slots from LSN %X/%X", - (uint32) (checkPointRedo >> 32), (uint32) checkPointRedo))); + (errmsg("starting up replication slots"))); /* restore all slots by iterating over all on-disk entries */ replication_dir = AllocateDir("pg_replslot"); diff --git a/src/backend/replication/slotfuncs.c b/src/backend/replication/slotfuncs.c index e89903ec62..f14a9aeb44 100644 --- a/src/backend/replication/slotfuncs.c +++ b/src/backend/replication/slotfuncs.c @@ -16,17 +16,10 @@ #include "funcapi.h" #include "miscadmin.h" - #include "access/htup_details.h" - -#include "nodes/makefuncs.h" - #include "utils/builtins.h" - #include "replication/slot.h" -#include "storage/fd.h" - Datum create_physical_replication_slot(PG_FUNCTION_ARGS); Datum drop_replication_slot(PG_FUNCTION_ARGS); -- 2.39.5