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 GS_STREAM_COPY_BUFFER_SIZE.

{
    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 143 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 157 of file AbsArchive.cc.

References newFWLiteAna::base, delta, 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;
}