2022-01-28 13:29:32 -05:00
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
*
|
|
|
|
* shell_archive.c
|
|
|
|
*
|
2022-02-03 13:57:27 -05:00
|
|
|
* This archiving function uses a user-specified shell command (the
|
|
|
|
* archive_command GUC) to copy write-ahead log files. It is used as the
|
|
|
|
* default, but other modules may define their own custom archiving logic.
|
|
|
|
*
|
2024-01-03 20:49:05 -05:00
|
|
|
* Copyright (c) 2022-2024, PostgreSQL Global Development Group
|
2022-01-28 13:29:32 -05:00
|
|
|
*
|
|
|
|
* IDENTIFICATION
|
Redesign archive modules
A new callback named startup_cb, called shortly after a module is
loaded, is added. This makes possible the initialization of any
additional state data required by a module. This initial state data can
be saved in a ArchiveModuleState, that is now passed down to all the
callbacks that can be defined in a module. With this design, it is
possible to have a per-module state, aimed at opening the door to the
support of more than one archive module.
The initialization of the callbacks is changed so as
_PG_archive_module_init() does not anymore give in input a
ArchiveModuleCallbacks that a module has to fill in with callback
definitions. Instead, a module now needs to return a const
ArchiveModuleCallbacks.
All the structure and callback definitions of archive modules are moved
into their own header, named archive_module.h, from pgarch.h.
Command-based archiving follows the same line, with a new set of files
named shell_archive.{c,h}.
There are a few more items that are under discussion to improve the
design of archive modules, like the fact that basic_archive calls
sigsetjmp() by itself to define its own error handling flow. These will
be adjusted later, the changes done here cover already a good portion
of what has been discussed.
Any modules created for v15 will need to be adjusted to this new
design.
Author: Nathan Bossart
Reviewed-by: Andres Freund
Discussion: https://postgr.es/m/20230130194810.6fztfgbn32e7qarj@awork3.anarazel.de
2023-02-17 14:26:42 +09:00
|
|
|
* src/backend/archive/shell_archive.c
|
2022-01-28 13:29:32 -05:00
|
|
|
*
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
*/
|
|
|
|
#include "postgres.h"
|
|
|
|
|
|
|
|
#include <sys/wait.h>
|
|
|
|
|
|
|
|
#include "access/xlog.h"
|
Redesign archive modules
A new callback named startup_cb, called shortly after a module is
loaded, is added. This makes possible the initialization of any
additional state data required by a module. This initial state data can
be saved in a ArchiveModuleState, that is now passed down to all the
callbacks that can be defined in a module. With this design, it is
possible to have a per-module state, aimed at opening the door to the
support of more than one archive module.
The initialization of the callbacks is changed so as
_PG_archive_module_init() does not anymore give in input a
ArchiveModuleCallbacks that a module has to fill in with callback
definitions. Instead, a module now needs to return a const
ArchiveModuleCallbacks.
All the structure and callback definitions of archive modules are moved
into their own header, named archive_module.h, from pgarch.h.
Command-based archiving follows the same line, with a new set of files
named shell_archive.{c,h}.
There are a few more items that are under discussion to improve the
design of archive modules, like the fact that basic_archive calls
sigsetjmp() by itself to define its own error handling flow. These will
be adjusted later, the changes done here cover already a good portion
of what has been discussed.
Any modules created for v15 will need to be adjusted to this new
design.
Author: Nathan Bossart
Reviewed-by: Andres Freund
Discussion: https://postgr.es/m/20230130194810.6fztfgbn32e7qarj@awork3.anarazel.de
2023-02-17 14:26:42 +09:00
|
|
|
#include "archive/archive_module.h"
|
|
|
|
#include "archive/shell_archive.h"
|
2023-01-11 07:22:51 +01:00
|
|
|
#include "common/percentrepl.h"
|
2022-01-28 13:29:32 -05:00
|
|
|
#include "pgstat.h"
|
|
|
|
|
Redesign archive modules
A new callback named startup_cb, called shortly after a module is
loaded, is added. This makes possible the initialization of any
additional state data required by a module. This initial state data can
be saved in a ArchiveModuleState, that is now passed down to all the
callbacks that can be defined in a module. With this design, it is
possible to have a per-module state, aimed at opening the door to the
support of more than one archive module.
The initialization of the callbacks is changed so as
_PG_archive_module_init() does not anymore give in input a
ArchiveModuleCallbacks that a module has to fill in with callback
definitions. Instead, a module now needs to return a const
ArchiveModuleCallbacks.
All the structure and callback definitions of archive modules are moved
into their own header, named archive_module.h, from pgarch.h.
Command-based archiving follows the same line, with a new set of files
named shell_archive.{c,h}.
There are a few more items that are under discussion to improve the
design of archive modules, like the fact that basic_archive calls
sigsetjmp() by itself to define its own error handling flow. These will
be adjusted later, the changes done here cover already a good portion
of what has been discussed.
Any modules created for v15 will need to be adjusted to this new
design.
Author: Nathan Bossart
Reviewed-by: Andres Freund
Discussion: https://postgr.es/m/20230130194810.6fztfgbn32e7qarj@awork3.anarazel.de
2023-02-17 14:26:42 +09:00
|
|
|
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);
|
|
|
|
|
|
|
|
static const ArchiveModuleCallbacks shell_archive_callbacks = {
|
|
|
|
.startup_cb = NULL,
|
|
|
|
.check_configured_cb = shell_archive_configured,
|
|
|
|
.archive_file_cb = shell_archive_file,
|
|
|
|
.shutdown_cb = shell_archive_shutdown
|
|
|
|
};
|
|
|
|
|
|
|
|
const ArchiveModuleCallbacks *
|
|
|
|
shell_archive_init(void)
|
2022-02-03 13:57:27 -05:00
|
|
|
{
|
Redesign archive modules
A new callback named startup_cb, called shortly after a module is
loaded, is added. This makes possible the initialization of any
additional state data required by a module. This initial state data can
be saved in a ArchiveModuleState, that is now passed down to all the
callbacks that can be defined in a module. With this design, it is
possible to have a per-module state, aimed at opening the door to the
support of more than one archive module.
The initialization of the callbacks is changed so as
_PG_archive_module_init() does not anymore give in input a
ArchiveModuleCallbacks that a module has to fill in with callback
definitions. Instead, a module now needs to return a const
ArchiveModuleCallbacks.
All the structure and callback definitions of archive modules are moved
into their own header, named archive_module.h, from pgarch.h.
Command-based archiving follows the same line, with a new set of files
named shell_archive.{c,h}.
There are a few more items that are under discussion to improve the
design of archive modules, like the fact that basic_archive calls
sigsetjmp() by itself to define its own error handling flow. These will
be adjusted later, the changes done here cover already a good portion
of what has been discussed.
Any modules created for v15 will need to be adjusted to this new
design.
Author: Nathan Bossart
Reviewed-by: Andres Freund
Discussion: https://postgr.es/m/20230130194810.6fztfgbn32e7qarj@awork3.anarazel.de
2023-02-17 14:26:42 +09:00
|
|
|
return &shell_archive_callbacks;
|
2022-02-03 13:57:27 -05:00
|
|
|
}
|
|
|
|
|
|
|
|
static bool
|
Redesign archive modules
A new callback named startup_cb, called shortly after a module is
loaded, is added. This makes possible the initialization of any
additional state data required by a module. This initial state data can
be saved in a ArchiveModuleState, that is now passed down to all the
callbacks that can be defined in a module. With this design, it is
possible to have a per-module state, aimed at opening the door to the
support of more than one archive module.
The initialization of the callbacks is changed so as
_PG_archive_module_init() does not anymore give in input a
ArchiveModuleCallbacks that a module has to fill in with callback
definitions. Instead, a module now needs to return a const
ArchiveModuleCallbacks.
All the structure and callback definitions of archive modules are moved
into their own header, named archive_module.h, from pgarch.h.
Command-based archiving follows the same line, with a new set of files
named shell_archive.{c,h}.
There are a few more items that are under discussion to improve the
design of archive modules, like the fact that basic_archive calls
sigsetjmp() by itself to define its own error handling flow. These will
be adjusted later, the changes done here cover already a good portion
of what has been discussed.
Any modules created for v15 will need to be adjusted to this new
design.
Author: Nathan Bossart
Reviewed-by: Andres Freund
Discussion: https://postgr.es/m/20230130194810.6fztfgbn32e7qarj@awork3.anarazel.de
2023-02-17 14:26:42 +09:00
|
|
|
shell_archive_configured(ArchiveModuleState *state)
|
2022-02-03 13:57:27 -05:00
|
|
|
{
|
2024-03-04 15:41:42 -06:00
|
|
|
if (XLogArchiveCommand[0] != '\0')
|
|
|
|
return true;
|
|
|
|
|
|
|
|
arch_module_check_errdetail("%s is not set.",
|
|
|
|
"archive_command");
|
|
|
|
return false;
|
2022-02-03 13:57:27 -05:00
|
|
|
}
|
|
|
|
|
|
|
|
static bool
|
Redesign archive modules
A new callback named startup_cb, called shortly after a module is
loaded, is added. This makes possible the initialization of any
additional state data required by a module. This initial state data can
be saved in a ArchiveModuleState, that is now passed down to all the
callbacks that can be defined in a module. With this design, it is
possible to have a per-module state, aimed at opening the door to the
support of more than one archive module.
The initialization of the callbacks is changed so as
_PG_archive_module_init() does not anymore give in input a
ArchiveModuleCallbacks that a module has to fill in with callback
definitions. Instead, a module now needs to return a const
ArchiveModuleCallbacks.
All the structure and callback definitions of archive modules are moved
into their own header, named archive_module.h, from pgarch.h.
Command-based archiving follows the same line, with a new set of files
named shell_archive.{c,h}.
There are a few more items that are under discussion to improve the
design of archive modules, like the fact that basic_archive calls
sigsetjmp() by itself to define its own error handling flow. These will
be adjusted later, the changes done here cover already a good portion
of what has been discussed.
Any modules created for v15 will need to be adjusted to this new
design.
Author: Nathan Bossart
Reviewed-by: Andres Freund
Discussion: https://postgr.es/m/20230130194810.6fztfgbn32e7qarj@awork3.anarazel.de
2023-02-17 14:26:42 +09:00
|
|
|
shell_archive_file(ArchiveModuleState *state, const char *file,
|
|
|
|
const char *path)
|
2022-01-28 13:29:32 -05:00
|
|
|
{
|
2023-01-11 07:22:51 +01:00
|
|
|
char *xlogarchcmd;
|
|
|
|
char *nativePath = NULL;
|
2022-01-28 13:29:32 -05:00
|
|
|
int rc;
|
|
|
|
|
2023-01-11 07:22:51 +01:00
|
|
|
if (path)
|
2022-01-28 13:29:32 -05:00
|
|
|
{
|
2023-01-11 07:22:51 +01:00
|
|
|
nativePath = pstrdup(path);
|
|
|
|
make_native_path(nativePath);
|
2022-01-28 13:29:32 -05:00
|
|
|
}
|
2023-01-11 07:22:51 +01:00
|
|
|
|
Redesign archive modules
A new callback named startup_cb, called shortly after a module is
loaded, is added. This makes possible the initialization of any
additional state data required by a module. This initial state data can
be saved in a ArchiveModuleState, that is now passed down to all the
callbacks that can be defined in a module. With this design, it is
possible to have a per-module state, aimed at opening the door to the
support of more than one archive module.
The initialization of the callbacks is changed so as
_PG_archive_module_init() does not anymore give in input a
ArchiveModuleCallbacks that a module has to fill in with callback
definitions. Instead, a module now needs to return a const
ArchiveModuleCallbacks.
All the structure and callback definitions of archive modules are moved
into their own header, named archive_module.h, from pgarch.h.
Command-based archiving follows the same line, with a new set of files
named shell_archive.{c,h}.
There are a few more items that are under discussion to improve the
design of archive modules, like the fact that basic_archive calls
sigsetjmp() by itself to define its own error handling flow. These will
be adjusted later, the changes done here cover already a good portion
of what has been discussed.
Any modules created for v15 will need to be adjusted to this new
design.
Author: Nathan Bossart
Reviewed-by: Andres Freund
Discussion: https://postgr.es/m/20230130194810.6fztfgbn32e7qarj@awork3.anarazel.de
2023-02-17 14:26:42 +09:00
|
|
|
xlogarchcmd = replace_percent_placeholders(XLogArchiveCommand,
|
|
|
|
"archive_command", "fp",
|
|
|
|
file, nativePath);
|
2023-01-11 07:22:51 +01:00
|
|
|
|
|
|
|
if (nativePath)
|
|
|
|
pfree(nativePath);
|
2022-01-28 13:29:32 -05:00
|
|
|
|
|
|
|
ereport(DEBUG3,
|
|
|
|
(errmsg_internal("executing archive command \"%s\"",
|
|
|
|
xlogarchcmd)));
|
|
|
|
|
2022-08-29 13:55:38 -04:00
|
|
|
fflush(NULL);
|
2022-01-28 13:29:32 -05:00
|
|
|
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)));
|
|
|
|
}
|
|
|
|
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
2023-01-11 07:22:51 +01:00
|
|
|
pfree(xlogarchcmd);
|
|
|
|
|
2022-01-28 13:29:32 -05:00
|
|
|
elog(DEBUG1, "archived write-ahead log file \"%s\"", file);
|
|
|
|
return true;
|
|
|
|
}
|
Rework shutdown callback of archiver modules
As currently designed, with a callback registered in a ERROR_CLEANUP
block, the shutdown callback would get called twice when updating
archive_library on SIGHUP, which is something that we want to avoid to
ease the life of extension writers.
Anyway, an ERROR in the archiver process is treated as a FATAL, stopping
it immediately, hence there is no need for a ERROR_CLEANUP block.
Instead of that, the shutdown callback is not called upon
before_shmem_exit(), giving to the modules the opportunity to do any
cleanup actions before the server shuts down its subsystems.
While on it, this commit adds some testing coverage for the shutdown
callback. Neither shell_archive nor basic_archive have been using it,
and one is added to shell_archive, whose trigger is checked in a TAP
test through a shutdown sequence.
Author: Nathan Bossart, Bharath Rupireddy
Reviewed-by: Kyotaro Horiguchi, Michael Paquier
Discussion: https://postgr.es/m/20221015221328.GB1821022@nathanxps13
Backpatch-through: 15
2022-10-19 14:06:56 +09:00
|
|
|
|
|
|
|
static void
|
Redesign archive modules
A new callback named startup_cb, called shortly after a module is
loaded, is added. This makes possible the initialization of any
additional state data required by a module. This initial state data can
be saved in a ArchiveModuleState, that is now passed down to all the
callbacks that can be defined in a module. With this design, it is
possible to have a per-module state, aimed at opening the door to the
support of more than one archive module.
The initialization of the callbacks is changed so as
_PG_archive_module_init() does not anymore give in input a
ArchiveModuleCallbacks that a module has to fill in with callback
definitions. Instead, a module now needs to return a const
ArchiveModuleCallbacks.
All the structure and callback definitions of archive modules are moved
into their own header, named archive_module.h, from pgarch.h.
Command-based archiving follows the same line, with a new set of files
named shell_archive.{c,h}.
There are a few more items that are under discussion to improve the
design of archive modules, like the fact that basic_archive calls
sigsetjmp() by itself to define its own error handling flow. These will
be adjusted later, the changes done here cover already a good portion
of what has been discussed.
Any modules created for v15 will need to be adjusted to this new
design.
Author: Nathan Bossart
Reviewed-by: Andres Freund
Discussion: https://postgr.es/m/20230130194810.6fztfgbn32e7qarj@awork3.anarazel.de
2023-02-17 14:26:42 +09:00
|
|
|
shell_archive_shutdown(ArchiveModuleState *state)
|
Rework shutdown callback of archiver modules
As currently designed, with a callback registered in a ERROR_CLEANUP
block, the shutdown callback would get called twice when updating
archive_library on SIGHUP, which is something that we want to avoid to
ease the life of extension writers.
Anyway, an ERROR in the archiver process is treated as a FATAL, stopping
it immediately, hence there is no need for a ERROR_CLEANUP block.
Instead of that, the shutdown callback is not called upon
before_shmem_exit(), giving to the modules the opportunity to do any
cleanup actions before the server shuts down its subsystems.
While on it, this commit adds some testing coverage for the shutdown
callback. Neither shell_archive nor basic_archive have been using it,
and one is added to shell_archive, whose trigger is checked in a TAP
test through a shutdown sequence.
Author: Nathan Bossart, Bharath Rupireddy
Reviewed-by: Kyotaro Horiguchi, Michael Paquier
Discussion: https://postgr.es/m/20221015221328.GB1821022@nathanxps13
Backpatch-through: 15
2022-10-19 14:06:56 +09:00
|
|
|
{
|
|
|
|
elog(DEBUG1, "archiver process shutting down");
|
|
|
|
}
|