CastorDbProducer.cc

Go to the documentation of this file.

// -*- C++ -*-
//
// Package:    CastorDbProducer
// Class:      CastorDbProducer
// 
//
// Original Author:  Fedor Ratnikov
//         Created:  Tue Aug  9 19:10:10 CDT 2005
//         Adapted for CASTOR by L. Mundim
//
//


// system include files
#include <iostream>
#include <fstream>

#include "FWCore/Framework/interface/ESHandle.h"

#include "CalibCalorimetry/CastorCalib/interface/CastorDbASCIIIO.h"
#include "CalibFormats/CastorObjects/interface/CastorDbService.h"
#include "CalibFormats/CastorObjects/interface/CastorDbRecord.h"


#include "CondFormats/CastorObjects/interface/AllObjects.h"

#include "CastorDbProducer.h"

CastorDbProducer::CastorDbProducer( const edm::ParameterSet& fConfig)
  : ESProducer(),
    mDumpRequest (),
    mDumpStream(nullptr)
{
  //the following line is needed to tell the framework what
  // data is being produced
  setWhatProduced(this);

  //now do what ever other initialization is needed

  mDumpRequest = fConfig.getUntrackedParameter <std::vector <std::string> > ("dump", std::vector<std::string>());
  if (!mDumpRequest.empty()) {
    std::string otputFile = fConfig.getUntrackedParameter <std::string> ("file", "");
    mDumpStream = otputFile.empty () ? &std::cout : new std::ofstream (otputFile.c_str());
  }
}


CastorDbProducer::~CastorDbProducer()
{
 
   // do anything here that needs to be done at desctruction time
   // (e.g. close files, deallocate resources etc.)
  if (mDumpStream != &std::cout) delete mDumpStream;
}


//
// member functions
//

// ------------ method called to produce the data  ------------
std::shared_ptr<CastorDbService> CastorDbProducer::produce( const CastorDbRecord& record)
{
  auto host = holder_.makeOrGet([]() {
    return new HostType;
  });

  bool needBuildCalibrations = false;
  bool needBuildCalibWidths = false;

  host->ifRecordChanges<CastorElectronicsMapRcd>(record,
                                                 [this, h=host.get()](auto const& rec) {
    setupElectronicsMap(rec, h);
  });
  host->ifRecordChanges<CastorChannelQualityRcd>(record,
                                                 [this, h=host.get()](auto const& rec) {
    setupChannelQuality(rec, h);
  });
  host->ifRecordChanges<CastorGainWidthsRcd>(record,
                                             [this, h=host.get(),
                                              &needBuildCalibWidths](auto const& rec) {
    setupGainWidths(rec, h);
    needBuildCalibWidths = true;
  });
  host->ifRecordChanges<CastorQIEDataRcd>(record,
                                          [this, h=host.get(),
                                           &needBuildCalibrations,
                                           &needBuildCalibWidths](auto const& rec) {
    setupQIEData(rec, h);
    needBuildCalibrations = true;
    needBuildCalibWidths = true;
  });
  host->ifRecordChanges<CastorPedestalWidthsRcd>(record,
                                                 [this, h=host.get(),
                                                  &needBuildCalibWidths](auto const& rec) {
    setupPedestalWidths(rec, h);
    needBuildCalibWidths = true;
  });
  host->ifRecordChanges<CastorGainsRcd>(record,
                                        [this, h=host.get(),
                                         &needBuildCalibrations](auto const& rec) {
    setupGains(rec, h);
    needBuildCalibrations = true;
  });
  host->ifRecordChanges<CastorPedestalsRcd>(record,
                                            [this, h=host.get(),
                                             &needBuildCalibrations](auto const& rec) {
    setupPedestals(rec, h);
    needBuildCalibrations = true;
  });

  if (needBuildCalibWidths) {
    host->buildCalibWidths();
  }

  if (needBuildCalibrations) {
    host->buildCalibrations();
  }

  return host; // automatically converts to std::shared_ptr<CastorDbService>
}

