TESDemoOutput.cpp

Go to the documentation of this file.

#include "src/TESDemoOutput.h"

#include "Event/RegistrationSequence.h"
#include "Event/TESDemoReadout.h"

#include "DybKernel/IDybStorageSvc.h"
#include "DybKernel/IArchiveTrimSvc.h"

using namespace DayaBay;

TESDemoOutput::TESDemoOutput( const std::string& name, 
                              ISvcLocator* pSvcLocator ) :
  GaudiAlgorithm(name,
                 pSvcLocator),
  p_storageSvc(0),
  p_trimSvc(0)
{
  declareProperty("RegSeqPath",
                  m_regSeqPath="/Event/RegistrationSequence",
                  "Path, in the TES, where the RegistrationSequnce object is kept");
  declareProperty("ReadoutPath",
                  m_readoutPath="/Event/TESDemo/Readout",
                  "Path from which to retrieve the Readouts");
}

StatusCode TESDemoOutput::initialize() {
  
   info() << "in initialize" 
          << endreq;
   info() << m_regSeqPath 
          << endreq;
   
   StatusCode status = service("DybStorageSvc",
                               p_storageSvc);
   if (status.isFailure()) {
     return Error("Service [DybStorageSvc] not found",
                  status);
   }

   status = service("ArchiveTrimSvc",
                    p_trimSvc);
   if (status.isFailure()) {
     warning() << "Service [ArchiveTrimSvc] not found, will run output"
               << "at the end of each loop"
               << endreq;
     p_trimSvc = 0;
   }

   return StatusCode::SUCCESS;

}

StatusCode TESDemoOutput::execute() {

  SmartDataPtr<RegistrationSequence>  regSeq(eventSvc(),
                                             m_regSeqPath.value());
  if (0 == regSeq) {
    return Error("Failed to retrieve RegistrationSequence from Event Store");
  }

  regSeq->addRef();
  m_regSeqs.push_back(regSeq.ptr());

  TimeStamp now;
  if (0 != p_trimSvc) {
    SmartDataPtr<const TESDemoReadout>  readout(eventSvc(),
                                                m_readoutPath.value());
    if (0 == readout) {
      return Error("Failed to retrieve readout from Event Store");
    }
    now = readout->timeStamp();
  }

  bool done = false;
  std::deque<RegistrationSequence*>::iterator entry = m_regSeqs.begin();
  while (!done &&
         m_regSeqs.end() != entry) {
    RegistrationSequence* element = *(entry);
    if (0 == p_trimSvc ||
        (now - TimeStamp(p_trimSvc->window(m_regSeqPath.value()))) > element->latest()) {
      p_storageSvc->store(*element);
      element->release();
      entry = m_regSeqs.erase(entry);
    } else {
      done = true;
    }
  }
  
  return StatusCode::SUCCESS;
}

StatusCode TESDemoOutput::finalize() {

  info() << "in finalize"
         << endreq;

  if (0 != p_storageSvc) {
    p_storageSvc->release();
  }

  return StatusCode::SUCCESS;

}