edm::service::CheckTransitions Class Reference

Public Types
enum	Phase {   Phase::kBeginRun, Phase::kBeginLumi, Phase::kEvent, Phase::kEndLumi,   Phase::kEndRun }
enum	Transition {   Transition::IsInvalid, Transition::IsStop, Transition::IsFile, Transition::IsRun,   Transition::IsLumi, Transition::IsEvent }

Public Member Functions
	CheckTransitions (const ParameterSet &, ActivityRegistry &)
void	postEndJob ()
void	preallocate (service::SystemBounds const &)
void	preBeginJob (PathsAndConsumesOfModulesBase const &, ProcessContext const &)
void	preCloseFile (std::string const &lfn, bool primary)
void	preEvent (StreamContext const &)
void	preGlobalBeginLumi (GlobalContext const &)
void	preGlobalBeginRun (GlobalContext const &)
void	preGlobalEndLumi (GlobalContext const &)
void	preGlobalEndRun (GlobalContext const &)
void	preOpenFile (std::string const &, bool)
void	preStreamBeginLumi (StreamContext const &)
void	preStreamBeginRun (StreamContext const &)
void	preStreamEndLumi (StreamContext const &)
void	preStreamEndRun (StreamContext const &)
	~CheckTransitions ()(false)

Static Public Member Functions
static void	fillDescriptions (edm::ConfigurationDescriptions &descriptions)

Private Attributes
std::vector< std::pair< Transition, edm::EventID > >	m_expectedTransitions
bool	m_failed = false
int	m_nstreams =0
tbb::concurrent_vector< std::tuple< Phase, edm::EventID, int > >	m_seenTransitions

Detailed Description

Definition at line 40 of file CheckTransitions.cc.

Member Enumeration Documentation

enum edm::service::CheckTransitions::Phase

strong

Enumerator
kBeginRun
kBeginLumi
kEvent
kEndLumi
kEndRun

Definition at line 43 of file CheckTransitions.cc.

                       {
        kBeginRun,
        kBeginLumi,
        kEvent,
        kEndLumi,
        kEndRun
      };

enum edm::service::CheckTransitions::Transition

strong

Enumerator
IsInvalid
IsStop
IsFile
IsRun
IsLumi
IsEvent

Definition at line 51 of file CheckTransitions.cc.

                            {
        IsInvalid,
        IsStop,
        IsFile,
        IsRun,
        IsLumi,
        IsEvent
      };

Constructor & Destructor Documentation

CheckTransitions::CheckTransitions	(	const ParameterSet &	,
		ActivityRegistry &
	)

Definition at line 202 of file CheckTransitions.cc.

References edm::ParameterSet::getUntrackedParameter(), m_expectedTransitions, AlCaHLTBitMon_ParallelJobs::p, postEndJob(), preallocate(), preCloseFile(), preEvent(), preGlobalBeginLumi(), preGlobalBeginRun(), preGlobalEndLumi(), preGlobalEndRun(), preOpenFile(), preStreamBeginLumi(), preStreamBeginRun(), preStreamEndLumi(), preStreamEndRun(), AlCaHLTBitMon_QueryRunRegistry::string, edm::ActivityRegistry::watchPostEndJob(), edm::ActivityRegistry::watchPreallocate(), edm::ActivityRegistry::watchPreCloseFile(), edm::ActivityRegistry::watchPreEvent(), edm::ActivityRegistry::watchPreGlobalBeginLumi(), edm::ActivityRegistry::watchPreGlobalBeginRun(), edm::ActivityRegistry::watchPreGlobalEndLumi(), edm::ActivityRegistry::watchPreGlobalEndRun(), edm::ActivityRegistry::watchPreOpenFile(), edm::ActivityRegistry::watchPreStreamBeginLumi(), edm::ActivityRegistry::watchPreStreamBeginRun(), edm::ActivityRegistry::watchPreStreamEndLumi(), and edm::ActivityRegistry::watchPreStreamEndRun().

{
  for( auto const& p: iPS.getUntrackedParameter<std::vector<edm::ParameterSet>>("transitions")) {
    m_expectedTransitions.emplace_back( stringToType(p.getUntrackedParameter<std::string>("type")),
                               p.getUntrackedParameter<EventID>("id"));
  }

  iRegistry.watchPreallocate(this, &CheckTransitions::preallocate);

  iRegistry.watchPostEndJob(this, &CheckTransitions::postEndJob);

  iRegistry.watchPreOpenFile(this, &CheckTransitions::preOpenFile);

  iRegistry.watchPreCloseFile(this, &CheckTransitions::preCloseFile);

  iRegistry.watchPreGlobalBeginRun(this, &CheckTransitions::preGlobalBeginRun);

  iRegistry.watchPreGlobalEndRun(this, &CheckTransitions::preGlobalEndRun);

  iRegistry.watchPreStreamBeginRun(this, &CheckTransitions::preStreamBeginRun);

  iRegistry.watchPreStreamEndRun(this, &CheckTransitions::preStreamEndRun);

  iRegistry.watchPreGlobalBeginLumi(this, &CheckTransitions::preGlobalBeginLumi);

  iRegistry.watchPreGlobalEndLumi(this, &CheckTransitions::preGlobalEndLumi);

  iRegistry.watchPreStreamBeginLumi(this, &CheckTransitions::preStreamBeginLumi);

  iRegistry.watchPreStreamEndLumi(this, &CheckTransitions::preStreamEndLumi);

  iRegistry.watchPreEvent(this, &CheckTransitions::preEvent);
}

