PostgreSQL Source Code
git master
|
Go to the source code of this file.
Data Structures | |
struct | astreamer_member |
struct | astreamer |
struct | astreamer_ops |
Typedefs | |
typedef struct astreamer | astreamer |
typedef struct astreamer_ops | astreamer_ops |
Enumerations | |
enum | astreamer_archive_context { ASTREAMER_UNKNOWN , ASTREAMER_MEMBER_HEADER , ASTREAMER_MEMBER_CONTENTS , ASTREAMER_MEMBER_TRAILER , ASTREAMER_ARCHIVE_TRAILER } |
Definition at line 1 of file astreamer.h.
typedef struct astreamer_ops astreamer_ops |
Definition at line 1 of file astreamer.h.
Enumerator | |
---|---|
ASTREAMER_UNKNOWN | |
ASTREAMER_MEMBER_HEADER | |
ASTREAMER_MEMBER_CONTENTS | |
ASTREAMER_MEMBER_TRAILER | |
ASTREAMER_ARCHIVE_TRAILER |
Definition at line 62 of file astreamer.h.
|
inlinestatic |
Definition at line 166 of file astreamer.h.
References appendBinaryStringInfo(), Assert, astreamer::bbs_buffer, data, and len.
Referenced by astreamer_buffer_until(), and astreamer_tar_parser_content().
|
inlinestatic |
Definition at line 184 of file astreamer.h.
References astreamer_buffer_bytes(), astreamer::bbs_buffer, data, StringInfoData::len, and len.
Referenced by astreamer_tar_parser_content().
|
inlinestatic |
Definition at line 135 of file astreamer.h.
References Assert, astreamer::bbs_ops, astreamer_ops::content, context, data, and len.
Referenced by astreamer_inject_file(), astreamer_recovery_injector_content(), astreamer_tar_archiver_content(), astreamer_tar_header(), astreamer_tar_parser_content(), astreamer_tar_parser_finalize(), astreamer_tar_terminator_content(), astreamer_tar_terminator_finalize(), ReceiveArchiveStreamChunk(), ReceiveTarCopyChunk(), and verify_tar_file().
astreamer* astreamer_extractor_new | ( | const char * | basepath, |
const char *(*)(const char *) | link_map, | ||
void(*)(const char *) | report_output_file | ||
) |
Definition at line 187 of file astreamer_file.c.
References astreamer_extractor_ops, astreamer_extractor::base, astreamer_extractor::basepath, astreamer::bbs_ops, astreamer_extractor::link_map, palloc0(), pstrdup(), and astreamer_extractor::report_output_file.
Referenced by CreateBackupStreamer().
|
inlinestatic |
Definition at line 145 of file astreamer.h.
References Assert, astreamer::bbs_ops, and astreamer_ops::finalize.
Referenced by astreamer_recovery_injector_finalize(), astreamer_tar_archiver_finalize(), astreamer_tar_parser_finalize(), astreamer_tar_terminator_finalize(), ReceiveArchiveStream(), ReceiveArchiveStreamChunk(), ReceiveTarFile(), and verify_tar_backup().
|
inlinestatic |
Definition at line 153 of file astreamer.h.
References Assert, astreamer::bbs_ops, and astreamer_ops::free.
Referenced by astreamer_recovery_injector_free(), astreamer_tar_archiver_free(), astreamer_tar_parser_free(), astreamer_tar_terminator_free(), ReceiveArchiveStream(), ReceiveArchiveStreamChunk(), ReceiveTarFile(), and verify_tar_backup().
Definition at line 238 of file astreamer_gzip.c.
References Assert, if(), initStringInfo(), next, palloc0(), and pg_fatal.
Referenced by create_archive_verifier(), and CreateBackupStreamer().
astreamer* astreamer_gzip_writer_new | ( | char * | pathname, |
FILE * | file, | ||
pg_compress_specification * | compress | ||
) |
Definition at line 101 of file astreamer_gzip.c.
References fd(), pg_compress_specification::level, palloc0(), pg_fatal, and pstrdup().
Referenced by CreateBackupStreamer().
astreamer* astreamer_lz4_compressor_new | ( | astreamer * | next, |
pg_compress_specification * | compress | ||
) |
Definition at line 74 of file astreamer_lz4.c.
References Assert, initStringInfo(), pg_compress_specification::level, next, palloc0(), pg_fatal, and pg_log_error.
Referenced by CreateBackupStreamer().
Definition at line 279 of file astreamer_lz4.c.
References Assert, initStringInfo(), next, palloc0(), and pg_fatal.
Referenced by create_archive_verifier(), and CreateBackupStreamer().
astreamer* astreamer_plain_writer_new | ( | char * | pathname, |
FILE * | file | ||
) |
Definition at line 82 of file astreamer_file.c.
References astreamer_plain_writer_ops, astreamer_plain_writer::base, astreamer::bbs_ops, astreamer_plain_writer::file, palloc0(), astreamer_plain_writer::pathname, pg_fatal, pstrdup(), and astreamer_plain_writer::should_close_file.
Referenced by CreateBackupStreamer().
Definition at line 356 of file astreamer_tar.c.
References astreamer_tar_archiver_ops, astreamer_tar_archiver::base, astreamer::bbs_next, astreamer::bbs_ops, next, and palloc0().
Referenced by CreateBackupStreamer().
Definition at line 93 of file astreamer_tar.c.
References ASTREAMER_MEMBER_HEADER, astreamer_tar_parser_ops, astreamer_tar_parser::base, astreamer::bbs_buffer, astreamer::bbs_next, astreamer::bbs_ops, initStringInfo(), next, astreamer_tar_parser::next_context, and palloc0().
Referenced by create_archive_verifier(), and CreateBackupStreamer().
Definition at line 462 of file astreamer_tar.c.
References astreamer_tar_terminator_ops, astreamer::bbs_next, astreamer::bbs_ops, next, and palloc0().
Referenced by CreateBackupStreamer().
astreamer* astreamer_zstd_compressor_new | ( | astreamer * | next, |
pg_compress_specification * | compress | ||
) |
Definition at line 70 of file astreamer_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().
Definition at line 262 of file astreamer_zstd.c.
References Assert, enlargeStringInfo(), initStringInfo(), next, palloc0(), and pg_fatal.
Referenced by create_archive_verifier(), and CreateBackupStreamer().