11 class ModuleBeginJobSignalSentry {
13 ModuleBeginJobSignalSentry(
ActivityRegistry*
a, ModuleDescription
const& md):a_(a), md_(&md) {
14 if(a_) a_->preModuleBeginJobSignal_(*md_);
16 ~ModuleBeginJobSignalSentry() {
17 if(a_) a_->postModuleBeginJobSignal_(*md_);
21 ModuleDescription
const* md_;
24 class ModuleEndJobSignalSentry {
26 ModuleEndJobSignalSentry(
ActivityRegistry* a, ModuleDescription
const& md):a_(a), md_(&md) {
27 if(a_) a_->preModuleEndJobSignal_(*md_);
29 ~ModuleEndJobSignalSentry() {
30 if(a_) a_->postModuleEndJobSignal_(*md_);
34 ModuleDescription
const* md_;
37 class ModuleBeginStreamSignalSentry {
40 StreamContext
const& sc,
41 ModuleCallingContext
const& mcc) : a_(a), sc_(sc), mcc_(mcc) {
42 if(a_) a_->preModuleBeginStreamSignal_(sc_, mcc_);
44 ~ModuleBeginStreamSignalSentry() {
45 if(a_) a_->postModuleBeginStreamSignal_(sc_, mcc_);
49 StreamContext
const& sc_;
50 ModuleCallingContext
const& mcc_;
53 class ModuleEndStreamSignalSentry {
56 StreamContext
const& sc,
57 ModuleCallingContext
const& mcc) : a_(a), sc_(sc), mcc_(mcc) {
58 if(a_) a_->preModuleEndStreamSignal_(sc_, mcc_);
60 ~ModuleEndStreamSignalSentry() {
61 if(a_) a_->postModuleEndStreamSignal_(sc_, mcc_);
65 StreamContext
const& sc_;
66 ModuleCallingContext
const& mcc_;
79 moduleCallingContext_(&iMD),
113 std::ostringstream ost;
129 std::ostringstream ost;
153 std::ostringstream ost;
177 std::ostringstream ost;
void resetModuleDescription(ModuleDescription const *)
void setTimestamp(Timestamp const &v)
ModuleDescription const & description() const
void setState(State state)
void setEarlyDeleteHelper(EarlyDeleteHelper *iHelper)
std::shared_ptr< ActivityRegistry > actReg_
std::string const & moduleName() const
void beginStream(StreamID id, StreamContext &streamContext)
std::string const & moduleLabel() const
void setActivityRegistry(std::shared_ptr< ActivityRegistry > areg)
ParentContext const & parent() const
ModuleCallingContext moduleCallingContext_
void setTransition(Transition v)
static RunIndex invalidRunIndex()
void setLuminosityBlockIndex(LuminosityBlockIndex const &v)
Worker(ModuleDescription const &iMD, ExceptionToActionTable const *iActions)
virtual void implEndJob()=0
static LuminosityBlockIndex invalidLuminosityBlockIndex()
virtual void implBeginJob()=0
void pathFinished(EventPrincipal const &)
void addContext(std::string const &context)
virtual void implBeginStream(StreamID)=0
virtual void implEndStream(StreamID)=0
void setEventID(EventID const &v)
ModuleCallingContext const * previousModuleOnThread() const
void endStream(StreamID id, StreamContext &streamContext)
void postDoEvent(EventPrincipal const &)
auto wrap(F iFunc) -> decltype(iFunc())
edm::propagate_const< EarlyDeleteHelper * > earlyDeleteHelper_
void setRunIndex(RunIndex const &v)