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

Macros
#define	MIN_XFN_CHARS 16

#define	MAX_XFN_CHARS 40

#define	VALID_XFN_CHARS "0123456789ABCDEF.history.backup.partial"

Functions
Size	PgArchShmemSize (void)

void	PgArchShmemInit (void)

bool	PgArchCanRestart (void)

void	PgArchiverMain (void) pg_attribute_noreturn()

void	PgArchWakeup (void)

void	PgArchForceDirScan (void)

Macro Definition Documentation

◆ MAX_XFN_CHARS

#define MAX_XFN_CHARS 40

Definition at line 26 of file pgarch.h.

◆ MIN_XFN_CHARS

#define MIN_XFN_CHARS 16

Definition at line 25 of file pgarch.h.

◆ VALID_XFN_CHARS

#define VALID_XFN_CHARS "0123456789ABCDEF.history.backup.partial"

Definition at line 27 of file pgarch.h.

Function Documentation

◆ PgArchCanRestart()

bool PgArchCanRestart ( void )

Definition at line 192 of file pgarch.c.

 {
     static time_t last_pgarch_start_time = 0;
     time_t      curtime = time(NULL);
  
     /*
      * Return false and don't restart archiver if too soon since last archiver
      * start.
      */
     if ((unsigned int) (curtime - last_pgarch_start_time) <
         (unsigned int) PGARCH_RESTART_INTERVAL)
         return false;
  
     last_pgarch_start_time = curtime;

References PGARCH_RESTART_INTERVAL.

◆ PgArchForceDirScan()

void PgArchForceDirScan ( void )

Definition at line 710 of file pgarch.c.

 {
     SpinLockAcquire(&PgArch->arch_lck);
     PgArch->force_dir_scan = true;

References PgArchData::arch_lck, PgArchData::force_dir_scan, PgArch, SpinLockAcquire, and SpinLockRelease.

Referenced by XLogArchiveNotify().

◆ PgArchiverMain()

void PgArchiverMain ( void )

Definition at line 212 of file pgarch.c.

 {
     /*
      * Ignore all signals usually bound to some action in the postmaster,
      * except for SIGHUP, SIGTERM, SIGUSR1, SIGUSR2, and SIGQUIT.
      */
     pqsignal(SIGHUP, SignalHandlerForConfigReload);
     pqsignal(SIGINT, SIG_IGN);
     pqsignal(SIGTERM, SignalHandlerForShutdownRequest);
     /* SIGQUIT handler was already set up by InitPostmasterChild */
     pqsignal(SIGALRM, SIG_IGN);
     pqsignal(SIGPIPE, SIG_IGN);
     pqsignal(SIGUSR1, procsignal_sigusr1_handler);
     pqsignal(SIGUSR2, pgarch_waken_stop);
  
     /* Reset some signals that are accepted by postmaster but not here */
     pqsignal(SIGCHLD, SIG_DFL);
  
     /* Unblock signals (they were blocked when the postmaster forked us) */
     sigprocmask(SIG_SETMASK, &UnBlockSig, NULL);
  
     /* We shouldn't be launched unnecessarily. */
     Assert(XLogArchivingActive());
  
     /* Arrange to clean up at archiver exit */
     on_shmem_exit(pgarch_die, 0);
  
     /*
      * Advertise our pgprocno so that backends can use our latch to wake us up
      * while we're sleeping.
      */
     PgArch->pgprocno = MyProc->pgprocno;
  
     /* Create workspace for pgarch_readyXlog() */
     arch_files = palloc(sizeof(struct arch_files_state));
     arch_files->arch_files_size = 0;
  
     /* Initialize our max-heap for prioritizing files to archive. */
     arch_files->arch_heap = binaryheap_allocate(NUM_FILES_PER_DIRECTORY_SCAN,
                                                 ready_file_comparator, NULL);
  
     /* Load the archive_library. */
     LoadArchiveLibrary();
  
     pgarch_MainLoop();
  

References arch_files, arch_files_state::arch_files_size, arch_files_state::arch_heap, Assert(), binaryheap_allocate(), LoadArchiveLibrary(), MyProc, NUM_FILES_PER_DIRECTORY_SCAN, on_shmem_exit(), palloc(), PgArch, pgarch_die(), pgarch_MainLoop(), pgarch_waken_stop(), PgArchData::pgprocno, PGPROC::pgprocno, pqsignal(), proc_exit(), procsignal_sigusr1_handler(), ready_file_comparator(), SIG_DFL, SIG_IGN, SIGALRM, SIGCHLD, SIGHUP, SignalHandlerForConfigReload(), SignalHandlerForShutdownRequest(), SIGPIPE, SIGUSR1, SIGUSR2, UnBlockSig, and XLogArchivingActive.

Referenced by AuxiliaryProcessMain().

◆ PgArchShmemInit()

void PgArchShmemInit ( void )

Definition at line 163 of file pgarch.c.

 {
     bool        found;
  
     PgArch = (PgArchData *)
         ShmemInitStruct("Archiver Data", PgArchShmemSize(), &found);
  
     if (!found)
     {
         /* First time through, so initialize */
         MemSet(PgArch, 0, PgArchShmemSize());
         PgArch->pgprocno = INVALID_PGPROCNO;
         SpinLockInit(&PgArch->arch_lck);

References PgArchData::arch_lck, INVALID_PGPROCNO, MemSet, PgArch, PgArchShmemSize(), PgArchData::pgprocno, ShmemInitStruct(), and SpinLockInit.

Referenced by CreateSharedMemoryAndSemaphores().

◆ PgArchShmemSize()

Size PgArchShmemSize ( void )

Definition at line 152 of file pgarch.c.

 {
     Size        size = 0;
  
     size = add_size(size, sizeof(PgArchData));
  

References add_size().

Referenced by CalculateShmemSize(), and PgArchShmemInit().

◆ PgArchWakeup()

void PgArchWakeup ( void )

Definition at line 265 of file pgarch.c.

 {
     int         arch_pgprocno = PgArch->pgprocno;
  
     /*
      * We don't acquire ProcArrayLock here.  It's actually fine because
      * procLatch isn't ever freed, so we just can potentially set the wrong
      * process' (or no process') latch.  Even in that case the archiver will
      * be relaunched shortly and will start archiving.
      */
     if (arch_pgprocno != INVALID_PGPROCNO)

References PROC_HDR::allProcs, INVALID_PGPROCNO, PgArch, PgArchData::pgprocno, ProcGlobal, PGPROC::procLatch, and SetLatch().