startup.c File Reference

#include "postgres.h"
#include "access/xlog.h"
#include "access/xlogrecovery.h"
#include "access/xlogutils.h"
#include "libpq/pqsignal.h"
#include "miscadmin.h"
#include "postmaster/auxprocess.h"
#include "postmaster/startup.h"
#include "storage/ipc.h"
#include "storage/pmsignal.h"
#include "storage/procsignal.h"
#include "storage/standby.h"
#include "utils/guc.h"
#include "utils/memutils.h"
#include "utils/timeout.h"

Include dependency graph for startup.c:

Go to the source code of this file.

Macros
#define	POSTMASTER_POLL_RATE_LIMIT   1024

Functions
static void	StartupProcTriggerHandler (SIGNAL_ARGS)
static void	StartupProcSigHupHandler (SIGNAL_ARGS)
static void	StartupProcExit (int code, Datum arg)
static void	StartupProcShutdownHandler (SIGNAL_ARGS)
static void	StartupRereadConfig (void)
void	ProcessStartupProcInterrupts (void)
void	StartupProcessMain (const void *startup_data, size_t startup_data_len)
void	PreRestoreCommand (void)
void	PostRestoreCommand (void)
bool	IsPromoteSignaled (void)
void	ResetPromoteSignaled (void)
void	startup_progress_timeout_handler (void)
void	disable_startup_progress_timeout (void)
void	enable_startup_progress_timeout (void)
void	begin_startup_progress_phase (void)
bool	has_startup_progress_timeout_expired (long *secs, int *usecs)

Variables
static volatile sig_atomic_t	got_SIGHUP = false
static volatile sig_atomic_t	shutdown_requested = false
static volatile sig_atomic_t	promote_signaled = false
static volatile sig_atomic_t	in_restore_command = false
static TimestampTz	startup_progress_phase_start_time
static volatile sig_atomic_t	startup_progress_timer_expired = false
int	log_startup_progress_interval = 10000

Macro Definition Documentation

POSTMASTER_POLL_RATE_LIMIT

#define POSTMASTER_POLL_RATE_LIMIT   1024

Definition at line 46 of file startup.c.

Function Documentation

begin_startup_progress_phase()

void begin_startup_progress_phase

(

void

)

Definition at line 347 of file startup.c.

{
    /* Feature is disabled. */
    if (log_startup_progress_interval == 0)
        return;
 
    disable_startup_progress_timeout();
    enable_startup_progress_timeout();
}

References disable_startup_progress_timeout(), enable_startup_progress_timeout(), and log_startup_progress_interval.

Referenced by PerformWalRecovery(), ResetUnloggedRelations(), and SyncDataDirectory().

disable_startup_progress_timeout()

void disable_startup_progress_timeout

(

void

)

Definition at line 313 of file startup.c.

{
    /* Feature is disabled. */
    if (log_startup_progress_interval == 0)
        return;
 
    disable_timeout(STARTUP_PROGRESS_TIMEOUT, false);
    startup_progress_timer_expired = false;
}

References disable_timeout(), log_startup_progress_interval, STARTUP_PROGRESS_TIMEOUT, and startup_progress_timer_expired.

Referenced by begin_startup_progress_phase(), and EnableStandbyMode().

enable_startup_progress_timeout()

void enable_startup_progress_timeout

(

void

)

Definition at line 327 of file startup.c.

{
    TimestampTz fin_time;
 
    /* Feature is disabled. */
    if (log_startup_progress_interval == 0)
        return;
 
    startup_progress_phase_start_time = GetCurrentTimestamp();
    fin_time = TimestampTzPlusMilliseconds(startup_progress_phase_start_time,
                                           log_startup_progress_interval);
    enable_timeout_every(STARTUP_PROGRESS_TIMEOUT, fin_time,
                         log_startup_progress_interval);
}

