PostgreSQL Source Code git master
|
Go to the source code of this file.
Data Structures | |
struct | bbsink_state |
struct | bbsink |
struct | bbsink_ops |
Typedefs | |
typedef struct bbsink | bbsink |
typedef struct bbsink_ops | bbsink_ops |
typedef struct bbsink_state | bbsink_state |
Definition at line 36 of file basebackup_sink.h.
typedef struct bbsink_ops bbsink_ops |
Definition at line 37 of file basebackup_sink.h.
typedef struct bbsink_state bbsink_state |
void basebackup_progress_done | ( | void | ) |
Definition at line 239 of file basebackup_progress.c.
References pgstat_progress_end_command().
Referenced by perform_base_backup().
void basebackup_progress_estimate_backup_size | ( | void | ) |
Definition at line 196 of file basebackup_progress.c.
References pgstat_progress_update_param(), PROGRESS_BASEBACKUP_PHASE, and PROGRESS_BASEBACKUP_PHASE_ESTIMATE_BACKUP_SIZE.
Referenced by perform_base_backup().
void basebackup_progress_transfer_wal | ( | void | ) |
Definition at line 229 of file basebackup_progress.c.
References pgstat_progress_update_param(), PROGRESS_BASEBACKUP_PHASE, and PROGRESS_BASEBACKUP_PHASE_TRANSFER_WAL.
Referenced by perform_base_backup().
void basebackup_progress_wait_checkpoint | ( | void | ) |
Definition at line 186 of file basebackup_progress.c.
References pgstat_progress_update_param(), PROGRESS_BASEBACKUP_PHASE, and PROGRESS_BASEBACKUP_PHASE_WAIT_CHECKPOINT.
Referenced by perform_base_backup().
void basebackup_progress_wait_wal_archive | ( | bbsink_state * | state | ) |
Definition at line 206 of file basebackup_progress.c.
References list_length(), pgstat_progress_update_multi_param(), PROGRESS_BASEBACKUP_PHASE, PROGRESS_BASEBACKUP_PHASE_WAIT_WAL_ARCHIVE, PROGRESS_BASEBACKUP_TBLSPC_STREAMED, and val.
Referenced by perform_base_backup().
|
inlinestatic |
Definition at line 200 of file basebackup_sink.h.
References bbsink_ops::archive_contents, Assert, bbsink::bbs_ops, and len.
Referenced by _tarWriteHeader(), _tarWritePadding(), bbsink_forward_archive_contents(), perform_base_backup(), push_to_sink(), sendFile(), and sendFileWithContent().
|
inlinestatic |
Definition at line 191 of file basebackup_sink.h.
References Assert, bbsink::bbs_ops, and bbsink_ops::begin_archive.
Referenced by bbsink_forward_begin_archive(), and perform_base_backup().
|
inlinestatic |
Definition at line 175 of file basebackup_sink.h.
References Assert, bbsink::bbs_buffer, bbsink::bbs_buffer_length, bbsink::bbs_ops, bbsink::bbs_state, and bbsink_ops::begin_backup.
Referenced by bbsink_forward_begin_backup(), and perform_base_backup().
|
inlinestatic |
Definition at line 225 of file basebackup_sink.h.
References Assert, bbsink::bbs_ops, and bbsink_ops::begin_manifest.
Referenced by bbsink_forward_begin_manifest(), and SendBackupManifest().
|
inlinestatic |
Definition at line 265 of file basebackup_sink.h.
References Assert, bbsink::bbs_ops, and bbsink_ops::cleanup.
Referenced by bbsink_forward_cleanup(), and SendBaseBackup().
bbsink * bbsink_copystream_new | ( | bool | send_to_client | ) |
Definition at line 108 of file basebackup_copy.c.
References bbsink_copystream::base, bbsink::bbs_ops, bbsink_copystream_ops, bbsink_copystream::bytes_done_at_last_time_check, GetCurrentTimestamp(), bbsink_copystream::last_progress_report_time, palloc0(), bbsink_copystream::send_to_client, and UINT64CONST.
Referenced by SendBaseBackup().
|
inlinestatic |
Definition at line 216 of file basebackup_sink.h.
References Assert, bbsink::bbs_ops, and bbsink_ops::end_archive.
Referenced by bbsink_forward_end_archive(), and perform_base_backup().
|
inlinestatic |
Definition at line 255 of file basebackup_sink.h.
References Assert, bbsink::bbs_ops, bbsink::bbs_state, bbsink_ops::end_backup, list_length(), bbsink_state::tablespace_num, and bbsink_state::tablespaces.
Referenced by bbsink_forward_end_backup(), and perform_base_backup().
|
inlinestatic |
Definition at line 246 of file basebackup_sink.h.
References Assert, bbsink::bbs_ops, and bbsink_ops::end_manifest.
Referenced by bbsink_forward_end_manifest(), and SendBackupManifest().
void bbsink_forward_archive_contents | ( | bbsink * | sink, |
size_t | len | ||
) |
Definition at line 54 of file basebackup_sink.c.
References Assert, bbsink::bbs_buffer, bbsink::bbs_buffer_length, bbsink::bbs_next, bbsink_archive_contents(), and len.
Referenced by bbsink_progress_archive_contents(), bbsink_server_archive_contents(), bbsink_shell_archive_contents(), and bbsink_throttle_archive_contents().
void bbsink_forward_begin_archive | ( | bbsink * | sink, |
const char * | archive_name | ||
) |
Definition at line 37 of file basebackup_sink.c.
References Assert, bbsink::bbs_next, and bbsink_begin_archive().
Referenced by bbsink_server_begin_archive(), and bbsink_shell_begin_archive().
void bbsink_forward_begin_backup | ( | bbsink * | sink | ) |
Definition at line 24 of file basebackup_sink.c.
References Assert, bbsink::bbs_buffer, bbsink::bbs_buffer_length, bbsink::bbs_next, bbsink::bbs_state, and bbsink_begin_backup().
Referenced by bbsink_progress_begin_backup(), and bbsink_throttle_begin_backup().
void bbsink_forward_begin_manifest | ( | bbsink * | sink | ) |
Definition at line 76 of file basebackup_sink.c.
References Assert, bbsink::bbs_next, and bbsink_begin_manifest().
Referenced by bbsink_server_begin_manifest(), and bbsink_shell_begin_manifest().
void bbsink_forward_cleanup | ( | bbsink * | sink | ) |
Definition at line 121 of file basebackup_sink.c.
References Assert, bbsink::bbs_next, and bbsink_cleanup().
void bbsink_forward_end_archive | ( | bbsink * | sink | ) |
Definition at line 66 of file basebackup_sink.c.
References Assert, bbsink::bbs_next, and bbsink_end_archive().
Referenced by bbsink_progress_end_archive(), bbsink_server_end_archive(), and bbsink_shell_end_archive().
void bbsink_forward_end_backup | ( | bbsink * | sink, |
XLogRecPtr | endptr, | ||
TimeLineID | endtli | ||
) |
Definition at line 111 of file basebackup_sink.c.
References Assert, bbsink::bbs_next, and bbsink_end_backup().
void bbsink_forward_end_manifest | ( | bbsink * | sink | ) |
Definition at line 101 of file basebackup_sink.c.
References Assert, bbsink::bbs_next, and bbsink_end_manifest().
Referenced by bbsink_server_end_manifest(), and bbsink_shell_end_manifest().
void bbsink_forward_manifest_contents | ( | bbsink * | sink, |
size_t | len | ||
) |
Definition at line 89 of file basebackup_sink.c.
References Assert, bbsink::bbs_buffer, bbsink::bbs_buffer_length, bbsink::bbs_next, bbsink_manifest_contents(), and len.
Referenced by bbsink_server_manifest_contents(), bbsink_shell_manifest_contents(), and bbsink_throttle_manifest_contents().
bbsink * bbsink_gzip_new | ( | bbsink * | next, |
pg_compress_specification * | compress | ||
) |
Definition at line 62 of file basebackup_gzip.c.
References Assert, compresslevel, ereport, errcode(), errmsg(), ERROR, pg_compress_specification::level, next, and palloc0().
Referenced by SendBaseBackup().
bbsink * bbsink_lz4_new | ( | bbsink * | next, |
pg_compress_specification * | compress | ||
) |
Definition at line 62 of file basebackup_lz4.c.
References Assert, compresslevel, ereport, errcode(), errmsg(), ERROR, pg_compress_specification::level, next, and palloc0().
Referenced by SendBaseBackup().
|
inlinestatic |
Definition at line 234 of file basebackup_sink.h.
References Assert, bbsink::bbs_ops, len, and bbsink_ops::manifest_contents.
Referenced by bbsink_forward_manifest_contents(), and SendBackupManifest().
Definition at line 59 of file basebackup_progress.c.
References Assert, bbsink::bbs_next, bbsink::bbs_ops, bbsink_progress_ops, InvalidOid, next, palloc0(), pgstat_progress_start_command(), pgstat_progress_update_param(), PROGRESS_BASEBACKUP_BACKUP_TOTAL, and PROGRESS_COMMAND_BASEBACKUP.
Referenced by SendBaseBackup().
Definition at line 60 of file basebackup_server.c.
References bbsink_server::base, bbsink::bbs_next, bbsink::bbs_ops, bbsink_server_ops, CommitTransactionCommand(), ereport, errcode(), errcode_for_file_access(), errdetail(), errmsg(), ERROR, GetUserId(), has_privs_of_role(), is_absolute_path, MakePGDirectory(), next, palloc0(), bbsink_server::pathname, pg_check_dir(), and StartTransactionCommand().
Referenced by server_get_sink().
Definition at line 68 of file basebackup_throttle.c.
References Assert, bbsink_throttle::base, bbsink::bbs_next, bbsink::bbs_ops, bbsink_throttle_ops, bbsink_throttle::elapsed_min_unit, maxrate, next, palloc0(), THROTTLING_FREQUENCY, bbsink_throttle::throttling_sample, and USECS_PER_SEC.
Referenced by SendBaseBackup().
bbsink * bbsink_zstd_new | ( | bbsink * | next, |
pg_compress_specification * | compress | ||
) |
Definition at line 61 of file basebackup_zstd.c.
References Assert, ereport, errcode(), errmsg(), ERROR, next, and palloc0().
Referenced by SendBaseBackup().