astreamer_lz4.c File Reference

#include "postgres_fe.h"
#include <unistd.h>
#include "common/file_perm.h"
#include "common/logging.h"
#include "common/string.h"
#include "fe_utils/astreamer.h"

Include dependency graph for astreamer_lz4.c:

Go to the source code of this file.

Functions
astreamer *	astreamer_lz4_compressor_new (astreamer *next, pg_compress_specification *compress)
astreamer *	astreamer_lz4_decompressor_new (astreamer *next)

Function Documentation

astreamer_lz4_compressor_new()

astreamer* astreamer_lz4_compressor_new	(	astreamer *	next,
		pg_compress_specification *	compress
	)

Definition at line 74 of file astreamer_lz4.c.

{
#ifdef USE_LZ4
    astreamer_lz4_frame *streamer;
    LZ4F_errorCode_t ctxError;
    LZ4F_preferences_t *prefs;
 
    Assert(next != NULL);
 
    streamer = palloc0(sizeof(astreamer_lz4_frame));
    *((const astreamer_ops **) &streamer->base.bbs_ops) =
        &astreamer_lz4_compressor_ops;
 
    streamer->base.bbs_next = next;
    initStringInfo(&streamer->base.bbs_buffer);
    streamer->header_written = false;
 
    /* Initialize stream compression preferences */
    prefs = &streamer->prefs;
    memset(prefs, 0, sizeof(LZ4F_preferences_t));
    prefs->frameInfo.blockSizeID = LZ4F_max256KB;
    prefs->compressionLevel = compress->level;
 
    ctxError = LZ4F_createCompressionContext(&streamer->cctx, LZ4F_VERSION);
    if (LZ4F_isError(ctxError))
        pg_log_error("could not create lz4 compression context: %s",
                     LZ4F_getErrorName(ctxError));
 
    return &streamer->base;
#else
    pg_fatal("this build does not support compression with %s", "LZ4");
    return NULL;                /* keep compiler quiet */
#endif
}

References Assert, initStringInfo(), pg_compress_specification::level, next, palloc0(), pg_fatal, and pg_log_error.

Referenced by CreateBackupStreamer().

astreamer_lz4_decompressor_new()

astreamer* astreamer_lz4_decompressor_new

(

astreamer *

next

)

Definition at line 279 of file astreamer_lz4.c.

{
#ifdef USE_LZ4
    astreamer_lz4_frame *streamer;
    LZ4F_errorCode_t ctxError;
 
    Assert(next != NULL);
 
    streamer = palloc0(sizeof(astreamer_lz4_frame));
    *((const astreamer_ops **) &streamer->base.bbs_ops) =
        &astreamer_lz4_decompressor_ops;
 
    streamer->base.bbs_next = next;
    initStringInfo(&streamer->base.bbs_buffer);
 
    /* Initialize internal stream state for decompression */
    ctxError = LZ4F_createDecompressionContext(&streamer->dctx, LZ4F_VERSION);
    if (LZ4F_isError(ctxError))
        pg_fatal("could not initialize compression library: %s",
                 LZ4F_getErrorName(ctxError));
 
    return &streamer->base;
#else
    pg_fatal("this build does not support compression with %s", "LZ4");
    return NULL;                /* keep compiler quiet */
#endif
}

References Assert, initStringInfo(), next, palloc0(), and pg_fatal.

Referenced by create_archive_verifier(), and CreateBackupStreamer().