edm::LuminosityBlockProcessingStatus Class Reference

#include <LuminosityBlockProcessingStatus.h>

Public Member Functions
bool	cleaningUpAfterException () const
bool	continuingLumi () const
bool	didGlobalBeginSucceed () const
WaitingTaskList &	endIOVWaitingTasks ()
void	endLumi ()
EventSetupImpl const &	eventSetupImpl (unsigned subProcessIndex) const
std::vector< std::shared_ptr < const EventSetupImpl > > &	eventSetupImpls ()
std::vector< std::shared_ptr < const EventSetupImpl > > const &	eventSetupImpls () const
void	globalBeginDidSucceed ()
void	haveContinuedLumi ()
bool	haveStartedNextLumi () const
bool	isLumiEnding () const
edm::Timestamp const &	lastTimestamp () const
	LuminosityBlockProcessingStatus (EventProcessor *iEP, unsigned int iNStreams, std::shared_ptr< void > iRunResource)
	LuminosityBlockProcessingStatus (LuminosityBlockProcessingStatus const &)=delete
std::shared_ptr < LuminosityBlockPrincipal > &	lumiPrincipal ()
void	needToContinueLumi ()
const IOVSyncValue	nextSyncValue () const
void	noExceptionHappened ()
LuminosityBlockProcessingStatus const &	operator= (LuminosityBlockProcessingStatus const &)=delete
void	resetResources ()
void	resumeGlobalLumiQueue ()
std::shared_ptr< void > const &	runResource () const
void	setEndTime ()
void	setNextSyncValue (IOVSyncValue const &iValue)
void	setResumer (LimitedTaskQueue::Resumer iResumer)
void	startNextLumi ()
void	startProcessingEvents ()
void	stopProcessingEvents ()
bool	streamFinishedLumi ()
void	updateLastTimestamp (edm::Timestamp const &iTime)
bool	wasEventProcessingStopped () const
	~LuminosityBlockProcessingStatus ()

Private Attributes
bool	cleaningUpAfterException_ {true}
bool	continuingLumi_ {false}
WaitingTaskList	endIOVWaitingTasks_
edm::Timestamp	endTime_ {}
std::atomic< char >	endTimeSetStatus_ {0}
EventProcessor *	eventProcessor_ = nullptr
std::vector< std::shared_ptr < const EventSetupImpl > >	eventSetupImpls_
bool	globalBeginSucceeded_ {false}
LimitedTaskQueue::Resumer	globalLumiQueueResumer_
bool	lumiEnding_
std::shared_ptr < LuminosityBlockPrincipal >	lumiPrincipal_
IOVSyncValue	nextSyncValue_
std::atomic< unsigned int >	nStreamsStillProcessingLumi_ {0}
std::shared_ptr< void >	run_
bool	startedNextLumi_ {false}
bool	stopProcessingEvents_ {false}

Detailed Description

Definition at line 41 of file LuminosityBlockProcessingStatus.h.

Constructor & Destructor Documentation

edm::LuminosityBlockProcessingStatus::LuminosityBlockProcessingStatus ( EventProcessor *  iEP, unsigned int  iNStreams, std::shared_ptr< void >  iRunResource  )

inline

Definition at line 43 of file LuminosityBlockProcessingStatus.h.

        : run_(std::move(iRunResource)), eventProcessor_(iEP), nStreamsStillProcessingLumi_(iNStreams) {}

edm::LuminosityBlockProcessingStatus::LuminosityBlockProcessingStatus ( LuminosityBlockProcessingStatus const &  )

delete

edm::LuminosityBlockProcessingStatus::~LuminosityBlockProcessingStatus ( )

inline

Definition at line 49 of file LuminosityBlockProcessingStatus.h.

References edm::WaitingTaskList::doneWaiting(), and endIOVWaitingTasks_.

{ endIOVWaitingTasks_.doneWaiting(std::exception_ptr{}); }

Member Function Documentation

bool edm::LuminosityBlockProcessingStatus::cleaningUpAfterException ( ) const

inline

Definition at line 91 of file LuminosityBlockProcessingStatus.h.

References cleaningUpAfterException_.

{ return cleaningUpAfterException_; }

bool edm::LuminosityBlockProcessingStatus::continuingLumi ( ) const

