/* prototypes for local functions */
static void ApplyWalRecord(XLogReaderState *xlogreader, XLogRecord *record, TimeLineID *replayTLI);
-static void EnableStandbyMode(void);
static void readRecoverySignalFile(void);
static void validateRecoveryParameters(void);
static bool read_backup_label(XLogRecPtr *checkPointLoc,
ConditionVariableInit(&XLogRecoveryCtl->recoveryNotPausedCV);
}
-/*
- * A thin wrapper to enable StandbyMode and do other preparatory work as
- * needed.
- */
-static void
-EnableStandbyMode(void)
-{
- StandbyMode = true;
-
- /*
- * To avoid server log bloat, we don't report recovery progress in a
- * standby as it will always be in recovery unless promoted. We disable
- * startup progress timeout in standby mode to avoid calling
- * startup_progress_timeout_handler() unnecessarily.
- */
- disable_startup_progress_timeout();
-}
-
/*
* Prepare the system for WAL recovery, if needed.
*
*/
InArchiveRecovery = true;
if (StandbyModeRequested)
- EnableStandbyMode();
+ StandbyMode = true;
/*
* When a backup_label file is present, we want to roll forward from
{
InArchiveRecovery = true;
if (StandbyModeRequested)
- EnableStandbyMode();
+ StandbyMode = true;
}
/* Get the last valid checkpoint record. */
(errmsg_internal("reached end of WAL in pg_wal, entering archive recovery")));
InArchiveRecovery = true;
if (StandbyModeRequested)
- EnableStandbyMode();
+ StandbyMode = true;
SwitchIntoArchiveRecovery(xlogreader->EndRecPtr, replayTLI);
minRecoveryPoint = xlogreader->EndRecPtr;
startup_progress_timer_expired = true;
}
-void
-disable_startup_progress_timeout(void)
-{
- /* Feature is disabled. */
- if (log_startup_progress_interval == 0)
- return;
-
- disable_timeout(STARTUP_PROGRESS_TIMEOUT, false);
- startup_progress_timer_expired = false;
-}
-
/*
* Set the start timestamp of the current operation and enable the timeout.
*/
void
-enable_startup_progress_timeout(void)
+begin_startup_progress_phase(void)
{
TimestampTz fin_time;
if (log_startup_progress_interval == 0)
return;
+ disable_timeout(STARTUP_PROGRESS_TIMEOUT, false);
+ startup_progress_timer_expired = false;
startup_progress_phase_start_time = GetCurrentTimestamp();
fin_time = TimestampTzPlusMilliseconds(startup_progress_phase_start_time,
log_startup_progress_interval);
log_startup_progress_interval);
}
-/*
- * A thin wrapper to first disable and then enable the startup progress
- * timeout.
- */
-void
-begin_startup_progress_phase(void)
-{
- /* Feature is disabled. */
- if (log_startup_progress_interval == 0)
- return;
-
- disable_startup_progress_timeout();
- enable_startup_progress_timeout();
-}
-
/*
* Report whether startup progress timeout has occurred. Reset the timer flag
* if it did, set the elapsed time to the out parameters and return true,
extern bool IsPromoteSignaled(void);
extern void ResetPromoteSignaled(void);
-extern void enable_startup_progress_timeout(void);
-extern void disable_startup_progress_timeout(void);
extern void begin_startup_progress_phase(void);
extern void startup_progress_timeout_handler(void);
extern bool has_startup_progress_timeout_expired(long *secs, int *usecs);