DelayedReader.cc

Go to the documentation of this file.

#include "FWCore/Framework/interface/DelayedReader.h"
#include "FWCore/Framework/interface/SharedResourcesAcquirer.h"
#include "FWCore/ServiceRegistry/interface/ModuleCallingContext.h"
#include "FWCore/ServiceRegistry/interface/StreamContext.h"
#include "FWCore/Utilities/interface/Signal.h"
 
#include <mutex>
#include <cassert>
/*----------------------------------------------------------------------
  
 
----------------------------------------------------------------------*/
 
namespace edm {
  DelayedReader::~DelayedReader() {}
 
  std::unique_ptr<WrapperBase> DelayedReader::getProduct(BranchID const& k,
                                                         EDProductGetter const* ep,
                                                         ModuleCallingContext const* mcc) {
    auto preSignal = preEventReadFromSourceSignal();
    if (mcc and preSignal) {
      preSignal->emit(*(mcc->getStreamContext()), *mcc);
    }
    auto postSignal = postEventReadFromSourceSignal();
 
    auto sentryCall = [&postSignal](ModuleCallingContext const* iContext) {
      if (postSignal) {
        postSignal->emit(*(iContext->getStreamContext()), *iContext);
      }
    };
    std::unique_ptr<ModuleCallingContext const, decltype(sentryCall)> sentry(mcc, sentryCall);
 
    return getProduct_(k, ep);
  }
 
  std::pair<SharedResourcesAcquirer*, std::recursive_mutex*> DelayedReader::sharedResources_() const {
    return std::pair<SharedResourcesAcquirer*, std::recursive_mutex*>(nullptr, nullptr);
  }
}  // namespace edm