diff options
| -rw-r--r-- | src/bin/pg_basebackup/pg_recvlogical.c | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/src/bin/pg_basebackup/pg_recvlogical.c b/src/bin/pg_basebackup/pg_recvlogical.c index f3b0f34fce9..a88ffacc06d 100644 --- a/src/bin/pg_basebackup/pg_recvlogical.c +++ b/src/bin/pg_basebackup/pg_recvlogical.c @@ -56,7 +56,7 @@ static XLogRecPtr output_written_lsn = InvalidXLogRecPtr; static XLogRecPtr output_fsync_lsn = InvalidXLogRecPtr; static void usage(void); -static void StreamLog(); +static void StreamLogicalLog(void); static void disconnect_and_exit(int code); static void @@ -194,7 +194,7 @@ OutputFsync(int64 now) * Start the log streaming */ static void -StreamLog(void) +StreamLogicalLog(void) { PGresult *res; char *copybuf = NULL; @@ -868,7 +868,7 @@ main(int argc, char **argv) /* - * stop a replication slot + * drop a replication slot */ if (do_drop_slot) { @@ -876,7 +876,7 @@ main(int argc, char **argv) if (verbose) fprintf(stderr, - _("%s: freeing replication slot \"%s\"\n"), + _("%s: dropping replication slot \"%s\"\n"), progname, replication_slot); snprintf(query, sizeof(query), "DROP_REPLICATION_SLOT \"%s\"", @@ -892,8 +892,8 @@ main(int argc, char **argv) if (PQntuples(res) != 0 || PQnfields(res) != 0) { fprintf(stderr, - _("%s: could not stop logical replication: got %d rows and %d fields, expected %d rows and %d fields\n"), - progname, PQntuples(res), PQnfields(res), 0, 0); + _("%s: could not drop replication slot \"%s\": got %d rows and %d fields, expected %d rows and %d fields\n"), + progname, replication_slot, PQntuples(res), PQnfields(res), 0, 0); disconnect_and_exit(1); } @@ -902,7 +902,7 @@ main(int argc, char **argv) } /* - * init a replication slot + * create a replication slot */ if (do_create_slot) { @@ -910,7 +910,7 @@ main(int argc, char **argv) if (verbose) fprintf(stderr, - _("%s: initializing replication slot \"%s\"\n"), + _("%s: creating replication slot \"%s\"\n"), progname, replication_slot); snprintf(query, sizeof(query), "CREATE_REPLICATION_SLOT \"%s\" LOGICAL \"%s\"", @@ -927,8 +927,8 @@ main(int argc, char **argv) if (PQntuples(res) != 1 || PQnfields(res) != 4) { fprintf(stderr, - _("%s: could not init logical replication: got %d rows and %d fields, expected %d rows and %d fields\n"), - progname, PQntuples(res), PQnfields(res), 1, 4); + _("%s: could not create replication slot \"%s\": got %d rows and %d fields, expected %d rows and %d fields\n"), + progname, replication_slot, PQntuples(res), PQnfields(res), 1, 4); disconnect_and_exit(1); } |