File indexing completed on 2021-07-19 01:43:38
0001 #ifndef FWCore_Framework_stream_EDProducer_h
0002 #define FWCore_Framework_stream_EDProducer_h
0003
0004
0005
0006
0007
0008
0009
0010
0011
0012
0013
0014
0015
0016
0017
0018
0019
0020
0021 #include "FWCore/Framework/interface/Frameworkfwd.h"
0022 #include "FWCore/Framework/interface/stream/AbilityToImplementor.h"
0023 #include "FWCore/Framework/interface/stream/CacheContexts.h"
0024 #include "FWCore/Framework/interface/stream/Contexts.h"
0025 #include "FWCore/Framework/interface/stream/AbilityChecker.h"
0026 #include "FWCore/Framework/interface/stream/EDProducerBase.h"
0027 #include "FWCore/Framework/interface/stream/ProducingModuleHelper.h"
0028
0029 namespace edm {
0030
0031 class WaitingTaskWithArenaHolder;
0032
0033 namespace stream {
0034
0035 template <typename... T>
0036 class EDProducer : public AbilityToImplementor<T>::Type...,
0037 public std::conditional<CheckAbility<edm::module::Abilities::kAccumulator, T...>::kHasIt,
0038 impl::EmptyType,
0039 EDProducerBase>::type {
0040 public:
0041 using CacheTypes = CacheContexts<T...>;
0042
0043 using GlobalCache = typename CacheTypes::GlobalCache;
0044 using InputProcessBlockCache = typename CacheTypes::InputProcessBlockCache;
0045 using RunCache = typename CacheTypes::RunCache;
0046 using LuminosityBlockCache = typename CacheTypes::LuminosityBlockCache;
0047 using RunContext = RunContextT<RunCache, GlobalCache>;
0048 using LuminosityBlockContext = LuminosityBlockContextT<LuminosityBlockCache, RunCache, GlobalCache>;
0049 using RunSummaryCache = typename CacheTypes::RunSummaryCache;
0050 using LuminosityBlockSummaryCache = typename CacheTypes::LuminosityBlockSummaryCache;
0051
0052 using HasAbility = AbilityChecker<T...>;
0053
0054 EDProducer() = default;
0055 EDProducer(const EDProducer&) = delete;
0056 const EDProducer& operator=(const EDProducer&) = delete;
0057
0058 bool hasAbilityToProduceInBeginProcessBlocks() const final {
0059 return HasAbilityToProduceInBeginProcessBlocks<T...>::value;
0060 }
0061 bool hasAbilityToProduceInEndProcessBlocks() const final {
0062 return HasAbilityToProduceInEndProcessBlocks<T...>::value;
0063 }
0064
0065 bool hasAbilityToProduceInBeginRuns() const final { return HasAbilityToProduceInBeginRuns<T...>::value; }
0066 bool hasAbilityToProduceInEndRuns() const final { return HasAbilityToProduceInEndRuns<T...>::value; }
0067
0068 bool hasAbilityToProduceInBeginLumis() const final { return HasAbilityToProduceInBeginLumis<T...>::value; }
0069 bool hasAbilityToProduceInEndLumis() const final { return HasAbilityToProduceInEndLumis<T...>::value; }
0070
0071 private:
0072 void doAcquire_(Event const& ev, EventSetup const& es, WaitingTaskWithArenaHolder& holder) final {
0073 doAcquireIfNeeded(this, ev, es, holder);
0074 }
0075 };
0076
0077 }
0078 }
0079
0080 #endif