bbstreamer_lz4.c File Reference

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

Include dependency graph for bbstreamer_lz4.c:

Go to the source code of this file.

Functions
bbstreamer *	bbstreamer_lz4_compressor_new (bbstreamer *next, pg_compress_specification *compress)
bbstreamer *	bbstreamer_lz4_decompressor_new (bbstreamer *next)

Function Documentation

bbstreamer_lz4_compressor_new()

bbstreamer* bbstreamer_lz4_compressor_new	(	bbstreamer *	next,
		pg_compress_specification *	compress
	)

Definition at line 70 of file bbstreamer_lz4.c.

{
#ifdef USE_LZ4
    bbstreamer_lz4_frame *streamer;
    LZ4F_errorCode_t ctxError;
    LZ4F_preferences_t *prefs;
 
    Assert(next != NULL);
 
    streamer = palloc0(sizeof(bbstreamer_lz4_frame));
    *((const bbstreamer_ops **) &streamer->base.bbs_ops) =
        &bbstreamer_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().

bbstreamer_lz4_decompressor_new()

bbstreamer* bbstreamer_lz4_decompressor_new

(

bbstreamer *

next

)

Definition at line 275 of file bbstreamer_lz4.c.

{
#ifdef USE_LZ4
    bbstreamer_lz4_frame *streamer;
    LZ4F_errorCode_t ctxError;
 
    Assert(next != NULL);
 
    streamer = palloc0(sizeof(bbstreamer_lz4_frame));
    *((const bbstreamer_ops **) &streamer->base.bbs_ops) =
        &bbstreamer_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 CreateBackupStreamer().