void CastorDbProducer::setupPedestals(const CastorPedestalsRcd& fRecord,
                                      CastorDbService* service) {

  edm::ESHandle <CastorPedestals> item;
  fRecord.get (item);

  service->setData(item.product());
  if (std::find (mDumpRequest.begin(), mDumpRequest.end(), std::string ("Pedestals")) != mDumpRequest.end()) {
    *mDumpStream << "New HCAL/CASTOR Pedestals set" << std::endl;
    CastorDbASCIIIO::dumpObject (*mDumpStream, *(item.product ()));
  }
}

void CastorDbProducer::setupPedestalWidths(const CastorPedestalWidthsRcd& fRecord,
                                           CastorDbService* service) {
  edm::ESHandle <CastorPedestalWidths> item;
  fRecord.get (item);
  service->setData(item.product());
  if (std::find (mDumpRequest.begin(), mDumpRequest.end(), std::string ("PedestalWidths")) != mDumpRequest.end()) {
    *mDumpStream << "New HCAL/CASTOR Pedestals set" << std::endl;
    CastorDbASCIIIO::dumpObject (*mDumpStream, *(item.product ()));
  }
}


void CastorDbProducer::setupGains(const CastorGainsRcd& fRecord,
                                  CastorDbService* service) {
  edm::ESHandle <CastorGains> item;
  fRecord.get (item);
  service->setData(item.product());
  if (std::find (mDumpRequest.begin(), mDumpRequest.end(), std::string ("Gains")) != mDumpRequest.end()) {
    *mDumpStream << "New HCAL/CASTOR Gains set" << std::endl;
    CastorDbASCIIIO::dumpObject (*mDumpStream, *(item.product ()));
  }
}


void CastorDbProducer::setupGainWidths(const CastorGainWidthsRcd& fRecord,
                                       CastorDbService* service) {
  edm::ESHandle <CastorGainWidths> item;
  fRecord.get (item);
  service->setData(item.product());
  if (std::find (mDumpRequest.begin(), mDumpRequest.end(), std::string ("GainWidths")) != mDumpRequest.end()) {
    *mDumpStream << "New HCAL/CASTOR GainWidths set" << std::endl;
    CastorDbASCIIIO::dumpObject (*mDumpStream, *(item.product ()));
  }
}

void CastorDbProducer::setupQIEData(const CastorQIEDataRcd& fRecord,
                                    CastorDbService* service) {
  edm::ESHandle <CastorQIEData> item;
  fRecord.get (item);
  service->setData(item.product());
  if (std::find (mDumpRequest.begin(), mDumpRequest.end(), std::string ("QIEData")) != mDumpRequest.end()) {
    *mDumpStream << "New HCAL/CASTOR QIEData set" << std::endl;
    CastorDbASCIIIO::dumpObject (*mDumpStream, *(item.product ()));
  }
}

void CastorDbProducer::setupChannelQuality(const CastorChannelQualityRcd& fRecord,
                                           CastorDbService* service) {
  edm::ESHandle <CastorChannelQuality> item;
  fRecord.get (item);
  service->setData(item.product());
  if (std::find (mDumpRequest.begin(), mDumpRequest.end(), std::string ("ChannelQuality")) != mDumpRequest.end()) {
    *mDumpStream << "New HCAL/CASTOR ChannelQuality set" << std::endl;
    CastorDbASCIIIO::dumpObject (*mDumpStream, *(item.product ()));
  }
}

void CastorDbProducer::setupElectronicsMap(const CastorElectronicsMapRcd& fRecord,
                                           CastorDbService* service) {
  edm::ESHandle <CastorElectronicsMap> item;
  fRecord.get (item);
  service->setData(item.product());
  if (std::find (mDumpRequest.begin(), mDumpRequest.end(), std::string ("ElectronicsMap")) != mDumpRequest.end()) {
    *mDumpStream << "New HCAL/CASTOR Electronics Map set" << std::endl;
    CastorDbASCIIIO::dumpObject (*mDumpStream, *(item.product ()));
  }
}