edm::OutputModuleCommunicatorT< T > Class Template Reference

#include <OutputModuleBase.h>

Inheritance diagram for edm::OutputModuleCommunicatorT< T >:

Public Member Functions
void	closeFile () override
void	configure (edm::OutputModuleDescription const &desc) override
ModuleDescription const &	description () const override
edm::SelectedProductsForBranchType const &	keptProducts () const override
bool	limitReached () const override
void	openFile (edm::FileBlock const &fb) override
	OutputModuleCommunicatorT (T *iModule)
void	selectProducts (edm::ProductRegistry const &preg, ThinnedAssociationsHelper const &) override
void	setEventSelectionInfo (std::map< std::string, std::vector< std::pair< std::string, int > > > const &outputModulePathPositions, bool anyProductProduced) override
bool	shouldWeCloseFile () const override
bool	wantAllEvents () const override
void	writeLumiAsync (WaitingTaskHolder iTask, edm::LuminosityBlockPrincipal const &lbp, ProcessContext const *, ActivityRegistry *) override
void	writeRunAsync (WaitingTaskHolder iTask, edm::RunPrincipal const &rp, ProcessContext const *, ActivityRegistry *, MergeableRunProductMetadata const *) override
Public Member Functions inherited from edm::OutputModuleCommunicator
	OutputModuleCommunicator ()=default
virtual	~OutputModuleCommunicator ()

Static Public Member Functions
static std::unique_ptr< edm::OutputModuleCommunicator >	createIfNeeded (T *iMod)

Private Member Functions
T &	module () const

Private Attributes
T *	module_

Detailed Description

template<typename T>
class edm::OutputModuleCommunicatorT< T >

Definition at line 56 of file OutputModuleBase.h.

Constructor & Destructor Documentation

template<typename T >

edm::OutputModuleCommunicatorT< T >::OutputModuleCommunicatorT ( T *  iModule )

inline

Definition at line 36 of file OutputModuleCommunicatorT.h.

References edmLumisInFiles::description, benchmark_cfg::fb, genParticles_cff::map, and AlCaHLTBitMon_QueryRunRegistry::string.

: module_(iModule) {}

Member Function Documentation

template<typename T >

void edm::OutputModuleCommunicatorT< T >::closeFile ( )

overridevirtual

Implements edm::OutputModuleCommunicator.

Definition at line 51 of file OutputModuleCommunicatorT.cc.

Referenced by Vispa.Main.Application.Application::tabCloseRequest().

                                               {
    module().doCloseFile();
  }

template<typename T >

void edm::OutputModuleCommunicatorT< T >::configure ( edm::OutputModuleDescription const &  desc )

overridevirtual

Implements edm::OutputModuleCommunicator.

Definition at line 149 of file OutputModuleCommunicatorT.cc.

                                                                                  {
    module().configure(desc);
  }

template<typename T >

static std::unique_ptr<edm::OutputModuleCommunicator> edm::OutputModuleCommunicatorT< T >::createIfNeeded ( T *  iMod )

inlinestatic

Definition at line 73 of file OutputModuleCommunicatorT.h.

References edm::impl::createCommunicatorIfNeeded(), and eostools::move().

                                                                              {
      return std::move(impl::createCommunicatorIfNeeded(iMod));
    }

template<typename T >

ModuleDescription const & edm::OutputModuleCommunicatorT< T >::description ( ) const

overridevirtual

Implements edm::OutputModuleCommunicator.

Definition at line 172 of file OutputModuleCommunicatorT.cc.

                                                                           {
    return module().description();
  }

template<typename T >

edm::SelectedProductsForBranchType const & edm::OutputModuleCommunicatorT< T >::keptProducts ( ) const

overridevirtual

Implements edm::OutputModuleCommunicator.

Definition at line 154 of file OutputModuleCommunicatorT.cc.

                                                                                           {
    return module().keptProducts();
  }

template<typename T >

bool edm::OutputModuleCommunicatorT< T >::limitReached ( ) const

overridevirtual

Returns

true if OutputModule has reached its limit on maximum number of events it wants to see

Implements edm::OutputModuleCommunicator.

Definition at line 144 of file OutputModuleCommunicatorT.cc.

                                                        {
    return module().limitReached();
  }

template<typename T >

T& edm::OutputModuleCommunicatorT< T >::module ( ) const

inlineprivate

Definition at line 78 of file OutputModuleCommunicatorT.h.

References sistrip::module_.

{ return *module_; }

template<typename T >

void edm::OutputModuleCommunicatorT< T >::openFile ( edm::FileBlock const &  fb )

overridevirtual

Implements edm::OutputModuleCommunicator.

Definition at line 61 of file OutputModuleCommunicatorT.cc.

Referenced by Vispa.Main.Application.Application::_readCommandLineAttributes(), Vispa.Main.Application.Application::doubleClickOnFile(), Vispa.Main.Application.Application::openFileDialog(), and Vispa.Main.Application.Application::openRecentFileSlot().

                                                                    {
    module().doOpenFile(fb);
  }

template<typename T >

void edm::OutputModuleCommunicatorT< T >::selectProducts ( edm::ProductRegistry const &  preg, ThinnedAssociationsHelper const &  helper  )

overridevirtual

Implements edm::OutputModuleCommunicator.

Definition at line 159 of file OutputModuleCommunicatorT.cc.

                                                                                             {
    module().selectProducts(preg, helper);
  }

template<typename T >

void edm::OutputModuleCommunicatorT< T >::setEventSelectionInfo ( std::map< std::string, std::vector< std::pair< std::string, int > > > const &  outputModulePathPositions, bool  anyProductProduced  )

overridevirtual

Implements edm::OutputModuleCommunicator.