inline

Definition at line 80 of file LuminosityBlockProcessingStatus.h.

References continuingLumi_.

Referenced by edm::EventProcessor::readNextEventForStream().

{ return continuingLumi_; }

bool edm::LuminosityBlockProcessingStatus::didGlobalBeginSucceed ( ) const

inline

Definition at line 87 of file LuminosityBlockProcessingStatus.h.

References globalBeginSucceeded_.

{ return globalBeginSucceeded_; }

WaitingTaskList& edm::LuminosityBlockProcessingStatus::endIOVWaitingTasks ( )

inline

Definition at line 69 of file LuminosityBlockProcessingStatus.h.

References endIOVWaitingTasks_.

{ return endIOVWaitingTasks_; }

void edm::LuminosityBlockProcessingStatus::endLumi ( )

inline

Definition at line 78 of file LuminosityBlockProcessingStatus.h.

References lumiEnding_.

Referenced by Types.EventRange::cppID(), and edm::EventProcessor::readNextEventForStream().

{ lumiEnding_ = true; }

EventSetupImpl const& edm::LuminosityBlockProcessingStatus::eventSetupImpl ( unsigned  subProcessIndex ) const

inline

Definition at line 62 of file LuminosityBlockProcessingStatus.h.

References eventSetupImpls_.

                                                                         {
      return *eventSetupImpls_.at(subProcessIndex);
    }

std::vector<std::shared_ptr<const EventSetupImpl> >& edm::LuminosityBlockProcessingStatus::eventSetupImpls ( )

inline

Definition at line 66 of file LuminosityBlockProcessingStatus.h.

References eventSetupImpls_.

{ return eventSetupImpls_; }

std::vector<std::shared_ptr<const EventSetupImpl> > const& edm::LuminosityBlockProcessingStatus::eventSetupImpls ( ) const

inline

Definition at line 67 of file LuminosityBlockProcessingStatus.h.

References eventSetupImpls_.

{ return eventSetupImpls_; }

void edm::LuminosityBlockProcessingStatus::globalBeginDidSucceed ( )

inline

Definition at line 88 of file LuminosityBlockProcessingStatus.h.

References globalBeginSucceeded_.

{ globalBeginSucceeded_ = true; }

void edm::LuminosityBlockProcessingStatus::haveContinuedLumi ( )

inline

Definition at line 81 of file LuminosityBlockProcessingStatus.h.

References continuingLumi_.

Referenced by edm::EventProcessor::readNextEventForStream().

{ continuingLumi_ = false; }

bool edm::LuminosityBlockProcessingStatus::haveStartedNextLumi ( ) const

inline

Definition at line 84 of file LuminosityBlockProcessingStatus.h.

References startedNextLumi_.

{ return startedNextLumi_; }

bool edm::LuminosityBlockProcessingStatus::isLumiEnding ( ) const

inline

Definition at line 77 of file LuminosityBlockProcessingStatus.h.

References lumiEnding_.

{ return lumiEnding_; }

edm::Timestamp const& edm::LuminosityBlockProcessingStatus::lastTimestamp ( ) const

inline

Definition at line 99 of file LuminosityBlockProcessingStatus.h.

References endTime_.

{ return endTime_; }

std::shared_ptr<LuminosityBlockPrincipal>& edm::LuminosityBlockProcessingStatus::lumiPrincipal ( )

inline

Definition at line 51 of file LuminosityBlockProcessingStatus.h.

References lumiPrincipal_.

Referenced by edm::EventProcessor::deleteLumiFromCache(), edm::EventProcessor::readAndMergeLumi(), edm::EventProcessor::readLuminosityBlock(), and edm::EventProcessor::readNextEventForStream().

{ return lumiPrincipal_; }

void edm::LuminosityBlockProcessingStatus::needToContinueLumi ( )

inline

Definition at line 82 of file LuminosityBlockProcessingStatus.h.

References continuingLumi_.

{ continuingLumi_ = true; }

const IOVSyncValue edm::LuminosityBlockProcessingStatus::nextSyncValue ( ) const

inline

Definition at line 103 of file LuminosityBlockProcessingStatus.h.

References nextSyncValue_.

{ return nextSyncValue_; }

void edm::LuminosityBlockProcessingStatus::noExceptionHappened ( )

