edm::RunProcessingStatus Class Reference

#include <RunProcessingStatus.h>

Public Member Functions
bool	cleaningUpAfterException () const
bool	didGlobalBeginSucceed () const
bool	endingEventSetupSucceeded () const
WaitingTaskList &	endIOVWaitingTasks ()
WaitingTaskList &	endIOVWaitingTasksEndRun ()
EventSetupImpl const &	eventSetupImpl (unsigned subProcessIndex) const
EventSetupImpl const &	eventSetupImplEndRun (unsigned subProcessIndex) const
std::vector< std::shared_ptr< const EventSetupImpl > > &	eventSetupImpls ()
std::vector< std::shared_ptr< const EventSetupImpl > > const &	eventSetupImpls () const
std::vector< std::shared_ptr< const EventSetupImpl > > &	eventSetupImplsEndRun ()
std::vector< std::shared_ptr< const EventSetupImpl > > const &	eventSetupImplsEndRun () const
void	globalBeginDidSucceed ()
WaitingTaskHolder &	globalEndRunHolder ()
WaitingTaskHolder &	holderOfTaskInProcessRuns ()
edm::Timestamp const &	lastTimestamp () const
RunProcessingStatus const &	operator= (RunProcessingStatus const &)=delete
void	resetBeginResources ()
void	resetEndResources ()
void	resumeGlobalRunQueue ()
std::shared_ptr< RunPrincipal > &	runPrincipal ()
	RunProcessingStatus (unsigned int iNStreams, WaitingTaskHolder const &holder)
	RunProcessingStatus (RunProcessingStatus const &)=delete
void	setCleaningUpAfterException (bool val)
void	setEndingEventSetupSucceeded (bool val)
void	setEndTime ()
void	setGlobalEndRunHolder (WaitingTaskHolder holder)
void	setHolderOfTaskInProcessRuns (WaitingTaskHolder const &holder)
void	setResumer (LimitedTaskQueue::Resumer iResumer)
void	setRunPrincipal (std::shared_ptr< RunPrincipal > val)
void	setStopBeforeProcessingRun (bool val)
bool	stopBeforeProcessingRun () const
bool	streamFinishedBeginRun ()
bool	streamFinishedRun ()
void	updateLastTimestamp (edm::Timestamp const &iTime)

Private Attributes
bool	cleaningUpAfterException_ {false}
bool	endingEventSetupSucceeded_ {true}
WaitingTaskList	endIOVWaitingTasks_
WaitingTaskList	endIOVWaitingTasksEndRun_
edm::Timestamp	endTime_ {}
std::atomic< char >	endTimeSetStatus_ {0}
std::vector< std::shared_ptr< const EventSetupImpl > >	eventSetupImpls_
std::vector< std::shared_ptr< const EventSetupImpl > >	eventSetupImplsEndRun_
bool	globalBeginSucceeded_ {false}
WaitingTaskHolder	globalEndRunHolder_
LimitedTaskQueue::Resumer	globalRunQueueResumer_
WaitingTaskHolder	holderOfTaskInProcessRuns_
std::atomic< unsigned int >	nStreamsStillProcessingBeginRun_
std::atomic< unsigned int >	nStreamsStillProcessingRun_
std::shared_ptr< RunPrincipal >	runPrincipal_
bool	stopBeforeProcessingRun_ {false}

Detailed Description

Description: Keep status information about one Run transition

Definition at line 32 of file RunProcessingStatus.h.

Constructor & Destructor Documentation

RunProcessingStatus() [1/2]

edm::RunProcessingStatus::RunProcessingStatus	(	unsigned int	iNStreams,
		WaitingTaskHolder const &	holder
	)

Definition at line 13 of file RunProcessingStatus.cc.

      : holderOfTaskInProcessRuns_(holder),
        nStreamsStillProcessingBeginRun_(iNStreams),
        nStreamsStillProcessingRun_(iNStreams) {}

RunProcessingStatus() [2/2]

edm::RunProcessingStatus::RunProcessingStatus ( RunProcessingStatus const &  )

delete

Member Function Documentation

cleaningUpAfterException()

bool edm::RunProcessingStatus::cleaningUpAfterException ( ) const

inline

Definition at line 94 of file RunProcessingStatus.h.

References cleaningUpAfterException_.

