PuttableSourceBase.cc

Go to the documentation of this file.

// -*- C++ -*-
//
// Package:     FWCore/Sources
// Class  :     PuttableSourceBase
// 
// Implementation:
//     [Notes on implementation]
//
// Original Author:  root
//         Created:  Tue, 26 Sep 2017 20:52:26 GMT
//

// system include files

// user include files
#include "FWCore/Sources/interface/PuttableSourceBase.h"

#include "DataFormats/Provenance/interface/ProductRegistry.h"
#include "DataFormats/Provenance/interface/ProductResolverIndexHelper.h"

#include "FWCore/Framework/interface/LuminosityBlock.h"
#include "FWCore/Framework/interface/Run.h"
#include "FWCore/Framework/interface/Event.h"
#include "FWCore/Framework/interface/ExceptionHelpers.h"

using namespace edm;
//
// constants, enums and typedefs
//

//
// static data member definitions
//

//
// constructors and destructor
//
PuttableSourceBase::PuttableSourceBase(ParameterSet const& iPSet, InputSourceDescription const& iISD):
InputSource(iPSet,iISD)
{
}

void
PuttableSourceBase::registerProducts() {
  registerProducts(this,&productRegistryUpdate(),moduleDescription());
}

void
PuttableSourceBase::beginJob() {
  auto r = productRegistry();
  auto const runLookup = r->productLookup(InRun);
  auto const lumiLookup = r->productLookup(InLumi);
  auto const eventLookup = r->productLookup(InEvent);
  auto const& processName = moduleDescription().processName();
  auto const& moduleLabel = moduleDescription().moduleLabel();
  
  auto const& runModuleToIndicies = runLookup->indiciesForModulesInProcess(processName);
  auto const& lumiModuleToIndicies = lumiLookup->indiciesForModulesInProcess(processName);
  auto const& eventModuleToIndicies = eventLookup->indiciesForModulesInProcess(processName);
  resolvePutIndicies(InRun,runModuleToIndicies,moduleLabel);
  resolvePutIndicies(InLumi,lumiModuleToIndicies,moduleLabel);
  resolvePutIndicies(InEvent,eventModuleToIndicies,moduleLabel);
}

void
PuttableSourceBase::doBeginRun(RunPrincipal& rp, ProcessContext const* ) {
  Run run(rp, moduleDescription(), nullptr);
  run.setProducer(this);
  callWithTryCatchAndPrint<void>( [this,&run](){ beginRun(run); }, "Calling Source::beginRun" );
  commit_(run);
}

void
PuttableSourceBase::doEndRun(RunPrincipal& rp, bool cleaningUpAfterException, ProcessContext const* ) {
  Run run(rp, moduleDescription(), nullptr);
  run.setProducer(this);
  callWithTryCatchAndPrint<void>( [this,&run](){ endRun(run); }, "Calling Source::endRun", cleaningUpAfterException );
  commit_(run);
}

void
PuttableSourceBase::doBeginLumi(LuminosityBlockPrincipal& lbp, ProcessContext const* ) {
  LuminosityBlock lb(lbp, moduleDescription(), nullptr);
  lb.setProducer(this);
  callWithTryCatchAndPrint<void>( [this,&lb](){ beginLuminosityBlock(lb); }, "Calling Source::beginLuminosityBlock" );
  commit_(lb);
}

void
PuttableSourceBase::doEndLumi(LuminosityBlockPrincipal& lbp, bool cleaningUpAfterException, ProcessContext const* ) {
  LuminosityBlock lb(lbp, moduleDescription(), nullptr);
  lb.setProducer(this);
  callWithTryCatchAndPrint<void>( [this,&lb](){ endLuminosityBlock(lb); }, "Calling Source::endLuminosityBlock", cleaningUpAfterException );
  commit_(lb);
}

void
PuttableSourceBase::beginRun(Run&) {
}

void
PuttableSourceBase::endRun(Run&) {
}

void
PuttableSourceBase::beginLuminosityBlock(LuminosityBlock&) {
}

void
PuttableSourceBase::endLuminosityBlock(LuminosityBlock&) {
}