inline

Definition at line 90 of file LuminosityBlockProcessingStatus.h.

References cleaningUpAfterException_.

{ cleaningUpAfterException_ = false; }

LuminosityBlockProcessingStatus const& edm::LuminosityBlockProcessingStatus::operator= ( LuminosityBlockProcessingStatus const &  )

delete

void LuminosityBlockProcessingStatus::resetResources

(

)

Definition at line 20 of file LuminosityBlockProcessingStatus.cc.

References edm::WaitingTaskList::doneWaiting(), endIOVWaitingTasks_, eventSetupImpls_, resumeGlobalLumiQueue(), and run_.

                                                       {
    endIOVWaitingTasks_.doneWaiting(std::exception_ptr{});
    for (auto& iter : eventSetupImpls_) {
      iter.reset();
    }
    resumeGlobalLumiQueue();
    run_.reset();
  }

void edm::LuminosityBlockProcessingStatus::resumeGlobalLumiQueue ( )

inline

Definition at line 54 of file LuminosityBlockProcessingStatus.h.

References globalLumiQueueResumer_, lumiPrincipal_, and edm::LimitedTaskQueue::Resumer::resume().

Referenced by resetResources().

                                 {
      //free lumi for next usage
      lumiPrincipal_.reset();
      globalLumiQueueResumer_.resume();
    }

std::shared_ptr<void> const& edm::LuminosityBlockProcessingStatus::runResource ( ) const

inline

Definition at line 105 of file LuminosityBlockProcessingStatus.h.

References run_.

{ return run_; }

void LuminosityBlockProcessingStatus::setEndTime

(

)

Definition at line 29 of file LuminosityBlockProcessingStatus.cc.

References endTime_, endTimeSetStatus_, and lumiPrincipal_.

                                                   {
    if (2 != endTimeSetStatus_) {
      //not already set
      char expected = 0;
      if (endTimeSetStatus_.compare_exchange_strong(expected, 1)) {
        lumiPrincipal_->setEndTime(endTime_);
        endTimeSetStatus_.store(2);
      } else {
        //wait until time is set
        while (2 != endTimeSetStatus_.load()) {
        }
      }
    }
  }

void edm::LuminosityBlockProcessingStatus::setNextSyncValue ( IOVSyncValue const &  iValue )

inline

Definition at line 101 of file LuminosityBlockProcessingStatus.h.

References nextSyncValue_.

Referenced by edm::EventProcessor::readNextEventForStream().

{ nextSyncValue_ = iValue; }

void edm::LuminosityBlockProcessingStatus::setResumer ( LimitedTaskQueue::Resumer  iResumer )

inline

Definition at line 53 of file LuminosityBlockProcessingStatus.h.

References globalLumiQueueResumer_, and eostools::move().

{ globalLumiQueueResumer_ = std::move(iResumer); }

void edm::LuminosityBlockProcessingStatus::startNextLumi ( )

inline

Definition at line 85 of file LuminosityBlockProcessingStatus.h.

References startedNextLumi_.

{ startedNextLumi_ = true; }

void edm::LuminosityBlockProcessingStatus::startProcessingEvents ( )

inline

Definition at line 75 of file LuminosityBlockProcessingStatus.h.

References stopProcessingEvents_.

{ stopProcessingEvents_ = false; }

void edm::LuminosityBlockProcessingStatus::stopProcessingEvents ( )

inline

Definition at line 74 of file LuminosityBlockProcessingStatus.h.

References stopProcessingEvents_.

Referenced by edm::EventProcessor::readNextEventForStream().

{ stopProcessingEvents_ = true; }

bool edm::LuminosityBlockProcessingStatus::streamFinishedLumi ( )

inline

Definition at line 71 of file LuminosityBlockProcessingStatus.h.

References nStreamsStillProcessingLumi_.

{ return 0 == (--nStreamsStillProcessingLumi_); }

void edm::LuminosityBlockProcessingStatus::updateLastTimestamp ( edm::Timestamp const &  iTime )

inline

Definition at line 94 of file LuminosityBlockProcessingStatus.h.

References endTime_.

                                                        {
      if (iTime > endTime_) {
        endTime_ = iTime;
      }
    }

