diff --git a/doc/src/sgml/func/func-admin.sgml b/doc/src/sgml/func/func-admin.sgml index 17319f9f969..210b1118bdf 100644 --- a/doc/src/sgml/func/func-admin.sgml +++ b/doc/src/sgml/func/func-admin.sgml @@ -1495,7 +1495,9 @@ postgres=# SELECT '0/0'::pg_lsn + pd.segment_number * ps.setting::int + :offset Synchronize the logical failover replication slots from the primary server to the standby server. This function can only be executed on the standby server. Temporary synced slots, if any, cannot be used for - logical decoding and must be dropped after promotion. See + logical decoding and must be dropped after promotion. This function + retries cyclically until all the failover slots that existed on + primary at the start of the function call are synchronized. See for details. Note that this function cannot be executed if diff --git a/src/backend/replication/logical/slotsync.c b/src/backend/replication/logical/slotsync.c index 062a08ccb88..0c0399406f3 100644 --- a/src/backend/replication/logical/slotsync.c +++ b/src/backend/replication/logical/slotsync.c @@ -34,6 +34,10 @@ * RS_TEMPORARY. Once the decoding from corresponding LSNs can reach a * consistent point, they will be marked as RS_PERSISTENT. * + * If the WAL prior to the remote slot's confirmed_flush_lsn has not been + * flushed on the standby, the slot is marked as RS_TEMPORARY. Once the standby + * catches up and flushes that WAL, the slot will be marked as RS_PERSISTENT. + * * The slot sync worker waits for some time before the next synchronization, * with the duration varying based on whether any slots were updated during * the last cycle. Refer to the comments above wait_for_slot_activity() for @@ -218,7 +222,7 @@ update_local_synced_slot(RemoteSlot *remote_slot, Oid remote_dbid) * Can get here only if GUC 'synchronized_standby_slots' on the * primary server was not configured correctly. */ - ereport(AmLogicalSlotSyncWorkerProcess() ? LOG : ERROR, + ereport(LOG, errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE), errmsg("skipping slot synchronization because the received slot sync" " LSN %X/%08X for slot \"%s\" is ahead of the standby position %X/%08X",