Back to home page

Project CMSSW displayed by LXR

 
 

    


File indexing completed on 2022-09-11 22:29:28

0001 #ifndef FWCore_Framework_stream_EDProducerBase_h
0002 #define FWCore_Framework_stream_EDProducerBase_h
0003 // -*- C++ -*-
0004 //
0005 // Package:     FWCore/Framework
0006 // Class  :     EDProducerBase
0007 //
0008 /**\class edm::stream::EDProducerBase EDProducerBase.h "FWCore/Framework/interface/stream/EDProducerBase.h"
0009 
0010  Description: [one line class summary]
0011 
0012  Usage:
0013     <usage>
0014 
0015 */
0016 //
0017 // Original Author:  Chris Jones
0018 //         Created:  Fri, 02 Aug 2013 00:11:27 GMT
0019 //
0020 
0021 // system include files
0022 
0023 // user include files
0024 #include "FWCore/Framework/interface/ProducerBase.h"
0025 #include "FWCore/Framework/interface/EDConsumerBase.h"
0026 #include "FWCore/Framework/interface/Frameworkfwd.h"
0027 #include "FWCore/Framework/interface/stream/EDProducerAdaptor.h"
0028 #include "DataFormats/Provenance/interface/ModuleDescription.h"
0029 #include "FWCore/ParameterSet/interface/ParameterSetfwd.h"
0030 #include "FWCore/Utilities/interface/ProductResolverIndex.h"
0031 
0032 // forward declarations
0033 namespace edm {
0034   template <typename T>
0035   class WorkerT;
0036   class ProductRegistry;
0037   class ThinnedAssociationsHelper;
0038   class WaitingTaskWithArenaHolder;
0039   class EventForTransformer;
0040 
0041   namespace stream {
0042     class EDProducerAdaptorBase;
0043     template <typename>
0044     class ProducingModuleAdaptorBase;
0045 
0046     class EDProducerBase : public edm::ProducerBase, public edm::EDConsumerBase {
0047       //This needs access to the parentage cache info
0048       friend class EDProducerAdaptorBase;
0049       friend class ProducingModuleAdaptorBase<EDProducerBase>;
0050 
0051     public:
0052       typedef EDProducerAdaptorBase ModuleType;
0053 
0054       EDProducerBase();
0055       EDProducerBase(const EDProducerBase&) = delete;                   // stop default
0056       const EDProducerBase& operator=(const EDProducerBase&) = delete;  // stop default
0057       ~EDProducerBase() override;
0058 
0059       static void fillDescriptions(ConfigurationDescriptions& descriptions);
0060       static void prevalidate(ConfigurationDescriptions& descriptions);
0061       static const std::string& baseType();
0062 
0063       // Warning: the returned moduleDescription will be invalid during construction
0064       ModuleDescription const& moduleDescription() const { return *moduleDescriptionPtr_; }
0065 
0066     private:
0067       virtual void beginStream(StreamID) {}
0068       virtual void beginRun(edm::Run const&, edm::EventSetup const&) {}
0069       virtual void beginLuminosityBlock(edm::LuminosityBlock const&, edm::EventSetup const&) {}
0070       virtual void produce(Event&, EventSetup const&) = 0;
0071       virtual void endLuminosityBlock(edm::LuminosityBlock const&, edm::EventSetup const&) {}
0072       virtual void endRun(edm::Run const&, edm::EventSetup const&) {}
0073       virtual void endStream() {}
0074 
0075       virtual void registerThinnedAssociations(ProductRegistry const&, ThinnedAssociationsHelper&) {}
0076 
0077       virtual void doAcquire_(Event const&, EventSetup const&, WaitingTaskWithArenaHolder&) = 0;
0078       virtual size_t transformIndex_(edm::BranchDescription const& iBranch) const;
0079       virtual ProductResolverIndex transformPrefetch_(std::size_t iIndex) const;
0080       virtual void transform_(std::size_t iIndex, edm::EventForTransformer& iEvent) const;
0081 
0082       void setModuleDescriptionPtr(ModuleDescription const* iDesc) { moduleDescriptionPtr_ = iDesc; }
0083       // ---------- member data --------------------------------
0084       std::vector<BranchID> previousParentage_;
0085       std::vector<BranchID> gotBranchIDsFromAcquire_;
0086       ParentageID previousParentageId_;
0087       ModuleDescription const* moduleDescriptionPtr_;
0088     };
0089 
0090   }  // namespace stream
0091 }  // namespace edm
0092 
0093 #endif