{ return cleaningUpAfterException_; }

didGlobalBeginSucceed()

bool edm::RunProcessingStatus::didGlobalBeginSucceed ( ) const

inline

Definition at line 91 of file RunProcessingStatus.h.

References globalBeginSucceeded_.

{ return globalBeginSucceeded_; }

endingEventSetupSucceeded()

bool edm::RunProcessingStatus::endingEventSetupSucceeded ( ) const

inline

Definition at line 100 of file RunProcessingStatus.h.

References endingEventSetupSucceeded_.

{ return endingEventSetupSucceeded_; }

endIOVWaitingTasks()

WaitingTaskList& edm::RunProcessingStatus::endIOVWaitingTasks ( )

inline

Definition at line 66 of file RunProcessingStatus.h.

References endIOVWaitingTasks_.

{ return endIOVWaitingTasks_; }

endIOVWaitingTasksEndRun()

WaitingTaskList& edm::RunProcessingStatus::endIOVWaitingTasksEndRun ( )

inline

Definition at line 73 of file RunProcessingStatus.h.

References endIOVWaitingTasksEndRun_.

{ return endIOVWaitingTasksEndRun_; }

eventSetupImpl()

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

inline

Definition at line 55 of file RunProcessingStatus.h.

References eventSetupImpls_.

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

                                                                         {
      return *eventSetupImpls_.at(subProcessIndex);
    }

eventSetupImplEndRun()

EventSetupImpl const& edm::RunProcessingStatus::eventSetupImplEndRun ( unsigned  subProcessIndex ) const

inline

Definition at line 59 of file RunProcessingStatus.h.

References eventSetupImplsEndRun_.

                                                                               {
      return *eventSetupImplsEndRun_.at(subProcessIndex);
    }

eventSetupImpls() [1/2]

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

inline

Definition at line 63 of file RunProcessingStatus.h.

References eventSetupImpls_.

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

{ return eventSetupImpls_; }

eventSetupImpls() [2/2]

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

inline

Definition at line 64 of file RunProcessingStatus.h.

References eventSetupImpls_.

{ return eventSetupImpls_; }

eventSetupImplsEndRun() [1/2]

std::vector<std::shared_ptr<const EventSetupImpl> >& edm::RunProcessingStatus::eventSetupImplsEndRun ( )

inline

Definition at line 68 of file RunProcessingStatus.h.

References eventSetupImplsEndRun_.

{ return eventSetupImplsEndRun_; }

eventSetupImplsEndRun() [2/2]

std::vector<std::shared_ptr<const EventSetupImpl> > const& edm::RunProcessingStatus::eventSetupImplsEndRun ( ) const

inline

Definition at line 69 of file RunProcessingStatus.h.

References eventSetupImplsEndRun_.

                                                                                        {
      return eventSetupImplsEndRun_;
    }

globalBeginDidSucceed()

void edm::RunProcessingStatus::globalBeginDidSucceed ( )

inline

Definition at line 92 of file RunProcessingStatus.h.

References globalBeginSucceeded_.

{ globalBeginSucceeded_ = true; }

globalEndRunHolder()

WaitingTaskHolder& edm::RunProcessingStatus::globalEndRunHolder ( )

inline

Definition at line 76 of file RunProcessingStatus.h.

References globalEndRunHolder_.

{ return globalEndRunHolder_; }

holderOfTaskInProcessRuns()

WaitingTaskHolder& edm::RunProcessingStatus::holderOfTaskInProcessRuns ( )

inline

Definition at line 39 of file RunProcessingStatus.h.

References holderOfTaskInProcessRuns_.

{ return holderOfTaskInProcessRuns_; }

lastTimestamp()

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

inline

Definition at line 87 of file RunProcessingStatus.h.

References endTime_.

{ return endTime_; }

operator=()

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

delete

resetBeginResources()

void edm::RunProcessingStatus::resetBeginResources

(

)

Definition at line 18 of file RunProcessingStatus.cc.

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

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

resetEndResources()

void edm::RunProcessingStatus::resetEndResources

(

)

Definition at line 25 of file RunProcessingStatus.cc.

References edm::WaitingTaskList::doneWaiting(), endIOVWaitingTasksEndRun_, and eventSetupImplsEndRun_.

                                              {
    endIOVWaitingTasksEndRun_.doneWaiting(std::exception_ptr{});
    for (auto& iter : eventSetupImplsEndRun_) {
      iter.reset();
    }
  }