References enable_timeout_every(), GetCurrentTimestamp(), log_startup_progress_interval, startup_progress_phase_start_time, STARTUP_PROGRESS_TIMEOUT, and TimestampTzPlusMilliseconds.

Referenced by begin_startup_progress_phase().

has_startup_progress_timeout_expired()

bool has_startup_progress_timeout_expired	(	long *	secs,
		int *	usecs
	)

Definition at line 363 of file startup.c.

{
    long        seconds;
    int         useconds;
    TimestampTz now;
 
    /* No timeout has occurred. */
    if (!startup_progress_timer_expired)
        return false;
 
    /* Calculate the elapsed time. */
    now = GetCurrentTimestamp();
    TimestampDifference(startup_progress_phase_start_time, now, &seconds, &useconds);
 
    *secs = seconds;
    *usecs = useconds;
    startup_progress_timer_expired = false;
 
    return true;
}

References GetCurrentTimestamp(), now(), startup_progress_phase_start_time, startup_progress_timer_expired, and TimestampDifference().

IsPromoteSignaled()

bool IsPromoteSignaled

(

void

)

Definition at line 292 of file startup.c.

{
    return promote_signaled;
}

References promote_signaled.

Referenced by CheckForStandbyTrigger().

PostRestoreCommand()

void PostRestoreCommand

(

void

)

Definition at line 286 of file startup.c.

{
    in_restore_command = false;
}

References in_restore_command.

Referenced by RestoreArchivedFile().

PreRestoreCommand()

void PreRestoreCommand

(

void

)

Definition at line 272 of file startup.c.

{
    /*
     * Set in_restore_command to tell the signal handler that we should exit
     * right away on SIGTERM. We know that we're at a safe point to do that.
     * Check if we had already received the signal, so that we don't miss a
     * shutdown request received just before this.
     */
    in_restore_command = true;
    if (shutdown_requested)
        proc_exit(1);
}

References in_restore_command, proc_exit(), and shutdown_requested.

Referenced by RestoreArchivedFile().

ProcessStartupProcInterrupts()

void ProcessStartupProcInterrupts

(

void

)

Definition at line 154 of file startup.c.

{
#ifdef POSTMASTER_POLL_RATE_LIMIT
    static uint32 postmaster_poll_count = 0;
#endif
 
    /*
     * Process any requests or signals received recently.
     */
    if (got_SIGHUP)
    {
        got_SIGHUP = false;
        StartupRereadConfig();
    }
 
    /*
     * Check if we were requested to exit without finishing recovery.
     */
    if (shutdown_requested)
        proc_exit(1);
 
    /*
     * Emergency bailout if postmaster has died.  This is to avoid the
     * necessity for manual cleanup of all postmaster children.  Do this less
     * frequently on systems for which we don't have signals to make that
     * cheap.
     */
    if (IsUnderPostmaster &&
#ifdef POSTMASTER_POLL_RATE_LIMIT
        postmaster_poll_count++ % POSTMASTER_POLL_RATE_LIMIT == 0 &&
#endif
        !PostmasterIsAlive())
        exit(1);
 
    /* Process barrier events */
    if (ProcSignalBarrierPending)
        ProcessProcSignalBarrier();
 
    /* Perform logging of memory contexts of this process */
    if (LogMemoryContextPending)
        ProcessLogMemoryContextInterrupt();
 
    /* Publish memory contexts of this process */
    if (PublishMemoryContextPending)
        ProcessGetMemoryContextInterrupt();
}

References got_SIGHUP, IsUnderPostmaster, LogMemoryContextPending, POSTMASTER_POLL_RATE_LIMIT, PostmasterIsAlive, proc_exit(), ProcessGetMemoryContextInterrupt(), ProcessLogMemoryContextInterrupt(), ProcessProcSignalBarrier(), ProcSignalBarrierPending, PublishMemoryContextPending, shutdown_requested, and StartupRereadConfig().

Referenced by PerformWalRecovery(), recoveryApplyDelay(), recoveryPausesHere(), RecoveryRequiresIntParameter(), and WaitForWALToBecomeAvailable().