bool edm::LuminosityBlockProcessingStatus::wasEventProcessingStopped ( ) const

inline

Definition at line 73 of file LuminosityBlockProcessingStatus.h.

References stopProcessingEvents_.

Referenced by edm::EventProcessor::readNextEventForStream().

{ return stopProcessingEvents_; }

Member Data Documentation

bool edm::LuminosityBlockProcessingStatus::cleaningUpAfterException_ {true}

private

Definition at line 128 of file LuminosityBlockProcessingStatus.h.

Referenced by cleaningUpAfterException(), and noExceptionHappened().

bool edm::LuminosityBlockProcessingStatus::continuingLumi_ {false}

private

Definition at line 125 of file LuminosityBlockProcessingStatus.h.

Referenced by continuingLumi(), haveContinuedLumi(), and needToContinueLumi().

WaitingTaskList edm::LuminosityBlockProcessingStatus::endIOVWaitingTasks_

private

Definition at line 116 of file LuminosityBlockProcessingStatus.h.

Referenced by endIOVWaitingTasks(), resetResources(), and ~LuminosityBlockProcessingStatus().

edm::Timestamp edm::LuminosityBlockProcessingStatus::endTime_ {}

private

Definition at line 120 of file LuminosityBlockProcessingStatus.h.

Referenced by lastTimestamp(), setEndTime(), and updateLastTimestamp().

std::atomic<char> edm::LuminosityBlockProcessingStatus::endTimeSetStatus_ {0}

private

Definition at line 121 of file LuminosityBlockProcessingStatus.h.

Referenced by setEndTime().

EventProcessor* edm::LuminosityBlockProcessingStatus::eventProcessor_ = nullptr

private

Definition at line 117 of file LuminosityBlockProcessingStatus.h.

std::vector<std::shared_ptr<const EventSetupImpl> > edm::LuminosityBlockProcessingStatus::eventSetupImpls_

private

Definition at line 115 of file LuminosityBlockProcessingStatus.h.

Referenced by eventSetupImpl(), eventSetupImpls(), and resetResources().

bool edm::LuminosityBlockProcessingStatus::globalBeginSucceeded_ {false}

private

Definition at line 127 of file LuminosityBlockProcessingStatus.h.

Referenced by didGlobalBeginSucceed(), and globalBeginDidSucceed().

LimitedTaskQueue::Resumer edm::LuminosityBlockProcessingStatus::globalLumiQueueResumer_

private

Definition at line 113 of file LuminosityBlockProcessingStatus.h.

Referenced by resumeGlobalLumiQueue(), and setResumer().

bool edm::LuminosityBlockProcessingStatus::lumiEnding_

private

Initial value:

{
        false}

Definition at line 123 of file LuminosityBlockProcessingStatus.h.

Referenced by endLumi(), and isLumiEnding().

std::shared_ptr<LuminosityBlockPrincipal> edm::LuminosityBlockProcessingStatus::lumiPrincipal_

private

Definition at line 114 of file LuminosityBlockProcessingStatus.h.

Referenced by lumiPrincipal(), resumeGlobalLumiQueue(), and setEndTime().

IOVSyncValue edm::LuminosityBlockProcessingStatus::nextSyncValue_

private

Definition at line 118 of file LuminosityBlockProcessingStatus.h.

Referenced by nextSyncValue(), and setNextSyncValue().

std::atomic<unsigned int> edm::LuminosityBlockProcessingStatus::nStreamsStillProcessingLumi_ {0}

private

Definition at line 119 of file LuminosityBlockProcessingStatus.h.

Referenced by streamFinishedLumi().

std::shared_ptr<void> edm::LuminosityBlockProcessingStatus::run_

private

Definition at line 112 of file LuminosityBlockProcessingStatus.h.

Referenced by resetResources(), and runResource().

bool edm::LuminosityBlockProcessingStatus::startedNextLumi_ {false}

private

Definition at line 126 of file LuminosityBlockProcessingStatus.h.

Referenced by haveStartedNextLumi(), and startNextLumi().

bool edm::LuminosityBlockProcessingStatus::stopProcessingEvents_ {false}

private

Definition at line 122 of file LuminosityBlockProcessingStatus.h.

Referenced by startProcessingEvents(), stopProcessingEvents(), and wasEventProcessingStopped().