PostgreSQL Source Code
git master
|
Go to the source code of this file.
Data Structures | |
struct | bbstreamer_member |
struct | bbstreamer |
struct | bbstreamer_ops |
Typedefs | |
typedef struct bbstreamer | bbstreamer |
typedef struct bbstreamer_ops | bbstreamer_ops |
Enumerations | |
enum | bbstreamer_archive_context { BBSTREAMER_UNKNOWN , BBSTREAMER_MEMBER_HEADER , BBSTREAMER_MEMBER_CONTENTS , BBSTREAMER_MEMBER_TRAILER , BBSTREAMER_ARCHIVE_TRAILER } |
typedef struct bbstreamer bbstreamer |
Definition at line 1 of file bbstreamer.h.
typedef struct bbstreamer_ops bbstreamer_ops |
Definition at line 1 of file bbstreamer.h.
Enumerator | |
---|---|
BBSTREAMER_UNKNOWN | |
BBSTREAMER_MEMBER_HEADER | |
BBSTREAMER_MEMBER_CONTENTS | |
BBSTREAMER_MEMBER_TRAILER | |
BBSTREAMER_ARCHIVE_TRAILER |
Definition at line 53 of file bbstreamer.h.
|
inlinestatic |
Definition at line 157 of file bbstreamer.h.
References appendBinaryStringInfo(), Assert(), bbstreamer::bbs_buffer, data, and len.
Referenced by bbstreamer_buffer_until(), and bbstreamer_tar_parser_content().
|
inlinestatic |
Definition at line 175 of file bbstreamer.h.
References bbstreamer::bbs_buffer, bbstreamer_buffer_bytes(), data, StringInfoData::len, and len.
Referenced by bbstreamer_tar_parser_content().
|
inlinestatic |
Definition at line 126 of file bbstreamer.h.
References Assert(), bbstreamer::bbs_ops, bbstreamer_ops::content, data, and len.
Referenced by bbstreamer_inject_file(), bbstreamer_recovery_injector_content(), bbstreamer_tar_archiver_content(), bbstreamer_tar_header(), bbstreamer_tar_parser_content(), bbstreamer_tar_parser_finalize(), bbstreamer_tar_terminator_content(), bbstreamer_tar_terminator_finalize(), ReceiveArchiveStreamChunk(), and ReceiveTarCopyChunk().
bbstreamer* bbstreamer_extractor_new | ( | const char * | basepath, |
const char *(*)(const char *) | link_map, | ||
void(*)(const char *) | report_output_file | ||
) |
Definition at line 183 of file bbstreamer_file.c.
References bbstreamer_extractor::base, bbstreamer_extractor::basepath, bbstreamer::bbs_ops, bbstreamer_extractor_ops, bbstreamer_extractor::link_map, palloc0(), pstrdup(), and bbstreamer_extractor::report_output_file.
Referenced by CreateBackupStreamer().
|
inlinestatic |
Definition at line 136 of file bbstreamer.h.
References Assert(), bbstreamer::bbs_ops, and bbstreamer_ops::finalize.
Referenced by bbstreamer_recovery_injector_finalize(), bbstreamer_tar_archiver_finalize(), bbstreamer_tar_parser_finalize(), bbstreamer_tar_terminator_finalize(), ReceiveArchiveStream(), ReceiveArchiveStreamChunk(), and ReceiveTarFile().
|
inlinestatic |
Definition at line 144 of file bbstreamer.h.
References Assert(), bbstreamer::bbs_ops, and bbstreamer_ops::free.
Referenced by bbstreamer_recovery_injector_free(), bbstreamer_tar_archiver_free(), bbstreamer_tar_parser_free(), bbstreamer_tar_terminator_free(), ReceiveArchiveStream(), ReceiveArchiveStreamChunk(), and ReceiveTarFile().
bbstreamer* bbstreamer_gzip_decompressor_new | ( | bbstreamer * | next | ) |
Definition at line 212 of file bbstreamer_gzip.c.
References Assert(), if(), initStringInfo(), next, palloc0(), and pg_fatal.
Referenced by CreateBackupStreamer().
bbstreamer* bbstreamer_gzip_writer_new | ( | char * | pathname, |
FILE * | file, | ||
pg_compress_specification * | compress | ||
) |
Definition at line 79 of file bbstreamer_gzip.c.
References fd(), pg_compress_specification::level, palloc0(), pg_fatal, and pstrdup().
Referenced by CreateBackupStreamer().
void bbstreamer_inject_file | ( | bbstreamer * | streamer, |
char * | pathname, | ||
char * | data, | ||
int | len | ||
) |
Definition at line 219 of file bbstreamer_inject.c.
References bbstreamer_content(), BBSTREAMER_MEMBER_CONTENTS, BBSTREAMER_MEMBER_HEADER, BBSTREAMER_MEMBER_TRAILER, data, bbstreamer_member::gid, bbstreamer_member::is_directory, bbstreamer_member::is_link, len, bbstreamer_member::linktarget, MAXPGPATH, bbstreamer_member::mode, bbstreamer_member::pathname, pg_file_create_mode, bbstreamer_member::size, strlcpy(), and bbstreamer_member::uid.
Referenced by bbstreamer_recovery_injector_content(), ReceiveArchiveStream(), and ReceiveTarFile().
bbstreamer* bbstreamer_lz4_compressor_new | ( | bbstreamer * | next, |
pg_compress_specification * | compress | ||
) |
Definition at line 70 of file bbstreamer_lz4.c.
References Assert(), initStringInfo(), pg_compress_specification::level, next, palloc0(), pg_fatal, and pg_log_error.
Referenced by CreateBackupStreamer().
bbstreamer* bbstreamer_lz4_decompressor_new | ( | bbstreamer * | next | ) |
Definition at line 275 of file bbstreamer_lz4.c.
References Assert(), initStringInfo(), next, palloc0(), and pg_fatal.
Referenced by CreateBackupStreamer().
bbstreamer* bbstreamer_plain_writer_new | ( | char * | pathname, |
FILE * | file | ||
) |
Definition at line 78 of file bbstreamer_file.c.
References bbstreamer_plain_writer::base, bbstreamer::bbs_ops, bbstreamer_plain_writer_ops, bbstreamer_plain_writer::file, palloc0(), bbstreamer_plain_writer::pathname, pg_fatal, pstrdup(), and bbstreamer_plain_writer::should_close_file.
Referenced by CreateBackupStreamer().
bbstreamer* bbstreamer_recovery_injector_new | ( | bbstreamer * | next, |
bool | is_recovery_guc_supported, | ||
PQExpBuffer | recoveryconfcontents | ||
) |
Definition at line 65 of file bbstreamer_inject.c.
References bbstreamer_recovery_injector::base, bbstreamer::bbs_next, bbstreamer::bbs_ops, bbstreamer_recovery_injector_ops, bbstreamer_recovery_injector::is_recovery_guc_supported, next, palloc0(), bbstreamer_recovery_injector::recoveryconfcontents, and recoveryconfcontents.
Referenced by CreateBackupStreamer().
bbstreamer* bbstreamer_tar_archiver_new | ( | bbstreamer * | next | ) |
Definition at line 358 of file bbstreamer_tar.c.
References bbstreamer_tar_archiver::base, bbstreamer::bbs_next, bbstreamer::bbs_ops, bbstreamer_tar_archiver_ops, next, and palloc0().
Referenced by CreateBackupStreamer().
bbstreamer* bbstreamer_tar_parser_new | ( | bbstreamer * | next | ) |
Definition at line 93 of file bbstreamer_tar.c.
References bbstreamer_tar_parser::base, bbstreamer::bbs_buffer, bbstreamer::bbs_next, bbstreamer::bbs_ops, BBSTREAMER_MEMBER_HEADER, bbstreamer_tar_parser_ops, initStringInfo(), next, bbstreamer_tar_parser::next_context, and palloc0().
Referenced by CreateBackupStreamer().
bbstreamer* bbstreamer_tar_terminator_new | ( | bbstreamer * | next | ) |
Definition at line 464 of file bbstreamer_tar.c.
References bbstreamer::bbs_next, bbstreamer::bbs_ops, bbstreamer_tar_terminator_ops, next, and palloc0().
Referenced by CreateBackupStreamer().
bbstreamer* bbstreamer_zstd_compressor_new | ( | bbstreamer * | next, |
pg_compress_specification * | compress | ||
) |
Definition at line 66 of file bbstreamer_zstd.c.
References Assert(), enlargeStringInfo(), exit(), initStringInfo(), pg_compress_specification::level, pg_compress_specification::long_distance, next, pg_compress_specification::options, palloc0(), PG_COMPRESSION_OPTION_LONG_DISTANCE, PG_COMPRESSION_OPTION_WORKERS, pg_fatal, pg_log_error, and pg_compress_specification::workers.
Referenced by CreateBackupStreamer().
bbstreamer* bbstreamer_zstd_decompressor_new | ( | bbstreamer * | next | ) |
Definition at line 258 of file bbstreamer_zstd.c.
References Assert(), enlargeStringInfo(), initStringInfo(), next, palloc0(), and pg_fatal.
Referenced by CreateBackupStreamer().