ResetPromoteSignaled()

void ResetPromoteSignaled

(

void

)

Definition at line 298 of file startup.c.

{
    promote_signaled = false;
}

References promote_signaled.

Referenced by CheckForStandbyTrigger().

startup_progress_timeout_handler()

void startup_progress_timeout_handler

(

void

)

Definition at line 307 of file startup.c.

{
    startup_progress_timer_expired = true;
}

References startup_progress_timer_expired.

Referenced by StartupXLOG().

StartupProcessMain()

void StartupProcessMain	(	const void *	startup_data,
		size_t	startup_data_len
	)

Definition at line 220 of file startup.c.

{
    Assert(startup_data_len == 0);
 
    MyBackendType = B_STARTUP;
    AuxiliaryProcessMainCommon();
 
    /* Arrange to clean up at startup process exit */
    on_shmem_exit(StartupProcExit, 0);
 
    /*
     * Properly accept or ignore signals the postmaster might send us.
     */
    pqsignal(SIGHUP, StartupProcSigHupHandler); /* reload config file */
    pqsignal(SIGINT, SIG_IGN);  /* ignore query cancel */
    pqsignal(SIGTERM, StartupProcShutdownHandler);  /* request shutdown */
    /* SIGQUIT handler was already set up by InitPostmasterChild */
    InitializeTimeouts();       /* establishes SIGALRM handler */
    pqsignal(SIGPIPE, SIG_IGN);
    pqsignal(SIGUSR1, procsignal_sigusr1_handler);
    pqsignal(SIGUSR2, StartupProcTriggerHandler);
 
    /*
     * Reset some signals that are accepted by postmaster but not here
     */
    pqsignal(SIGCHLD, SIG_DFL);
 
    /*
     * Register timeouts needed for standby mode
     */
    RegisterTimeout(STANDBY_DEADLOCK_TIMEOUT, StandbyDeadLockHandler);
    RegisterTimeout(STANDBY_TIMEOUT, StandbyTimeoutHandler);
    RegisterTimeout(STANDBY_LOCK_TIMEOUT, StandbyLockTimeoutHandler);
 
    /*
     * Unblock signals (they were blocked when the postmaster forked us)
     */
    sigprocmask(SIG_SETMASK, &UnBlockSig, NULL);
 
    /*
     * Do what we came for.
     */
    StartupXLOG();
 
    /*
     * Exit normally. Exit code 0 tells postmaster that we completed recovery
     * successfully.
     */
    proc_exit(0);
}

References Assert(), AuxiliaryProcessMainCommon(), B_STARTUP, InitializeTimeouts(), MyBackendType, on_shmem_exit(), pqsignal, proc_exit(), procsignal_sigusr1_handler(), RegisterTimeout(), SIGCHLD, SIGHUP, SIGPIPE, SIGUSR1, SIGUSR2, STANDBY_DEADLOCK_TIMEOUT, STANDBY_LOCK_TIMEOUT, STANDBY_TIMEOUT, StandbyDeadLockHandler(), StandbyLockTimeoutHandler(), StandbyTimeoutHandler(), StartupProcExit(), StartupProcShutdownHandler(), StartupProcSigHupHandler(), StartupProcTriggerHandler(), StartupXLOG(), and UnBlockSig.

StartupProcExit()

static void StartupProcExit ( int  code, Datum  arg  )

static

Definition at line 207 of file startup.c.

{
    /* Shutdown the recovery environment */
    if (standbyState != STANDBY_DISABLED)
        ShutdownRecoveryTransactionEnvironment();
}

References ShutdownRecoveryTransactionEnvironment(), STANDBY_DISABLED, and standbyState.

Referenced by StartupProcessMain().

StartupProcShutdownHandler()

static void StartupProcShutdownHandler ( SIGNAL_ARGS  )

static

Definition at line 109 of file startup.c.

