edm::LuminosityBlockProcessingStatus Class Reference

#include <LuminosityBlockProcessingStatus.h>

Public Member Functions
bool	cleaningUpAfterException () const
bool	continuingLumi () const
bool	didGlobalBeginSucceed () const
void	endLumi ()
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)
std::shared_ptr< LuminosityBlockPrincipal > &	lumiPrincipal ()
void	needToContinueLumi ()
const IOVSyncValue	nextSyncValue () const
void	noExceptionHappened ()
void	resumeGlobalLumiQueue ()
std::shared_ptr< void > const &	runResource () const
void	setEndTime ()
void	setNextSyncValue (IOVSyncValue iValue)
void	setResumer (LimitedTaskQueue::Resumer iResumer)
void	startNextLumi ()
void	startProcessingEvents ()
void	stopProcessingEvents ()
bool	streamFinishedLumi ()
void	updateLastTimestamp (edm::Timestamp const &iTime)
bool	wasEventProcessingStopped () const

Private Attributes
bool	cleaningUpAfterException_ {true}
bool	continuingLumi_ {false}
edm::Timestamp	endTime_ {}
std::atomic< char >	endTimeSetStatus_ {0}
EventProcessor *	eventProcessor_ = nullptr
bool	globalBeginSucceeded_ {false}
LimitedTaskQueue::Resumer	globalLumiQueueResumer_
bool	lumiEnding_ {false}
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 39 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){}

Member Function Documentation

bool edm::LuminosityBlockProcessingStatus::cleaningUpAfterException ( ) const

inline

Definition at line 79 of file LuminosityBlockProcessingStatus.h.

References cleaningUpAfterException_.

{ return cleaningUpAfterException_;}

bool edm::LuminosityBlockProcessingStatus::continuingLumi ( ) const

inline

Definition at line 68 of file LuminosityBlockProcessingStatus.h.

References continuingLumi_.

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

{ return continuingLumi_;}

bool edm::LuminosityBlockProcessingStatus::didGlobalBeginSucceed ( ) const

inline

Definition at line 75 of file LuminosityBlockProcessingStatus.h.

References globalBeginSucceeded_.

{return globalBeginSucceeded_;}

void edm::LuminosityBlockProcessingStatus::endLumi ( )

inline

Definition at line 66 of file LuminosityBlockProcessingStatus.h.

References lumiEnding_.

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

{ lumiEnding_ = true;}

void edm::LuminosityBlockProcessingStatus::globalBeginDidSucceed ( )

inline

Definition at line 76 of file LuminosityBlockProcessingStatus.h.

References globalBeginSucceeded_.

{ globalBeginSucceeded_ = true;}

void edm::LuminosityBlockProcessingStatus::haveContinuedLumi ( )

inline

Definition at line 69 of file LuminosityBlockProcessingStatus.h.

References continuingLumi_.

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

{ continuingLumi_ = false; }

bool edm::LuminosityBlockProcessingStatus::haveStartedNextLumi ( ) const

inline

Definition at line 72 of file LuminosityBlockProcessingStatus.h.

References startedNextLumi_.

{ return startedNextLumi_;}

bool edm::LuminosityBlockProcessingStatus::isLumiEnding ( ) const

inline

Definition at line 65 of file LuminosityBlockProcessingStatus.h.

References lumiEnding_.

{return lumiEnding_;}

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

inline

Definition at line 85 of file LuminosityBlockProcessingStatus.h.

References endTime_.

{ return endTime_;}

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

inline

Definition at line 46 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 70 of file LuminosityBlockProcessingStatus.h.

References continuingLumi_.

{ continuingLumi_ = true;}

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

inline

Definition at line 91 of file LuminosityBlockProcessingStatus.h.

References nextSyncValue_.

{ return nextSyncValue_;}

void edm::LuminosityBlockProcessingStatus::noExceptionHappened ( )

inline

Definition at line 78 of file LuminosityBlockProcessingStatus.h.

References cleaningUpAfterException_.

{ cleaningUpAfterException_ = false; }

void edm::LuminosityBlockProcessingStatus::resumeGlobalLumiQueue ( )

inline

Definition at line 51 of file LuminosityBlockProcessingStatus.h.

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

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

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

inline