CheckTransitions::~CheckTransitions

(

)

Definition at line 236 of file CheckTransitions.cc.

References edm::errors::EventProcessorFailure, Exception, and m_failed.

                                                    {
  if (m_failed) {
    throw edm::Exception(errors::EventProcessorFailure)<<"incorrect transtions";
  }
}

Member Function Documentation

void CheckTransitions::fillDescriptions ( edm::ConfigurationDescriptions &  descriptions )

static

Definition at line 243 of file CheckTransitions.cc.

References edm::ConfigurationDescriptions::add(), edm::ParameterSetDescription::addUntracked(), edm::ParameterSetDescription::addVPSetUntracked(), edm::ParameterSetDescription::setComment(), and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                              {
  ParameterSetDescription desc;
  desc.setComment("Checks that the transitions specified occur during the job.");
  
  ParameterSetDescription trans;
  trans.addUntracked<std::string>("type");
  trans.addUntracked<edm::EventID>("id");
  desc.addVPSetUntracked("transitions",trans, {{}});
  descriptions.add("CheckTransitions", desc);
}

void CheckTransitions::postEndJob

(

)

Definition at line 260 of file CheckTransitions.cc.

References gather_cfg::cout, mps_fire::i, m_expectedTransitions, m_failed, m_nstreams, m_seenTransitions, and alignCSCRings::s.

Referenced by CheckTransitions().

                             {
  
  auto expectedV = expectedValues(m_expectedTransitions,m_nstreams);
  
  std::vector<std::tuple<Phase,edm::EventID,int>> orderedSeen;
  orderedSeen.reserve(m_seenTransitions.size());
  for(auto const& i: m_seenTransitions) {
    //      std::cout <<i.first.m_run<<" "<<i.first.m_lumi<<" "<<i.first.m_event<<" "<<i.second<<std::endl;
    auto s = std::get<2>(i);
    if(std::get<1>(i).event() > 0) {
      s=-2;
    }
    orderedSeen.emplace_back(std::get<0>(i),std::get<1>(i),s);
  }
  std::sort(orderedSeen.begin(),orderedSeen.end());
  
  auto orderedExpected = expectedV;
  std::sort(orderedExpected.begin(),orderedExpected.end());
  /*   for(auto const& i: expectedV) {
   std::cout <<i.first.m_run<<" "<<i.first.m_lumi<<" "<<i.first.m_event<<" "<<i.second<<std::endl;
   } */
  
  auto itOS = orderedSeen.begin();
  for(auto itOE = orderedExpected.begin(); itOE != orderedExpected.end(); ++itOE) {
    if(itOS == orderedSeen.end()) {
      break;
    }
    if ( *itOE != *itOS) {
      auto syncOE = std::get<1>(*itOE);
      auto syncOS = std::get<1>(*itOS);
      std::cout <<"Different ordering "<<syncOE<<" "<<std::get<2>(*itOE)<<"\n"
             <<"                   "<<syncOS<<" "<<std::get<2>(*itOS)<<"\n";
      m_failed=true;
    }
    ++itOS;
  }
  
  if(orderedSeen.size() != orderedExpected.size()) {
    std::cout <<"Wrong number of transition "<<orderedSeen.size() <<" "<<orderedExpected.size()<<std::endl;
    m_failed = true;
    return;
  }

}

void CheckTransitions::preallocate

(

service::SystemBounds const &

bounds

)

Definition at line 255 of file CheckTransitions.cc.

References m_nstreams, and edm::service::SystemBounds::maxNumberOfStreams().

Referenced by CheckTransitions().

                                                               {
  m_nstreams = bounds.maxNumberOfStreams();
}

void edm::service::CheckTransitions::preBeginJob	(	PathsAndConsumesOfModulesBase const &	,
		ProcessContext const &
	)

void CheckTransitions::preCloseFile	(	std::string const &	lfn,
		bool	primary
	)

Definition at line 310 of file CheckTransitions.cc.

Referenced by CheckTransitions().

                                                            {
}

void CheckTransitions::preEvent

(

StreamContext const &

sc

)

Definition at line 358 of file CheckTransitions.cc.

References DEFINE_FWK_SERVICE, edm::StreamContext::eventID(), kEvent, m_seenTransitions, and edm::StreamContext::streamID().

Referenced by CheckTransitions().

                                                  {
  m_seenTransitions.emplace_back(Phase::kEvent,sc.eventID(),sc.streamID());
}

