diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/bin/pg_basebackup/receivelog.c | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/src/bin/pg_basebackup/receivelog.c b/src/bin/pg_basebackup/receivelog.c index 3b464123b34..9de0eb6275c 100644 --- a/src/bin/pg_basebackup/receivelog.c +++ b/src/bin/pg_basebackup/receivelog.c @@ -611,11 +611,20 @@ ReceiveXlogStream(PGconn *conn, XLogRecPtr startpos, uint32 timeline, } PQclear(res); + /* Complain if we've not reached stop point yet */ + if (stream_stop != NULL && !stream_stop(blockpos, timeline, false)) + { + fprintf(stderr, _("%s: replication stream was terminated before stop point\n"), + progname); + goto error; + } + if (copybuf != NULL) PQfreemem(copybuf); if (walfile != -1 && close(walfile) != 0) fprintf(stderr, _("%s: could not close file %s: %s\n"), progname, current_walfile_name, strerror(errno)); + walfile = -1; return true; error: @@ -624,5 +633,6 @@ error: if (walfile != -1 && close(walfile) != 0) fprintf(stderr, _("%s: could not close file %s: %s\n"), progname, current_walfile_name, strerror(errno)); + walfile = -1; return false; } |