resumeGlobalRunQueue()

void edm::RunProcessingStatus::resumeGlobalRunQueue ( )

inline

Definition at line 43 of file RunProcessingStatus.h.

References globalRunQueueResumer_, edm::LimitedTaskQueue::Resumer::resume(), and runPrincipal_.

                                {
      //free run for next usage
      runPrincipal_.reset();
      globalRunQueueResumer_.resume();
    }

runPrincipal()

std::shared_ptr<RunPrincipal>& edm::RunProcessingStatus::runPrincipal ( )

inline

Definition at line 49 of file RunProcessingStatus.h.

References runPrincipal_.

Referenced by edm::EventProcessor::clearRunPrincipal(), edm::EventProcessor::readAndMergeRun(), and edm::EventProcessor::streamBeginRunAsync().

{ return runPrincipal_; }

setCleaningUpAfterException()

void edm::RunProcessingStatus::setCleaningUpAfterException ( bool  val )

inline

Definition at line 95 of file RunProcessingStatus.h.

References cleaningUpAfterException_, and heppy_batch::val.

{ cleaningUpAfterException_ = val; }

setEndingEventSetupSucceeded()

void edm::RunProcessingStatus::setEndingEventSetupSucceeded ( bool  val )

inline

Definition at line 101 of file RunProcessingStatus.h.

References endingEventSetupSucceeded_, and heppy_batch::val.

{ endingEventSetupSucceeded_ = val; }

setEndTime()

void edm::RunProcessingStatus::setEndTime

(

)

Definition at line 32 of file RunProcessingStatus.cc.

References ALPAKA_ACCELERATOR_NAMESPACE::brokenline::constexpr(), endTime_, endTimeSetStatus_, kSet, kUnset, and runPrincipal_.

                                       {
    constexpr char kUnset = 0;
    constexpr char kSetting = 1;
    constexpr char kSet = 2;

    if (endTimeSetStatus_ != kSet) {
      //not already set
      char expected = kUnset;
      if (endTimeSetStatus_.compare_exchange_strong(expected, kSetting)) {
        runPrincipal_->setEndTime(endTime_);
        endTimeSetStatus_.store(kSet);
      } else {
        //wait until time is set
        while (endTimeSetStatus_.load() != kSet) {
        }
      }
    }
  }

setGlobalEndRunHolder()

void edm::RunProcessingStatus::setGlobalEndRunHolder ( WaitingTaskHolder  holder )

inline

Definition at line 75 of file RunProcessingStatus.h.

References globalEndRunHolder_, and eostools::move().

{ globalEndRunHolder_ = std::move(holder); }

setHolderOfTaskInProcessRuns()

void edm::RunProcessingStatus::setHolderOfTaskInProcessRuns ( WaitingTaskHolder const &  holder )

inline

Definition at line 40 of file RunProcessingStatus.h.

References holderOfTaskInProcessRuns_.

{ holderOfTaskInProcessRuns_ = holder; }

setResumer()

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

inline

Definition at line 42 of file RunProcessingStatus.h.

References globalRunQueueResumer_, and eostools::move().

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

setRunPrincipal()

void edm::RunProcessingStatus::setRunPrincipal ( std::shared_ptr< RunPrincipal >  val )

inline

Definition at line 50 of file RunProcessingStatus.h.

References eostools::move(), runPrincipal_, and heppy_batch::val.

{ runPrincipal_ = std::move(val); }

setStopBeforeProcessingRun()

void edm::RunProcessingStatus::setStopBeforeProcessingRun ( bool  val )

inline

Definition at line 98 of file RunProcessingStatus.h.

References stopBeforeProcessingRun_, and heppy_batch::val.

{ stopBeforeProcessingRun_ = val; }

stopBeforeProcessingRun()

bool edm::RunProcessingStatus::stopBeforeProcessingRun ( ) const

inline

Definition at line 97 of file RunProcessingStatus.h.

References stopBeforeProcessingRun_.

{ return stopBeforeProcessingRun_; }

streamFinishedBeginRun()

bool edm::RunProcessingStatus::streamFinishedBeginRun ( )

inline

Definition at line 78 of file RunProcessingStatus.h.

