AbsArchive.cc File Reference

#include <cassert>
#include <sstream>
#include "Alignment/Geners/interface/AbsArchive.hh"
#include "Alignment/Geners/interface/IOException.hh"

Go to the source code of this file.

Namespaces
	gs

Macros
#define	GS_STREAM_COPY_BUFFER_SIZE   65536

Functions
static void	archive_stream_copy (std::istream &in, std::size_t count, std::ostream &out)
static std::string	local_error_message (gs::AbsArchive &ar, const gs::AbsRecord &record, const char *failedAction)
gs::AbsArchive &	operator<< (gs::AbsArchive &ar, const gs::AbsRecord &record)

Macro Definition Documentation

#define GS_STREAM_COPY_BUFFER_SIZE   65536

Definition at line 7 of file AbsArchive.cc.

Referenced by archive_stream_copy().

Function Documentation

static void archive_stream_copy ( std::istream &  in, std::size_t  count, std::ostream &  out  )

static

Definition at line 9 of file AbsArchive.cc.

References edmScanValgrind::buffer, taus_updatedMVAIds_cff::category, GS_STREAM_COPY_BUFFER_SIZE, and dataset::name.

                                                                                  {
  if (count) {
    const std::size_t bufsize = GS_STREAM_COPY_BUFFER_SIZE;
    char buffer[bufsize];

    bool in_fail = in.fail();
    bool out_fail = out.fail();
    while (count > bufsize && !in_fail && !out_fail) {
      in.read(buffer, bufsize);
      in_fail = in.fail();
      if (!in_fail) {
        out.write(buffer, bufsize);
        out_fail = out.fail();
      }
      count -= bufsize;
    }
    if (!in_fail && !out_fail) {
      in.read(buffer, count);
      if (!in.fail())
        out.write(buffer, count);
    }
  }
}

static std::string local_error_message ( gs::AbsArchive &  ar, const gs::AbsRecord &  record, const char *  failedAction  )

static

Definition at line 131 of file AbsArchive.cc.

Referenced by operator<<().

                                                                                                            {
  std::ostringstream err;
  err << "In operator<<(gs::AbsArchive& ar, const gs::AbsRecord& record): "
      << "failed to " << failedAction << " to the archive \"" << ar.name() << "\" for item with type \""
      << record.type().name() << "\", name \"" << record.name() << "\", and category \"" << record.category() << '"';
  return err.str();
}

gs::AbsArchive& operator<<	(	gs::AbsArchive &	ar,
		const gs::AbsRecord &	record
	)

Definition at line 139 of file AbsArchive.cc.

References runEdmFileComparison::base, delta, triggerObjects_cff::id, and local_error_message().

                                                                      {
  // Do not reuse records
  if (record.id())
    throw gs::IOInvalidArgument(
        "In operator<<(gs::AbsArchive& ar, const gs::AbsRecord& record): "
        "records can not be reused");

  // Get the relevant streams. Do not change the order
  // of the next three lines, some code which does
  // not implement compression may actually rely on
  // the fact that the "outputStream()" method
  // is called before "compressedStream()".
  std::ostream &os = ar.outputStream();
  std::streampos base = os.tellp();
  std::ostream &compressed = ar.compressedStream(os);

  // Write the data
  if (!record.writeData(compressed))
    throw gs::IOWriteFailure(local_error_message(ar, record, "write data"));

  const unsigned compressCode = ar.flushCompressedRecord(compressed);
  if (os.fail())
    throw gs::IOWriteFailure(local_error_message(ar, record, "transfer compressed data"));

  // Figure out the record length. Naturally, can't have negative length.
  std::streamoff off = os.tellp() - base;
  const long long delta = off;
  assert(delta >= 0LL);

  // Add the record to the catalog
  const unsigned long long id = ar.addToCatalog(record, compressCode, delta);
  if (id == 0ULL)
    throw gs::IOWriteFailure(local_error_message(ar, record, "add catalog entry"));

  // Mark record as written and give feedback about item length
  record.itemId_ = id;
  record.itemLength_ = delta;

  // Same thing for the archive
  ar.lastItemId_ = id;
  ar.lastItemLength_ = delta;

  return ar;
}