void CheckTransitions::preGlobalBeginLumi

(

GlobalContext const &

gc

)

Definition at line 336 of file CheckTransitions.cc.

References kBeginLumi, edm::GlobalContext::luminosityBlockID(), m_seenTransitions, and edm::EventID::run().

Referenced by CheckTransitions().

                                                            {
  auto id =gc.luminosityBlockID();
  m_seenTransitions.emplace_back(Phase::kBeginLumi,edm::EventID{id.run(),id.luminosityBlock(),0},-1);
}

void CheckTransitions::preGlobalBeginRun

(

GlobalContext const &

gc

)

Definition at line 314 of file CheckTransitions.cc.

References kBeginRun, edm::GlobalContext::luminosityBlockID(), m_seenTransitions, and edm::EventID::run().

Referenced by CheckTransitions().

                                                           {
  auto id =gc.luminosityBlockID();
  m_seenTransitions.emplace_back(Phase::kBeginRun,edm::EventID{id.run(),0,0},-1);
}

void CheckTransitions::preGlobalEndLumi

(

GlobalContext const &

gc

)

Definition at line 342 of file CheckTransitions.cc.

References kEndLumi, edm::GlobalContext::luminosityBlockID(), m_seenTransitions, and edm::EventID::run().

Referenced by CheckTransitions().

                                                          {
  auto id =gc.luminosityBlockID();
  m_seenTransitions.emplace_back(Phase::kEndLumi,edm::EventID{id.run(),id.luminosityBlock(),0},1000);
}

void CheckTransitions::preGlobalEndRun

(

GlobalContext const &

gc

)

Definition at line 320 of file CheckTransitions.cc.

References kEndRun, edm::GlobalContext::luminosityBlockID(), m_seenTransitions, and edm::EventID::run().

Referenced by CheckTransitions().

                                                         {
  auto id =gc.luminosityBlockID();
  m_seenTransitions.emplace_back(Phase::kEndRun,edm::EventID{id.run(),0,0},1000);
}

void CheckTransitions::preOpenFile	(	std::string const &	lfn,
		bool	b
	)

Definition at line 306 of file CheckTransitions.cc.

Referenced by CheckTransitions().

                                                          {
}

void CheckTransitions::preStreamBeginLumi

(

StreamContext const &

sc

)

Definition at line 348 of file CheckTransitions.cc.

References edm::StreamContext::eventID(), kBeginLumi, m_seenTransitions, and edm::StreamContext::streamID().

Referenced by CheckTransitions().

                                                            {
  m_seenTransitions.emplace_back(Phase::kBeginLumi,sc.eventID(),sc.streamID());
}

void CheckTransitions::preStreamBeginRun

(

StreamContext const &

sc

)

Definition at line 326 of file CheckTransitions.cc.

References edm::StreamContext::eventID(), kBeginRun, m_seenTransitions, and edm::StreamContext::streamID().

Referenced by CheckTransitions().

                                                           {
  m_seenTransitions.emplace_back(Phase::kBeginRun,sc.eventID(),sc.streamID());
}

void CheckTransitions::preStreamEndLumi

(

StreamContext const &

sc

)

Definition at line 353 of file CheckTransitions.cc.

References edm::StreamContext::eventID(), kEndLumi, m_seenTransitions, and edm::StreamContext::streamID().

Referenced by CheckTransitions().

                                                          {
  m_seenTransitions.emplace_back(Phase::kEndLumi,sc.eventID(),sc.streamID());
}

void CheckTransitions::preStreamEndRun

(

StreamContext const &

sc

)

Definition at line 331 of file CheckTransitions.cc.

References edm::StreamContext::eventID(), kEndRun, m_seenTransitions, and edm::StreamContext::streamID().

Referenced by CheckTransitions().

                                                         {
  m_seenTransitions.emplace_back(Phase::kEndRun,sc.eventID(),sc.streamID());
}

Member Data Documentation

std::vector<std::pair<Transition,edm::EventID> > edm::service::CheckTransitions::m_expectedTransitions

private

Definition at line 94 of file CheckTransitions.cc.

Referenced by CheckTransitions(), and postEndJob().

bool edm::service::CheckTransitions::m_failed = false

private

Definition at line 96 of file CheckTransitions.cc.

Referenced by postEndJob(), and ~CheckTransitions().

int edm::service::CheckTransitions::m_nstreams =0

private

Definition at line 95 of file CheckTransitions.cc.

Referenced by postEndJob(), and preallocate().

tbb::concurrent_vector<std::tuple<Phase,edm::EventID,int> > edm::service::CheckTransitions::m_seenTransitions

private

Definition at line 93 of file CheckTransitions.cc.

Referenced by postEndJob(), preEvent(), preGlobalBeginLumi(), preGlobalBeginRun(), preGlobalEndLumi(), preGlobalEndRun(), preStreamBeginLumi(), preStreamBeginRun(), preStreamEndLumi(), and preStreamEndRun().