Definition at line 93 of file LuminosityBlockProcessingStatus.h.

References run_, and setEndTime().

{return run_;}

void LuminosityBlockProcessingStatus::setEndTime

(

)

Definition at line 20 of file LuminosityBlockProcessingStatus.cc.

References endTime_, endTimeSetStatus_, and lumiPrincipal_.

Referenced by runResource().

                                                   {
    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  iValue )

inline

Definition at line 87 of file LuminosityBlockProcessingStatus.h.

References eostools::move(), and nextSyncValue_.

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

                                             {
    nextSyncValue_ = std::move(iValue);
  }

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

inline

Definition at line 48 of file LuminosityBlockProcessingStatus.h.

References globalLumiQueueResumer_, and eostools::move().

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

void edm::LuminosityBlockProcessingStatus::startNextLumi ( )

inline

Definition at line 73 of file LuminosityBlockProcessingStatus.h.

References startedNextLumi_.

{ startedNextLumi_ = true;}

void edm::LuminosityBlockProcessingStatus::startProcessingEvents ( )

inline

Definition at line 63 of file LuminosityBlockProcessingStatus.h.

References stopProcessingEvents_.

{ stopProcessingEvents_ = false;}

void edm::LuminosityBlockProcessingStatus::stopProcessingEvents ( )

inline

Definition at line 62 of file LuminosityBlockProcessingStatus.h.

References stopProcessingEvents_.

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

{ stopProcessingEvents_ = true;}

bool edm::LuminosityBlockProcessingStatus::streamFinishedLumi ( )

inline

Definition at line 57 of file LuminosityBlockProcessingStatus.h.

References nStreamsStillProcessingLumi_.

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

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

inline

Definition at line 82 of file LuminosityBlockProcessingStatus.h.

References endTime_.

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

bool edm::LuminosityBlockProcessingStatus::wasEventProcessingStopped ( ) const

inline

Definition at line 61 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 112 of file LuminosityBlockProcessingStatus.h.

Referenced by cleaningUpAfterException(), and noExceptionHappened().

bool edm::LuminosityBlockProcessingStatus::continuingLumi_ {false}

private

Definition at line 109 of file LuminosityBlockProcessingStatus.h.

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

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

private

Definition at line 105 of file LuminosityBlockProcessingStatus.h.

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

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

private

Definition at line 106 of file LuminosityBlockProcessingStatus.h.

Referenced by setEndTime().

EventProcessor* edm::LuminosityBlockProcessingStatus::eventProcessor_ = nullptr

private

Definition at line 102 of file LuminosityBlockProcessingStatus.h.

bool edm::LuminosityBlockProcessingStatus::globalBeginSucceeded_ {false}

private

Definition at line 111 of file LuminosityBlockProcessingStatus.h.

Referenced by didGlobalBeginSucceed(), and globalBeginDidSucceed().

LimitedTaskQueue::Resumer edm::LuminosityBlockProcessingStatus::globalLumiQueueResumer_

private

Definition at line 101 of file LuminosityBlockProcessingStatus.h.

Referenced by resumeGlobalLumiQueue(), and setResumer().

bool edm::LuminosityBlockProcessingStatus::lumiEnding_ {false}

private

Definition at line 108 of file LuminosityBlockProcessingStatus.h.

Referenced by endLumi(), and isLumiEnding().

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

private

Definition at line 99 of file LuminosityBlockProcessingStatus.h.

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

IOVSyncValue edm::LuminosityBlockProcessingStatus::nextSyncValue_

private

Definition at line 103 of file LuminosityBlockProcessingStatus.h.

Referenced by nextSyncValue(), and setNextSyncValue().

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

private

Definition at line 104 of file LuminosityBlockProcessingStatus.h.

Referenced by streamFinishedLumi().

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

private

Definition at line 100 of file LuminosityBlockProcessingStatus.h.

Referenced by runResource().

bool edm::LuminosityBlockProcessingStatus::startedNextLumi_ {false}

private

Definition at line 110 of file LuminosityBlockProcessingStatus.h.

Referenced by haveStartedNextLumi(), and startNextLumi().

bool edm::LuminosityBlockProcessingStatus::stopProcessingEvents_ {false}

private

Definition at line 107 of file LuminosityBlockProcessingStatus.h.

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