CStringStream.cc File Reference

#include <cassert>
#include <cstring>
#include "zlib.h"
#include "Alignment/Geners/interface/BZ2Handle.hh"
#include "Alignment/Geners/interface/CStringStream.hh"
#include "Alignment/Geners/interface/IOException.hh"

Go to the source code of this file.

Namespaces
	gs

Functions
static void	doBZ2Compression (const char *data, const unsigned long long len, const bool defl, bz_stream &strm, char *buffer, const unsigned long long bufLen, std::ostream &sink)
static void	doZlibCompression (const char *data, const unsigned long long len, const bool defl, z_stream_s &strm, char *buffer, const unsigned long long bufLen, std::ostream &sink)

Function Documentation

static void doBZ2Compression ( const char *  data, const unsigned long long  len, const bool  defl, bz_stream &  strm, char *  buffer, const unsigned long long  bufLen, std::ostream &  sink  )

static

Definition at line 45 of file CStringStream.cc.

References data, and ntuplemaker::status.

{
    assert(buffer);
    assert(bufLen);

    int status = BZ_OK;
    strm.next_in = const_cast<char*>(data);
    strm.avail_in = len;
    do 
    {
        strm.next_out = buffer;
        strm.avail_out = bufLen;
        status = defl ? BZ2_bzCompress(&strm, BZ_FINISH) :
                        BZ2_bzDecompress(&strm);
        assert(status == BZ_OK || status == BZ_STREAM_END);
        const unsigned have = bufLen - strm.avail_out;
        sink.write(buffer, have);
        if (sink.fail()) throw gs::IOWriteFailure(
            "In gs::doBZ2Compression: sink stream failure");
    } while (status != BZ_STREAM_END);
}

static void doZlibCompression ( const char *  data, const unsigned long long  len, const bool  defl, z_stream_s &  strm, char *  buffer, const unsigned long long  bufLen, std::ostream &  sink  )

static

Definition at line 10 of file CStringStream.cc.

References data, and ntuplemaker::status.

{
    assert(buffer);
    assert(bufLen);

    int status = Z_OK;
    strm.next_in = reinterpret_cast<Bytef*>(const_cast<char*>(data));
    strm.avail_in = len;
    do 
    {
        strm.next_out = reinterpret_cast<Bytef*>(buffer);
        strm.avail_out = bufLen;
        status = defl ? deflate(&strm, Z_FINISH) :
                        inflate(&strm, Z_NO_FLUSH);
        assert(status == Z_OK || status == Z_STREAM_END);
        const unsigned have = bufLen - strm.avail_out;
        sink.write(buffer, have);
        if (sink.fail()) throw gs::IOWriteFailure(
            "In gs::doZlibCompression: sink stream failure");
    } while (strm.avail_out == 0);

    if (defl)
    {
        assert(strm.avail_in == 0);
        assert(status == Z_STREAM_END);
        assert(deflateReset(&strm) == Z_OK);
    }
    else
        assert(inflateReset(&strm) == Z_OK);
}