References nStreamsStillProcessingBeginRun_.

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

streamFinishedRun()

bool edm::RunProcessingStatus::streamFinishedRun ( )

inline

Definition at line 79 of file RunProcessingStatus.h.

References nStreamsStillProcessingRun_.

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

updateLastTimestamp()

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

inline

Definition at line 82 of file RunProcessingStatus.h.

References endTime_.

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

Member Data Documentation

cleaningUpAfterException_

bool edm::RunProcessingStatus::cleaningUpAfterException_ {false}

private

Definition at line 117 of file RunProcessingStatus.h.

Referenced by cleaningUpAfterException(), and setCleaningUpAfterException().

endingEventSetupSucceeded_

bool edm::RunProcessingStatus::endingEventSetupSucceeded_ {true}

private

Definition at line 119 of file RunProcessingStatus.h.

Referenced by endingEventSetupSucceeded(), and setEndingEventSetupSucceeded().

endIOVWaitingTasks_

WaitingTaskList edm::RunProcessingStatus::endIOVWaitingTasks_

private

Definition at line 108 of file RunProcessingStatus.h.

Referenced by endIOVWaitingTasks(), and resetBeginResources().

endIOVWaitingTasksEndRun_

WaitingTaskList edm::RunProcessingStatus::endIOVWaitingTasksEndRun_

private

Definition at line 110 of file RunProcessingStatus.h.

Referenced by endIOVWaitingTasksEndRun(), and resetEndResources().

endTime_

edm::Timestamp edm::RunProcessingStatus::endTime_ {}

private

Definition at line 114 of file RunProcessingStatus.h.

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

endTimeSetStatus_

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

private

Definition at line 115 of file RunProcessingStatus.h.

Referenced by setEndTime().

eventSetupImpls_

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

private

Definition at line 107 of file RunProcessingStatus.h.

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

eventSetupImplsEndRun_

std::vector<std::shared_ptr<const EventSetupImpl> > edm::RunProcessingStatus::eventSetupImplsEndRun_

private

Definition at line 109 of file RunProcessingStatus.h.

Referenced by eventSetupImplEndRun(), eventSetupImplsEndRun(), and resetEndResources().

globalBeginSucceeded_

bool edm::RunProcessingStatus::globalBeginSucceeded_ {false}

private

Definition at line 116 of file RunProcessingStatus.h.

Referenced by didGlobalBeginSucceed(), and globalBeginDidSucceed().

globalEndRunHolder_

WaitingTaskHolder edm::RunProcessingStatus::globalEndRunHolder_

private

Definition at line 111 of file RunProcessingStatus.h.

Referenced by globalEndRunHolder(), and setGlobalEndRunHolder().

globalRunQueueResumer_

LimitedTaskQueue::Resumer edm::RunProcessingStatus::globalRunQueueResumer_

private

Definition at line 105 of file RunProcessingStatus.h.

Referenced by resumeGlobalRunQueue(), and setResumer().

holderOfTaskInProcessRuns_

WaitingTaskHolder edm::RunProcessingStatus::holderOfTaskInProcessRuns_

private

Definition at line 104 of file RunProcessingStatus.h.

Referenced by holderOfTaskInProcessRuns(), and setHolderOfTaskInProcessRuns().

nStreamsStillProcessingBeginRun_

std::atomic<unsigned int> edm::RunProcessingStatus::nStreamsStillProcessingBeginRun_

private

Definition at line 112 of file RunProcessingStatus.h.

Referenced by streamFinishedBeginRun().

nStreamsStillProcessingRun_

std::atomic<unsigned int> edm::RunProcessingStatus::nStreamsStillProcessingRun_

private

Definition at line 113 of file RunProcessingStatus.h.

Referenced by streamFinishedRun().

runPrincipal_

std::shared_ptr<RunPrincipal> edm::RunProcessingStatus::runPrincipal_

private

Definition at line 106 of file RunProcessingStatus.h.

Referenced by resumeGlobalRunQueue(), runPrincipal(), setEndTime(), and setRunPrincipal().

stopBeforeProcessingRun_

bool edm::RunProcessingStatus::stopBeforeProcessingRun_ {false}

private

Definition at line 118 of file RunProcessingStatus.h.

Referenced by setStopBeforeProcessingRun(), and stopBeforeProcessingRun().