1 #ifndef FWCore_Framework_WorkerT_h
2 #define FWCore_Framework_WorkerT_h
19 class ModuleCallingContext;
20 class ProductHolderIndexAndSkipBit;
25 class WorkerT :
public Worker {
98 unsigned int iNumberOfChildren)
override;
102 module_->modulesDependentUpon(
module_->moduleDescription().processName(),oModuleLabels);
106 module_->itemsToGet(branchType, indexes);
110 module_->itemsMayGet(branchType, indexes);
virtual bool implDo(EventPrincipal &ep, EventSetup const &c, ModuleCallingContext const *mcc) override
void resetModuleDescription(ModuleDescription const *)
virtual Types moduleType() const override
virtual void implEndJob() override
void callWorkerStreamEnd(D, StreamID id, RunPrincipal &rp, EventSetup const &c, ModuleCallingContext const *mcc)
virtual std::string workerType() const override
virtual std::vector< ProductHolderIndexAndSkipBit > const & itemsToGetFromEvent() const override
void setModule(T *iModule)
virtual void itemsToGet(BranchType branchType, std::vector< ProductHolderIndexAndSkipBit > &indexes) const override
virtual bool implDoBegin(RunPrincipal &rp, EventSetup const &c, ModuleCallingContext const *mcc) override
virtual void updateLookup(BranchType iBranchType, ProductHolderIndexHelper const &) override
virtual void implRespondToOpenInputFile(FileBlock const &fb) override
virtual bool implDoStreamBegin(StreamID id, RunPrincipal &rp, EventSetup const &c, ModuleCallingContext const *mcc) override
virtual void itemsMayGet(BranchType branchType, std::vector< ProductHolderIndexAndSkipBit > &indexes) const override
void callWorkerEndStream(D, StreamID)
virtual void implBeginStream(StreamID) override
UnscheduledHandler * getUnscheduledHandler(EventPrincipal const &ep)
virtual void implEndStream(StreamID) override
virtual void implBeginJob() override
virtual void implPreForkReleaseResources() override
virtual bool implDoStreamEnd(StreamID id, RunPrincipal &rp, EventSetup const &c, ModuleCallingContext const *mcc) override
virtual void implRespondToCloseInputFile(FileBlock const &fb) override
void callWorkerBeginStream(D, StreamID)
virtual bool implDoEnd(RunPrincipal &rp, EventSetup const &c, ModuleCallingContext const *mcc) override
void callWorkerStreamBegin(D, StreamID id, RunPrincipal &rp, EventSetup const &c, ModuleCallingContext const *mcc)
virtual void modulesDependentUpon(std::vector< const char * > &oModuleLabels) const override
DecomposeProduct< arg, typename Div::arg > D
virtual void implPostForkReacquireResources(unsigned int iChildIndex, unsigned int iNumberOfChildren) override
WorkerT(T *, ModuleDescription const &, ExceptionToActionTable const *actions)