startup.h File Reference

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Macros
#define	ereport_startup_progress(msg, ...)

Functions
void	ProcessStartupProcInterrupts (void)
pg_noreturn void	StartupProcessMain (const void *startup_data, size_t startup_data_len)
void	PreRestoreCommand (void)
void	PostRestoreCommand (void)
bool	IsPromoteSignaled (void)
void	ResetPromoteSignaled (void)
void	enable_startup_progress_timeout (void)
void	disable_startup_progress_timeout (void)
void	begin_startup_progress_phase (void)
void	startup_progress_timeout_handler (void)
bool	has_startup_progress_timeout_expired (long *secs, int *usecs)

Variables
PGDLLIMPORT int	log_startup_progress_interval

Macro Definition Documentation

ereport_startup_progress

#define ereport_startup_progress	(		msg,
			...
	)

Value:

    do { \
        long    secs; \
        int     usecs; \
		if (has_startup_progress_timeout_expired(&secs, &usecs)) \
			ereport(LOG, errmsg(msg, secs, (usecs / 10000),  __VA_ARGS__ )); \
    } while(0)

Definition at line 18 of file startup.h.

       { \
        long    secs; \
        int     usecs; \
		if (has_startup_progress_timeout_expired(&secs, &usecs)) \
			ereport(LOG, errmsg(msg, secs, (usecs / 10000),  __VA_ARGS__ )); \
    } while(0)

Function Documentation

begin_startup_progress_phase()

void begin_startup_progress_phase ( void  )

extern

Definition at line 343 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  )

extern

Definition at line 309 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  )

extern

Definition at line 323 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  )

extern

Definition at line 359 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 fb(), GetCurrentTimestamp(), now(), startup_progress_phase_start_time, startup_progress_timer_expired, and TimestampDifference().

IsPromoteSignaled()

bool IsPromoteSignaled ( void  )

extern

Definition at line 288 of file startup.c.

{
    return promote_signaled;
}

References promote_signaled.

Referenced by CheckForStandbyTrigger().

PostRestoreCommand()

void PostRestoreCommand ( void  )

extern

Definition at line 282 of file startup.c.

{
    in_restore_command = false;
}

References in_restore_command.

Referenced by RestoreArchivedFile().

PreRestoreCommand()

void PreRestoreCommand ( void  )

extern

Definition at line 268 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  )

extern

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();
}

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

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

ResetPromoteSignaled()

void ResetPromoteSignaled ( void  )

extern

Definition at line 294 of file startup.c.

{
    promote_signaled = false;
}

References promote_signaled.

Referenced by CheckForStandbyTrigger().

startup_progress_timeout_handler()

void startup_progress_timeout_handler ( void  )

extern

Definition at line 303 of file startup.c.

{
    startup_progress_timer_expired = true;
}

References startup_progress_timer_expired.

Referenced by StartupXLOG().

StartupProcessMain()

pg_noreturn void StartupProcessMain ( const void *  startup_data, size_t  startup_data_len  )

extern

Definition at line 216 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, fb(), 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.

Variable Documentation

log_startup_progress_interval

PGDLLIMPORT int log_startup_progress_interval

extern

Definition at line 76 of file startup.c.

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