{
    if (in_restore_command)
        proc_exit(1);
    else
        shutdown_requested = true;
    WakeupRecovery();
}

References in_restore_command, proc_exit(), shutdown_requested, and WakeupRecovery().

Referenced by StartupProcessMain().

StartupProcSigHupHandler()

static void StartupProcSigHupHandler ( SIGNAL_ARGS  )

static

Definition at line 101 of file startup.c.

{
    got_SIGHUP = true;
    WakeupRecovery();
}

References got_SIGHUP, and WakeupRecovery().

Referenced by StartupProcessMain().

StartupProcTriggerHandler()

static void StartupProcTriggerHandler ( SIGNAL_ARGS  )

static

Definition at line 93 of file startup.c.

{
    promote_signaled = true;
    WakeupRecovery();
}

References promote_signaled, and WakeupRecovery().

Referenced by StartupProcessMain().

StartupRereadConfig()

static void StartupRereadConfig ( void  )

static

Definition at line 125 of file startup.c.

{
    char       *conninfo = pstrdup(PrimaryConnInfo);
    char       *slotname = pstrdup(PrimarySlotName);
    bool        tempSlot = wal_receiver_create_temp_slot;
    bool        conninfoChanged;
    bool        slotnameChanged;
    bool        tempSlotChanged = false;
 
    ProcessConfigFile(PGC_SIGHUP);
 
    conninfoChanged = strcmp(conninfo, PrimaryConnInfo) != 0;
    slotnameChanged = strcmp(slotname, PrimarySlotName) != 0;
 
    /*
     * wal_receiver_create_temp_slot is used only when we have no slot
     * configured.  We do not need to track this change if it has no effect.
     */
    if (!slotnameChanged && strcmp(PrimarySlotName, "") == 0)
        tempSlotChanged = tempSlot != wal_receiver_create_temp_slot;
    pfree(conninfo);
    pfree(slotname);
 
    if (conninfoChanged || slotnameChanged || tempSlotChanged)
        StartupRequestWalReceiverRestart();
}

References pfree(), PGC_SIGHUP, PrimaryConnInfo, PrimarySlotName, ProcessConfigFile(), pstrdup(), StartupRequestWalReceiverRestart(), and wal_receiver_create_temp_slot.

Referenced by ProcessStartupProcInterrupts().

Variable Documentation

got_SIGHUP

volatile sig_atomic_t got_SIGHUP = false

static

Definition at line 52 of file startup.c.

Referenced by ProcessStartupProcInterrupts(), and StartupProcSigHupHandler().

in_restore_command

volatile sig_atomic_t in_restore_command = false

static

Definition at line 60 of file startup.c.

Referenced by PostRestoreCommand(), PreRestoreCommand(), and StartupProcShutdownHandler().

log_startup_progress_interval

int log_startup_progress_interval = 10000

Definition at line 76 of file startup.c.

Referenced by begin_startup_progress_phase(), disable_startup_progress_timeout(), and enable_startup_progress_timeout().

promote_signaled

volatile sig_atomic_t promote_signaled = false

static

Definition at line 54 of file startup.c.

Referenced by IsPromoteSignaled(), ResetPromoteSignaled(), and StartupProcTriggerHandler().

shutdown_requested

volatile sig_atomic_t shutdown_requested = false

static

Definition at line 53 of file startup.c.

Referenced by PreRestoreCommand(), ProcessStartupProcInterrupts(), and StartupProcShutdownHandler().

startup_progress_phase_start_time

TimestampTz startup_progress_phase_start_time

static

Definition at line 65 of file startup.c.

Referenced by enable_startup_progress_timeout(), and has_startup_progress_timeout_expired().

startup_progress_timer_expired

volatile sig_atomic_t startup_progress_timer_expired = false

static

Definition at line 71 of file startup.c.

Referenced by disable_startup_progress_timeout(), has_startup_progress_timeout_expired(), and startup_progress_timeout_handler().