diff options
Diffstat (limited to 'src/bin/pg_basebackup/bbstreamer_zstd.c')
| -rw-r--r-- | src/bin/pg_basebackup/bbstreamer_zstd.c | 33 |
1 files changed, 10 insertions, 23 deletions
diff --git a/src/bin/pg_basebackup/bbstreamer_zstd.c b/src/bin/pg_basebackup/bbstreamer_zstd.c index f94c5c041d3..e2c76503cc7 100644 --- a/src/bin/pg_basebackup/bbstreamer_zstd.c +++ b/src/bin/pg_basebackup/bbstreamer_zstd.c @@ -82,10 +82,7 @@ bbstreamer_zstd_compressor_new(bbstreamer *next, bc_specification *compress) streamer->cctx = ZSTD_createCCtx(); if (!streamer->cctx) - { - pg_log_error("could not create zstd compression context"); - exit(1); - } + pg_fatal("could not create zstd compression context"); /* Set compression level, if specified */ if ((compress->options & BACKUP_COMPRESSION_OPTION_LEVEL) != 0) @@ -93,11 +90,8 @@ bbstreamer_zstd_compressor_new(bbstreamer *next, bc_specification *compress) ret = ZSTD_CCtx_setParameter(streamer->cctx, ZSTD_c_compressionLevel, compress->level); if (ZSTD_isError(ret)) - { - pg_log_error("could not set zstd compression level to %d: %s", - compress->level, ZSTD_getErrorName(ret)); - exit(1); - } + pg_fatal("could not set zstd compression level to %d: %s", + compress->level, ZSTD_getErrorName(ret)); } /* Set # of workers, if specified */ @@ -111,11 +105,8 @@ bbstreamer_zstd_compressor_new(bbstreamer *next, bc_specification *compress) ret = ZSTD_CCtx_setParameter(streamer->cctx, ZSTD_c_nbWorkers, compress->workers); if (ZSTD_isError(ret)) - { - pg_log_error("could not set compression worker count to %d: %s", - compress->workers, ZSTD_getErrorName(ret)); - exit(1); - } + pg_fatal("could not set compression worker count to %d: %s", + compress->workers, ZSTD_getErrorName(ret)); } /* Initialize the ZSTD output buffer. */ @@ -125,8 +116,7 @@ bbstreamer_zstd_compressor_new(bbstreamer *next, bc_specification *compress) return &streamer->base; #else - pg_log_error("this build does not support zstd compression"); - exit(1); + pg_fatal("this build does not support zstd compression"); #endif } @@ -271,10 +261,7 @@ bbstreamer_zstd_decompressor_new(bbstreamer *next) streamer->dctx = ZSTD_createDCtx(); if (!streamer->dctx) - { - pg_log_error("could not create zstd decompression context"); - exit(1); - } + pg_fatal("could not create zstd decompression context"); /* Initialize the ZSTD output buffer. */ streamer->zstd_outBuf.dst = streamer->base.bbs_buffer.data; @@ -283,8 +270,7 @@ bbstreamer_zstd_decompressor_new(bbstreamer *next) return &streamer->base; #else - pg_log_error("this build does not support compression"); - exit(1); + pg_fatal("this build does not support zstd compression"); #endif } @@ -328,7 +314,8 @@ bbstreamer_zstd_decompressor_content(bbstreamer *streamer, &mystreamer->zstd_outBuf, &inBuf); if (ZSTD_isError(ret)) - pg_log_error("could not decompress data: %s", ZSTD_getErrorName(ret)); + pg_log_error("could not decompress data: %s", + ZSTD_getErrorName(ret)); } } |