PostgreSQL Source Code: src/include/backup/basebackup.h File Reference (original) (raw)
Go to the source code of this file.
◆ MAX_RATE_LOWER
#define MAX_RATE_LOWER 32
◆ MAX_RATE_UPPER
#define MAX_RATE_UPPER 1048576
◆ SendBaseBackup()
Definition at line 990 of file basebackup.c.
991{
995
998 (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
999 errmsg("a backup is already in progress in this session")));
1000
1002
1004
1006 {
1007 char activitymsg[50];
1008
1009 snprintf(activitymsg, sizeof(activitymsg), "sending backup \"%s\"",
1012 }
1013
1014
1015
1016
1017
1018
1019
1020
1022 ib = NULL;
1023 else if (ib == NULL)
1025 (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
1026 errmsg("must UPLOAD_MANIFEST before performing an incremental BASE_BACKUP")));
1027
1028
1029
1030
1031
1032
1033
1037
1038
1041
1042
1049
1050
1052
1053
1054
1055
1056
1058 {
1060 }
1062 {
1064 }
1066}
static void parse_basebackup_options(List *options, basebackup_options *opt)
static void perform_base_backup(basebackup_options *opt, bbsink *sink, IncrementalBackupInfo *ib)
bbsink * bbsink_copystream_new(bool send_to_client)
bbsink * bbsink_gzip_new(bbsink *next, pg_compress_specification *compress)
bbsink * bbsink_lz4_new(bbsink *next, pg_compress_specification *compress)
bbsink * bbsink_progress_new(bbsink *next, bool estimate_backup_size)
static void bbsink_cleanup(bbsink *sink)
bbsink * BaseBackupGetSink(BaseBackupTargetHandle *handle, bbsink *next_sink)
bbsink * bbsink_throttle_new(bbsink *next, uint32 maxrate)
bbsink * bbsink_zstd_new(bbsink *next, pg_compress_specification *compress)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
bool update_process_title
static void set_ps_display(const char *activity)
pg_compress_specification compression_specification
pg_compress_algorithm compression
BaseBackupTargetHandle * target_handle
void WalSndSetState(WalSndState state)
SessionBackupState get_backup_status(void)
References BaseBackupGetSink(), bbsink_cleanup(), bbsink_copystream_new(), bbsink_gzip_new(), bbsink_lz4_new(), bbsink_progress_new(), bbsink_throttle_new(), bbsink_zstd_new(), basebackup_options::compression, basebackup_options::compression_specification, ereport, errcode(), errmsg(), ERROR, get_backup_status(), basebackup_options::incremental, basebackup_options::label, basebackup_options::maxrate, BaseBackupCmd::options, parse_basebackup_options(), perform_base_backup(), PG_COMPRESSION_GZIP, PG_COMPRESSION_LZ4, PG_COMPRESSION_ZSTD, PG_END_TRY, PG_FINALLY, PG_TRY, basebackup_options::progress, basebackup_options::send_to_client, SESSION_BACKUP_RUNNING, set_ps_display(), snprintf, basebackup_options::target_handle, update_process_title, WalSndSetState(), and WALSNDSTATE_BACKUP.
Referenced by exec_replication_command().