SiPixelFEDChannelContainerWriteFromASCII

Line Code
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168
// -*- C++ -*-
//
// Package:    CondFormats/SiPixelObjects
// Class:      SiPixelFEDChannelContainerTestWriter
//
/**\class SiPixelFEDChannelContainerTestWriter SiPixelFEDChannelContainerTestWriter.cc CondFormats/SiPixelObjects/plugins/SiPixelFEDChannelContainerTestWriter.cc
 Description: class to build the SiPixelFEDChannelContainer payloads
*/
//
// Original Author:  Marco Musich
//         Created:  Wed, 27 Nov 2018 12:04:36 GMT
//
//

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

// user include files
#include "CondCore/DBOutputService/interface/PoolDBOutputService.h"
#include "CondFormats/SiPixelObjects/interface/SiPixelQuality.h"
#include "CondFormats/SiPixelObjects/interface/SiPixelFEDChannelContainer.h"
#include "CondFormats/SiPixelObjects/interface/SiPixelFedCablingMap.h"
#include "CondFormats/DataRecord/interface/SiPixelFedCablingMapRcd.h"
#include "CondFormats/DataRecord/interface/SiPixelQualityFromDbRcd.h"
#include "FWCore/Framework/interface/ESHandle.h"
#include "FWCore/Framework/interface/ESWatcher.h"
#include "FWCore/Framework/interface/Event.h"
#include "FWCore/Framework/interface/Frameworkfwd.h"
#include "FWCore/Framework/interface/MakerMacros.h"
#include "FWCore/Framework/interface/one/EDAnalyzer.h"
#include "FWCore/ParameterSet/interface/ParameterSet.h"
#include "FWCore/ServiceRegistry/interface/Service.h"

//
// class declaration
//

class SiPixelFEDChannelContainerWriteFromASCII : public edm::one::EDAnalyzer<> {
public:
  explicit SiPixelFEDChannelContainerWriteFromASCII(const edm::ParameterSet&);
  ~SiPixelFEDChannelContainerWriteFromASCII() override;

  static void fillDescriptions(edm::ConfigurationDescriptions& descriptions);

private:
  void analyze(const edm::Event&, const edm::EventSetup&) override;
  void endJob() override;

  // ----------member data ---------------------------
  const std::string m_record;
  const std::string m_SnapshotInputs;
  const bool printdebug_;
  const bool addDefault_;
  SiPixelFEDChannelContainer* myQualities;
};

//
// constructors and destructor
//
SiPixelFEDChannelContainerWriteFromASCII::SiPixelFEDChannelContainerWriteFromASCII(const edm::ParameterSet& iConfig)
    : m_record(iConfig.getParameter<std::string>("record")),
      m_SnapshotInputs(iConfig.getParameter<std::string>("snapshots")),
      printdebug_(iConfig.getUntrackedParameter<bool>("printDebug", false)),
      addDefault_(iConfig.getUntrackedParameter<bool>("addDefault", false)) {
  //now do what ever initialization is needed
  myQualities = new SiPixelFEDChannelContainer();
}

SiPixelFEDChannelContainerWriteFromASCII::~SiPixelFEDChannelContainerWriteFromASCII() { delete myQualities; }

//
// member functions
//

// ------------ method called for each event  ------------
void SiPixelFEDChannelContainerWriteFromASCII::analyze(const edm::Event& iEvent, const edm::EventSetup& iSetup) {
  using namespace edm;

  std::ifstream mysnapshots(m_SnapshotInputs);
  std::string line;

  std::string scenario = "";
  unsigned int thedetid(0);

  SiPixelFEDChannelContainer::SiPixelFEDChannelCollection theBadFEDChannels;

  if (mysnapshots.is_open()) {
    while (getline(mysnapshots, line)) {
      if (printdebug_) {
        edm::LogVerbatim("SiPixelFEDChannelContainerWriteFromASCII") << line << std::endl;
      }
      std::istringstream iss(line);
      unsigned int run, ls, detid, fed, link, roc_first, roc_last;
      iss >> run >> ls >> detid >> fed >> link >> roc_first >> roc_last;

      PixelFEDChannel theBadChannel{fed, link, roc_first, roc_last};

      auto newscenario = std::to_string(run) + "_" + std::to_string(ls);
      if (newscenario != scenario) {
        edm::LogVerbatim("SiPixelFEDChannelContainerWriteFromASCII") << "================================" << std::endl;
        edm::LogVerbatim("SiPixelFEDChannelContainerWriteFromASCII")
            << "found a new scenario: " << newscenario << std::endl;
        if (!scenario.empty()) {
          edm::LogVerbatim("SiPixelFEDChannelContainerWriteFromASCII")
              << "size of the fed channel vector: " << theBadFEDChannels.size() << std::endl;
          edm::LogVerbatim("SiPixelFEDChannelContainerWriteFromASCII")
              << "================================" << std::endl;
          myQualities->setScenario(scenario, theBadFEDChannels);
          theBadFEDChannels.clear();
        }
        scenario = newscenario;
      }

      if (detid != thedetid) {
        if (printdebug_) {
          edm::LogVerbatim("SiPixelFEDChannelContainerWriteFromASCII") << "found a new detid!" << detid << std::endl;
        }
        thedetid = detid;
      }
      theBadFEDChannels[thedetid].push_back(theBadChannel);
    }
  }

  myQualities->setScenario(scenario, theBadFEDChannels);

  if (printdebug_) {
    edm::LogInfo("SiPixelFEDChannelContainerWriteFromASCII") << "Content of SiPixelFEDChannelContainer " << std::endl;

    // use buil-in method in the CondFormat
    myQualities->printAll();
  }
}

// ------------ method called once each job just after ending the event loop  ------------
void SiPixelFEDChannelContainerWriteFromASCII::endJob() {
  // adds an empty payload with name "default" => no channels are masked
  if (addDefault_) {
    SiPixelFEDChannelContainer::SiPixelFEDChannelCollection theBadFEDChannels;
    myQualities->setScenario("default", theBadFEDChannels);
  }

  edm::LogInfo("SiPixelFEDChannelContainerWriteFromASCII")
      << "Size of SiPixelFEDChannelContainer object " << myQualities->size() << std::endl
      << std::endl;

  // Form the data here
  edm::Service<cond::service::PoolDBOutputService> poolDbService;
  if (poolDbService.isAvailable()) {
    cond::Time_t valid_time = poolDbService->currentTime();
    // this writes the payload to begin in current run defined in cfg
    poolDbService->writeOneIOV(*myQualities, valid_time, m_record);
  }
}

// ------------ method fills 'descriptions' with the allowed parameters for the module  ------------
void SiPixelFEDChannelContainerWriteFromASCII::fillDescriptions(edm::ConfigurationDescriptions& descriptions) {
  edm::ParameterSetDescription desc;
  desc.setComment("Writes payloads of type SiPixelFEDChannelContainer from input ASCII files");
  desc.addUntracked<bool>("printDebug", true);
  desc.addUntracked<bool>("addDefault", true);
  desc.add<std::string>("snapshots", "");
  desc.add<std::string>("record", "SiPixelStatusScenariosRcd");
  descriptions.add("SiPixelFEDChannelContainerWriteFromASCII", desc);
}

//define this as a plug-in
DEFINE_FWK_MODULE(SiPixelFEDChannelContainerWriteFromASCII);