SIOVChannelStatusService_service.cc

Go to the documentation of this file.

#ifndef SIOVCHANNELSTATUSSERVICE_CC
#define SIOVCHANNELSTATUSSERVICE_CC

#include "art/Framework/Services/Registry/ServiceMacros.h"
#include "art/Framework/Services/Registry/ActivityRegistry.h"
#include "art/Framework/Principal/Event.h"
#include "fhiclcpp/ParameterSet.h"
#include "larevt/CalibrationDBI/Interface/ChannelStatusService.h"
#include "larevt/CalibrationDBI/Providers/SIOVChannelStatusProvider.h"

namespace lariov{

  class SIOVChannelStatusService : public ChannelStatusService {
  
    public:
    
      SIOVChannelStatusService(fhicl::ParameterSet const& pset, art::ActivityRegistry& reg);
      
      void PreProcessEvent(const art::Event& evt); 
     
    private:
    
      const ChannelStatusProvider& DoGetProvider() const override {
        return fProvider;
      }    
      
      const ChannelStatusProvider* DoGetProviderPtr() const override {
        return &fProvider;
      }
    
      SIOVChannelStatusProvider fProvider;
  };
}//end namespace lariov
      
DECLARE_ART_SERVICE_INTERFACE_IMPL(lariov::SIOVChannelStatusService, lariov::ChannelStatusService, LEGACY)
      

namespace lariov{

  SIOVChannelStatusService::SIOVChannelStatusService(fhicl::ParameterSet const& pset, art::ActivityRegistry& reg) 
  : fProvider(pset.get<fhicl::ParameterSet>("ChannelStatusProvider"))
  {
   
    //register callback to update local database cache before each event is processed
    reg.sPreProcessEvent.watch(this, &SIOVChannelStatusService::PreProcessEvent);
    
  }
  
  
  void SIOVChannelStatusService::PreProcessEvent(const art::Event& evt) {
    
    //First grab an update from the database
    fProvider.UpdateTimeStamp(evt.time().value());
  } 

}//end namespace lariov

DEFINE_ART_SERVICE_INTERFACE_IMPL(lariov::SIOVChannelStatusService, lariov::ChannelStatusService)

#endif