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

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

◆ GS_STREAM_COPY_BUFFER_SIZE

#define GS_STREAM_COPY_BUFFER_SIZE 65536

Definition at line 7 of file AbsArchive.cc.

Function Documentation

◆ archive_stream_copy()

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

static

Definition at line 9 of file AbsArchive.cc.

                                                                                   {
   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);
     }
   }
 }

References edmScanValgrind::buffer, submitPVResolutionJobs::count, GS_STREAM_COPY_BUFFER_SIZE, recoMuon::in, and MillePedeFileConverter_cfg::out.

◆ local_error_message()

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.

                                                                                                             {
   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();
 }

References submitPVResolutionJobs::err, and GlobalPosition_Frontier_DevDB_cff::record.

Referenced by operator<<().

◆ operator<<()

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

Definition at line 139 of file AbsArchive.cc.

                                                                       {
   // 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;
 }

References cms::cuda::assert(), newFWLiteAna::base, dumpMFGeometry_cfg::delta, triggerObjects_cff::id, L1DTConfigBti_cff::LL, local_error_message(), and GlobalPosition_Frontier_DevDB_cff::record.

Namespaces