15 #ifndef __COMPRESS_IO__
16 #define __COMPRESS_IO__
27 #define DEFAULT_IO_BUFFER_SIZE 4096
62 const void *
data,
size_t dLen);
size_t(* ReadFunc)(ArchiveHandle *AH, char **buf, size_t *buflen)
bool EndCompressFileHandle(CompressFileHandle *CFH)
char * supports_compression(const pg_compress_specification compression_spec)
CompressorState * AllocateCompressor(const pg_compress_specification compression_spec, ReadFunc readF, WriteFunc writeF)
void(* WriteFunc)(ArchiveHandle *AH, const char *buf, size_t len)
void EndCompressor(ArchiveHandle *AH, CompressorState *cs)
CompressFileHandle * InitDiscoverCompressFileHandle(const char *path, const char *mode)
CompressFileHandle * InitCompressFileHandle(const pg_compress_specification compression_spec)
static PgChecksumMode mode
static int fd(const char *x, int i)
static pg_noinline void Size size
bool(* open_write_func)(const char *path, const char *mode, CompressFileHandle *CFH)
bool(* write_func)(const void *ptr, size_t size, struct CompressFileHandle *CFH)
int(* getc_func)(CompressFileHandle *CFH)
bool(* eof_func)(CompressFileHandle *CFH)
bool(* open_func)(const char *path, int fd, const char *mode, CompressFileHandle *CFH)
pg_compress_specification compression_spec
bool(* close_func)(CompressFileHandle *CFH)
bool(* read_func)(void *ptr, size_t size, size_t *rsize, CompressFileHandle *CFH)
void(* readData)(ArchiveHandle *AH, CompressorState *cs)
pg_compress_specification compression_spec
void(* end)(ArchiveHandle *AH, CompressorState *cs)
void(* writeData)(ArchiveHandle *AH, CompressorState *cs, const void *data, size_t dLen)