diff options
| author | Fujii Masao <fujii@postgresql.org> | 2020-09-29 16:21:46 +0900 |
|---|---|---|
| committer | Fujii Masao <fujii@postgresql.org> | 2020-09-29 16:24:47 +0900 |
| commit | 462ff7966997301de3ce469b1034a0aba44957c1 (patch) | |
| tree | 9ebab8b135f664370e258aaf9b6b532e7050e647 /src/backend | |
| parent | dd89ba5780214e5f0d9b222e242141fe99cfcdd9 (diff) | |
| download | postgresql-462ff7966997301de3ce469b1034a0aba44957c1.tar.gz postgresql-462ff7966997301de3ce469b1034a0aba44957c1.zip | |
Archive timeline history files in standby if archive_mode is set to "always".
Previously the standby server didn't archive timeline history files
streamed from the primary even when archive_mode is set to "always",
while it archives the streamed WAL files. This could cause the PITR to
fail because there was no required timeline history file in the archive.
The cause of this issue was that walreceiver didn't mark those files as
ready for archiving.
This commit makes walreceiver mark those streamed timeline history
files as ready for archiving if archive_mode=always. Then the archiver
process archives the marked timeline history files.
Back-patch to all supported versions.
Reported-by: Grigory Smolkin
Author: Grigory Smolkin, Fujii Masao
Reviewed-by: David Zhang, Anastasia Lubennikova
Discussion: https://postgr.es/m/54b059d4-2b48-13a4-6f43-95a087c92367@postgrespro.ru
Diffstat (limited to 'src/backend')
| -rw-r--r-- | src/backend/replication/walreceiver.c | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/src/backend/replication/walreceiver.c b/src/backend/replication/walreceiver.c index 17b5b8be999..a07108dfe8f 100644 --- a/src/backend/replication/walreceiver.c +++ b/src/backend/replication/walreceiver.c @@ -747,6 +747,15 @@ WalRcvFetchTimeLineHistoryFiles(TimeLineID first, TimeLineID last) */ writeTimeLineHistoryFile(tli, content, len); + /* + * Mark the streamed history file as ready for archiving + * if archive_mode is always. + */ + if (XLogArchiveMode != ARCHIVE_MODE_ALWAYS) + XLogArchiveForceDone(fname); + else + XLogArchiveNotify(fname); + pfree(fname); pfree(content); } |