StreamDQMDeserializer.cc

Go to the documentation of this file.

#include "FWCore/Utilities/interface/DebugMacros.h"
#include "FWCore/Utilities/interface/Exception.h"
#include "IOPool/Streamer/interface/StreamDQMDeserializer.h"
#include "IOPool/Streamer/interface/StreamerInputSource.h"
#include "FWCore/Utilities/interface/Adler32Calculator.h"
#include <iostream>

namespace edm
{
  namespace {
    const int init_size = 1024*1024;
  }

  StreamDQMDeserializer::StreamDQMDeserializer():
    decompressBuffer_(init_size),
    workTBuffer_(TBuffer::kRead, init_size)
  { }

  std::auto_ptr<DQMEvent::TObjectTable>
  StreamDQMDeserializer::deserializeDQMEvent(DQMEventMsgView const& dqmEventView)
  {
    if (dqmEventView.code() != Header::DQM_EVENT)
      throw cms::Exception("StreamTranslation",
                           "DQM Event deserialization error")
        << "received wrong message type: expected DQM_EVENT ("
        << Header::DQM_EVENT << "), got " << dqmEventView.code() << "\n";
    FDEBUG(9) << "Deserialing DQM event: "
         << dqmEventView.eventNumberAtUpdate() << " "
         << dqmEventView.runNumber() << " "
         << dqmEventView.size() << " "
         << dqmEventView.adler32_chksum() << " "
         << dqmEventView.hostName() << " "
         << dqmEventView.eventLength() << " "
         << dqmEventView.eventAddress()
         << std::endl;


    // create the folder name to TObject map
    std::auto_ptr<DQMEvent::TObjectTable> tablePtr(new DQMEvent::TObjectTable());

    // fetch the number of subfolders
    uint32 subFolderCount = dqmEventView.subFolderCount();

    // handle compressed data, if needed
    unsigned char *bufPtr = dqmEventView.eventAddress();
    unsigned int bufLen = dqmEventView.eventLength();
    unsigned int originalSize = dqmEventView.compressionFlag();

    uint32_t adler32_chksum = cms::Adler32((char*)dqmEventView.eventAddress(), dqmEventView.eventLength());
    if((uint32)adler32_chksum != dqmEventView.adler32_chksum()) {
      throw cms::Exception("StreamTranslation",
                           "DQM Event chksum error")
          << "Error from StreamDQMSerializer: checksum of event data blob failed:" << std::endl
          << "chksum from event = " << adler32_chksum << " from header = "
          << dqmEventView.adler32_chksum() << " host name = "
          << dqmEventView.hostName() << std::endl;
    }

    if (originalSize != 0)
      {
        unsigned int actualSize =
          StreamerInputSource::uncompressBuffer(bufPtr, bufLen,
                                               decompressBuffer_,
                                               originalSize);
        bufPtr = &decompressBuffer_[0];
        bufLen = actualSize;
      }

    // wrap a TBuffer around the DQM event data so that we can read out the
    // monitor elements
    workTBuffer_.Reset();
    workTBuffer_.SetBuffer(bufPtr, bufLen, kFALSE);

    // loop over the subfolders
    for (uint32 fdx = 0; fdx < subFolderCount; fdx++)
      {

        // create the list of monitor elements in the subfolder
        std::vector<TObject *> meList;
        int meCount = dqmEventView.meCount(fdx);
        for (int mdx = 0; mdx < meCount; mdx++)
          {
            TObject *tmpPtr = workTBuffer_.ReadObject(TObject::Class());
            meList.push_back(tmpPtr);
          }

        // store the list of monitor elements in the table
        std::string subFolderName = dqmEventView.subFolderName(fdx);
        (*tablePtr)[subFolderName] = meList;
      }

    return tablePtr;
  }
}