FWCore/Framework/interface/LuminosityBlockPrincipal.h - master - githubmirror/cmssw

FWCore/Framework/interface/LuminosityBlockPrincipal.h
99 строк4 KB
Christopher Jones
Renamed BranchDescription to ProductDescription
25 янв 2025, 01:05
25 янв 2025, 01:0573afa2d
#ifndef FWCore_Framework_LuminosityBlockPrincipal_h
#define FWCore_Framework_LuminosityBlockPrincipal_h

/*----------------------------------------------------------------------

LuminosityBlockPrincipal: This is the class responsible for management of
per luminosity block EDProducts. It is not seen by reconstruction code;
such code sees the LuminosityBlock class, which is a proxy for LuminosityBlockPrincipal.

The major internal component of the LuminosityBlockPrincipal
is the DataBlock.

----------------------------------------------------------------------*/

#include "DataFormats/Provenance/interface/LuminosityBlockAuxiliary.h"
#include "DataFormats/Provenance/interface/RunID.h"
#include "FWCore/Utilities/interface/LuminosityBlockIndex.h"
#include "FWCore/Framework/interface/Principal.h"
#include "FWCore/Framework/interface/ProductResolversFactory.h"
#include "FWCore/Utilities/interface/propagate_const.h"

#include <memory>

#include <vector>

namespace edm {

  class HistoryAppender;
  class ModuleCallingContext;
  class RunPrincipal;

  class LuminosityBlockPrincipal : public Principal {
  public:
    typedef LuminosityBlockAuxiliary Auxiliary;
    typedef Principal Base;

    template <ProductResolversFactory FACTORY>
    LuminosityBlockPrincipal(std::shared_ptr<ProductRegistry const> reg,
                             FACTORY&& iFactory,
                             ProcessConfiguration const& pc,
                             HistoryAppender* historyAppender,
                             unsigned int index)
        : LuminosityBlockPrincipal(reg, iFactory(InLumi, pc.processName(), *reg), pc, historyAppender, index) {}

    ~LuminosityBlockPrincipal() override {}

    void fillLuminosityBlockPrincipal(ProcessHistory const* processHistory, DelayedReader* reader = nullptr);

    RunPrincipal const& runPrincipal() const { return *runPrincipal_; }

    RunPrincipal& runPrincipal() { return *runPrincipal_; }

    void setRunPrincipal(std::shared_ptr<RunPrincipal> rp) { runPrincipal_ = rp; }

    LuminosityBlockIndex index() const { return index_; }

    LuminosityBlockID id() const { return aux().id(); }

    Timestamp const& beginTime() const { return aux().beginTime(); }

    Timestamp const& endTime() const { return aux().endTime(); }

    void setEndTime(Timestamp const& time) { aux_.setEndTime(time); }

    LuminosityBlockNumber_t luminosityBlock() const { return aux().luminosityBlock(); }

    void setAux(LuminosityBlockAuxiliary iAux) { aux_ = std::move(iAux); }
    LuminosityBlockAuxiliary const& aux() const { return aux_; }

    RunNumber_t run() const { return aux().run(); }

    void mergeAuxiliary(LuminosityBlockAuxiliary const& aux) { return aux_.mergeAuxiliary(aux); }

    void put(ProductDescription const& bd, std::unique_ptr<WrapperBase> edp) const;

    void put(ProductResolverIndex index, std::unique_ptr<WrapperBase> edp) const;

    enum ShouldWriteLumi { kUninitialized, kNo, kYes };
    ShouldWriteLumi shouldWriteLumi() const { return shouldWriteLumi_; }
    void setShouldWriteLumi(ShouldWriteLumi value) { shouldWriteLumi_ = value; }

  private:
    LuminosityBlockPrincipal(std::shared_ptr<ProductRegistry const> reg,
                             std::vector<std::shared_ptr<ProductResolverBase>>&& resolvers,
                             ProcessConfiguration const& pc,
                             HistoryAppender* historyAppender,
                             unsigned int index);
    unsigned int transitionIndex_() const override;

    edm::propagate_const<std::shared_ptr<RunPrincipal>> runPrincipal_;

    LuminosityBlockAuxiliary aux_;

    LuminosityBlockIndex index_;

    ShouldWriteLumi shouldWriteLumi_ = kUninitialized;
  };
}  // namespace edm
#endif