}
/*
- * 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)
}
/*
- * 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)
/*
* 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)
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");
#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);