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 42 of file CStringStream.cc.

References cms::cuda::assert(), edmScanValgrind::buffer, data, and mps_update::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 cms::cuda::assert(), edmScanValgrind::buffer, data, and mps_update::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);
}