diff options
Diffstat (limited to 'src/backend/replication/basebackup_zstd.c')
| -rw-r--r-- | src/backend/replication/basebackup_zstd.c | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/backend/replication/basebackup_zstd.c b/src/backend/replication/basebackup_zstd.c index 55dee6b0b5e..acb32275bcc 100644 --- a/src/backend/replication/basebackup_zstd.c +++ b/src/backend/replication/basebackup_zstd.c @@ -26,7 +26,7 @@ typedef struct bbsink_zstd bbsink base; /* Compression options */ - bc_specification *compress; + pg_compress_specification *compress; ZSTD_CCtx *cctx; ZSTD_outBuffer zstd_outBuf; @@ -58,7 +58,7 @@ const bbsink_ops bbsink_zstd_ops = { * Create a new basebackup sink that performs zstd compression. */ bbsink * -bbsink_zstd_new(bbsink *next, bc_specification *compress) +bbsink_zstd_new(bbsink *next, pg_compress_specification *compress) { #ifndef USE_ZSTD ereport(ERROR, @@ -90,13 +90,13 @@ bbsink_zstd_begin_backup(bbsink *sink) bbsink_zstd *mysink = (bbsink_zstd *) sink; size_t output_buffer_bound; size_t ret; - bc_specification *compress = mysink->compress; + pg_compress_specification *compress = mysink->compress; mysink->cctx = ZSTD_createCCtx(); if (!mysink->cctx) elog(ERROR, "could not create zstd compression context"); - if ((compress->options & BACKUP_COMPRESSION_OPTION_LEVEL) != 0) + if ((compress->options & PG_COMPRESSION_OPTION_LEVEL) != 0) { ret = ZSTD_CCtx_setParameter(mysink->cctx, ZSTD_c_compressionLevel, compress->level); @@ -105,7 +105,7 @@ bbsink_zstd_begin_backup(bbsink *sink) compress->level, ZSTD_getErrorName(ret)); } - if ((compress->options & BACKUP_COMPRESSION_OPTION_WORKERS) != 0) + if ((compress->options & PG_COMPRESSION_OPTION_WORKERS) != 0) { /* * On older versions of libzstd, this option does not exist, and trying |