shell_archive.c File Reference

#include "postgres.h"
#include <sys/wait.h>
#include "access/xlog.h"
#include "archive/archive_module.h"
#include "archive/shell_archive.h"
#include "common/percentrepl.h"
#include "pgstat.h"
#include "utils/wait_event.h"

Include dependency graph for shell_archive.c:

Go to the source code of this file.

Functions
static bool	shell_archive_configured (ArchiveModuleState *state)
static bool	shell_archive_file (ArchiveModuleState *state, const char *file, const char *path)
static void	shell_archive_shutdown (ArchiveModuleState *state)
const ArchiveModuleCallbacks *	shell_archive_init (void)

Variables
static const ArchiveModuleCallbacks	shell_archive_callbacks

Function Documentation

shell_archive_configured()

static bool shell_archive_configured ( ArchiveModuleState *  state )

static

Definition at line 47 of file shell_archive.c.

{
    if (XLogArchiveCommand[0] != '\0')
        return true;
 
    arch_module_check_errdetail("\"%s\" is not set.",
                                "archive_command");
    return false;
}

References arch_module_check_errdetail, and XLogArchiveCommand.

shell_archive_file()

static bool shell_archive_file ( ArchiveModuleState *  state, const char *  file, const char *  path  )

static

Definition at line 58 of file shell_archive.c.

{
    char       *xlogarchcmd;
    char       *nativePath = NULL;
    int         rc;
 
    if (path)
    {
        nativePath = pstrdup(path);
        make_native_path(nativePath);
    }
 
    xlogarchcmd = replace_percent_placeholders(XLogArchiveCommand,
                                               "archive_command", "fp",
                                               file, nativePath);
 
    ereport(DEBUG3,
            (errmsg_internal("executing archive command \"%s\"",
                             xlogarchcmd)));
 
    fflush(NULL);
    pgstat_report_wait_start(WAIT_EVENT_ARCHIVE_COMMAND);
    rc = system(xlogarchcmd);
    pgstat_report_wait_end();
 
    if (rc != 0)
    {
        /*
         * If either the shell itself, or a called command, died on a signal,
         * abort the archiver.  We do this because system() ignores SIGINT and
         * SIGQUIT while waiting; so a signal is very likely something that
         * should have interrupted us too.  Also die if the shell got a hard
         * "command not found" type of error.  If we overreact it's no big
         * deal, the postmaster will just start the archiver again.
         */
        int         lev = wait_result_is_any_signal(rc, true) ? FATAL : LOG;
 
        if (WIFEXITED(rc))
        {
            ereport(lev,
                    (errmsg("archive command failed with exit code %d",
                            WEXITSTATUS(rc)),
                     errdetail("The failed archive command was: %s",
                               xlogarchcmd)));
        }
        else if (WIFSIGNALED(rc))
        {
#if defined(WIN32)
            ereport(lev,
                    (errmsg("archive command was terminated by exception 0x%X",
                            WTERMSIG(rc)),
                     errhint("See C include file \"ntstatus.h\" for a description of the hexadecimal value."),
                     errdetail("The failed archive command was: %s",
                               xlogarchcmd)));
#else
            ereport(lev,
                    (errmsg("archive command was terminated by signal %d: %s",
                            WTERMSIG(rc), pg_strsignal(WTERMSIG(rc))),
                     errdetail("The failed archive command was: %s",
                               xlogarchcmd)));
#endif
        }
        else
        {
            ereport(lev,
                    (errmsg("archive command exited with unrecognized status %d",
                            rc),
                     errdetail("The failed archive command was: %s",
                               xlogarchcmd)));
        }
        pfree(xlogarchcmd);
 
        return false;
    }
    pfree(xlogarchcmd);
 
    elog(DEBUG1, "archived write-ahead log file \"%s\"", file);
    return true;
}

References DEBUG1, DEBUG3, elog, ereport, errdetail(), errhint(), errmsg, errmsg_internal(), FATAL, fb(), LOG, make_native_path(), pfree(), pg_strsignal(), pgstat_report_wait_end(), pgstat_report_wait_start(), pstrdup(), replace_percent_placeholders(), wait_result_is_any_signal(), WEXITSTATUS, WIFEXITED, WIFSIGNALED, WTERMSIG, and XLogArchiveCommand.

shell_archive_init()

const ArchiveModuleCallbacks * shell_archive_init

(

void

)

Definition at line 41 of file shell_archive.c.

{
    return &shell_archive_callbacks;
}

References shell_archive_callbacks.

Referenced by LoadArchiveLibrary().

shell_archive_shutdown()

static void shell_archive_shutdown ( ArchiveModuleState *  state )

static

Definition at line 140 of file shell_archive.c.

{
    elog(DEBUG1, "archiver process shutting down");
}

References DEBUG1, and elog.

Variable Documentation

shell_archive_callbacks

const ArchiveModuleCallbacks shell_archive_callbacks

static

Initial value:

= {
    .startup_cb = NULL,
    .check_configured_cb = shell_archive_configured,
    .archive_file_cb = shell_archive_file,
    .shutdown_cb = shell_archive_shutdown
}

Definition at line 33 of file shell_archive.c.

                                                              {
    .startup_cb = NULL,
    .check_configured_cb = shell_archive_configured,
    .archive_file_cb = shell_archive_file,
    .shutdown_cb = shell_archive_shutdown
};

Referenced by shell_archive_init().