Definition at line 165 of file OutputModuleCommunicatorT.cc.

                               {
    module().setEventSelectionInfo(outputModulePathPositions, anyProductProduced);
  }

template<typename T >

bool edm::OutputModuleCommunicatorT< T >::shouldWeCloseFile ( ) const

overridevirtual

Returns

true if output module wishes to close its file

Implements edm::OutputModuleCommunicator.

Definition at line 56 of file OutputModuleCommunicatorT.cc.

                                                             {
    return module().shouldWeCloseFile();
  }

template<typename T >

bool edm::OutputModuleCommunicatorT< T >::wantAllEvents ( ) const

overridevirtual

Returns

true if no event filtering is applied to OutputModule

Implements edm::OutputModuleCommunicator.

Definition at line 139 of file OutputModuleCommunicatorT.cc.

                                                         {
    return module().wantAllEvents();
  }

template<typename T >

void edm::OutputModuleCommunicatorT< T >::writeLumiAsync ( WaitingTaskHolder  iTask, edm::LuminosityBlockPrincipal const &  lbp, ProcessContext const *  processContext, ActivityRegistry *  activityRegistry  )

overridevirtual

Implements edm::OutputModuleCommunicator.

Definition at line 106 of file OutputModuleCommunicatorT.cc.

References edm::LuminosityBlockPrincipal::beginTime(), edmLumisInFiles::description, edm::WaitingTaskHolder::doneWaiting(), edm::LuminosityBlockPrincipal::id(), edm::LuminosityBlockPrincipal::index(), edm::RunPrincipal::index(), edm::ServiceRegistry::instance(), edm::GlobalContext::kWriteLuminosityBlock, edm::make_sentry(), mod(), eostools::move(), edm::ActivityRegistry::postModuleWriteLumiSignal_, edm::ServiceRegistry::presentToken(), edm::LuminosityBlockPrincipal::runPrincipal(), OrderedSet::t, and unpackBuffers-CaloStage2::token.

                                                                                        {
    auto token = ServiceRegistry::instance().presentToken();
    GlobalContext globalContext(GlobalContext::Transition::kWriteLuminosityBlock,
                                lbp.id(),
                                lbp.runPrincipal().index(),
                                lbp.index(),
                                lbp.beginTime(),
                                processContext);
    auto t = [& mod = module(), &lbp, activityRegistry, token, globalContext, desc = &description(), iTask]() mutable {
      std::exception_ptr ex;
      try {
        ServiceRegistry::Operate op(token);

        ParentContext parentContext(&globalContext);
        ModuleCallingContext mcc(desc);
        ModuleContextSentry moduleContextSentry(&mcc, parentContext);
        activityRegistry->preModuleWriteLumiSignal_(globalContext, mcc);
        auto sentry(make_sentry(activityRegistry, [&globalContext, &mcc](ActivityRegistry* ar) {
          ar->postModuleWriteLumiSignal_(globalContext, mcc);
        }));
        mod.doWriteLuminosityBlock(lbp, &mcc);
      } catch (...) {
        ex = std::current_exception();
      }
      iTask.doneWaiting(ex);
    };
    async(module(), std::move(t));
  }

template<typename T >

void edm::OutputModuleCommunicatorT< T >::writeRunAsync ( WaitingTaskHolder  iTask, edm::RunPrincipal const &  rp, ProcessContext const *  processContext, ActivityRegistry *  activityRegistry, MergeableRunProductMetadata const *  mergeableRunProductMetadata  )

overridevirtual

Implements edm::OutputModuleCommunicator.

Definition at line 66 of file OutputModuleCommunicatorT.cc.

References edmLumisInFiles::description, edm::WaitingTaskHolder::doneWaiting(), edm::RunPrincipal::endTime(), edm::RunPrincipal::index(), edm::ServiceRegistry::instance(), edm::LuminosityBlockIndex::invalidLuminosityBlockIndex(), edm::GlobalContext::kWriteRun, edm::make_sentry(), mod(), eostools::move(), edm::ActivityRegistry::postModuleWriteRunSignal_, edm::ActivityRegistry::preModuleWriteRunSignal_, edm::ServiceRegistry::presentToken(), edm::RunPrincipal::run(), OrderedSet::t, and unpackBuffers-CaloStage2::token.

                                                                                                                   {
    auto token = ServiceRegistry::instance().presentToken();
    GlobalContext globalContext(GlobalContext::Transition::kWriteRun,
                                LuminosityBlockID(rp.run(), 0),
                                rp.index(),
                                LuminosityBlockIndex::invalidLuminosityBlockIndex(),
                                rp.endTime(),
                                processContext);
    auto t = [& mod = module(),
              &rp,
              globalContext,
              token,
              desc = &description(),
              activityRegistry,
              mergeableRunProductMetadata,
              iTask]() mutable {
      std::exception_ptr ex;
      try {
        ServiceRegistry::Operate op(token);
        ParentContext parentContext(&globalContext);
        ModuleCallingContext mcc(desc);
        ModuleContextSentry moduleContextSentry(&mcc, parentContext);
        activityRegistry->preModuleWriteRunSignal_(globalContext, mcc);
        auto sentry(make_sentry(activityRegistry, [&globalContext, &mcc](ActivityRegistry* ar) {
          ar->postModuleWriteRunSignal_(globalContext, mcc);
        }));
        mod.doWriteRun(rp, &mcc, mergeableRunProductMetadata);
      } catch (...) {
        ex = std::current_exception();
      }
      iTask.doneWaiting(ex);
    };
    async(module(), std::move(t));
  }

Member Data Documentation

template<typename T >

T* edm::OutputModuleCommunicatorT< T >::module_

private

Definition at line 79 of file OutputModuleCommunicatorT.h.