diff options
Diffstat (limited to 'src/backend/access/transam/xlogarchive.c')
| -rw-r--r-- | src/backend/access/transam/xlogarchive.c | 17 |
1 files changed, 7 insertions, 10 deletions
diff --git a/src/backend/access/transam/xlogarchive.c b/src/backend/access/transam/xlogarchive.c index b9c19b20856..26b023e754b 100644 --- a/src/backend/access/transam/xlogarchive.c +++ b/src/backend/access/transam/xlogarchive.c @@ -433,7 +433,7 @@ KeepFileRestoredFromArchive(const char *path, const char *xlogfname) if (XLogArchiveMode != ARCHIVE_MODE_ALWAYS) XLogArchiveForceDone(xlogfname); else - XLogArchiveNotify(xlogfname, true); + XLogArchiveNotify(xlogfname); /* * If the existing file was replaced, since walsenders might have it open, @@ -462,12 +462,9 @@ KeepFileRestoredFromArchive(const char *path, const char *xlogfname) * by the archiver, e.g. we write 0000000100000001000000C6.ready * and the archiver then knows to archive XLOGDIR/0000000100000001000000C6, * then when complete, rename it to 0000000100000001000000C6.done - * - * Optionally, nudge the archiver process so that it'll notice the file we - * create. */ void -XLogArchiveNotify(const char *xlog, bool nudge) +XLogArchiveNotify(const char *xlog) { char archiveStatusPath[MAXPGPATH]; FILE *fd; @@ -492,8 +489,8 @@ XLogArchiveNotify(const char *xlog, bool nudge) return; } - /* If caller requested, let archiver know it's got work to do */ - if (nudge) + /* Notify archiver that it's got something to do */ + if (IsUnderPostmaster) PgArchWakeup(); } @@ -501,12 +498,12 @@ XLogArchiveNotify(const char *xlog, bool nudge) * Convenience routine to notify using segment number representation of filename */ void -XLogArchiveNotifySeg(XLogSegNo segno, bool nudge) +XLogArchiveNotifySeg(XLogSegNo segno) { char xlog[MAXFNAMELEN]; XLogFileName(xlog, ThisTimeLineID, segno, wal_segment_size); - XLogArchiveNotify(xlog, nudge); + XLogArchiveNotify(xlog); } /* @@ -611,7 +608,7 @@ XLogArchiveCheckDone(const char *xlog) return true; /* Retry creation of the .ready file */ - XLogArchiveNotify(xlog, true); + XLogArchiveNotify(xlog); return false; } |