In This Package:

DybTrimIO.cc

Go to the documentation of this file.

//
#include "DybTrimIO.h"
//
// now time
#include "Event/RegistrationSequence.h"
#include "Event/TemporalDataObject.h"
//
// IO
#include "DybKernel/ISaveB4TrimAesSvc.h"
#include "DybKernel/IDybStorageSvc.h"
//
// trimming
#include "GaudiKernel/IDataManagerSvc.h"
#include "DybKernel/IArchiveTrimSvc.h"
//
#include "GaudiKernel/SmartDataPtr.h"


DybTrimIO::DybTrimIO(const std::string& name, ISvcLocator* pSvcLocator):
  GaudiAlgorithm(name, pSvcLocator),
  m_pSaveB4TrimAesSvc(0),
  m_pDybStorageSvc(0),
  m_pArchiveSvc(0),
  m_pTrimSvc(0)
{
  declareProperty("SaveFlag",m_saveFlag=false,"Save or not");

  declareProperty("NowLocation",
                  m_nowLocation =  DayaBay::RegistrationSequenceLocation::Default, 
                  "Location to determine current time, default: RegistrationSequence");

  declareProperty("RegSeqLocation",
                  m_regSeqLocation=DayaBay::RegistrationSequenceLocation::Default,
                  "Location to RegistrationSequence");

  declareProperty("SaveB4TrimAesSvc",
                  m_pSaveB4TrimAesSvcName="SaveB4TrimAesSvc",
                  "Name of SaveB4TrimAesSvc");

  declareProperty("DybStorageSvc",
                  m_pDybStorageSvcName="DybStorageSvc",
                  "Name of an IDybStorageSvc");

  declareProperty("ArchiveSvc",
                  m_pArchiveSvcName="EventDataArchiveSvc",
                  "Name of AES");

  declareProperty("TrimSvc",
                  m_pTrimSvcName="ArchiveTrimSvc",
                  "Name of trimming service");

}

// * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * 

StatusCode DybTrimIO::initialize()
{
  //
  StatusCode status;
  debug() << " DybTrimIO initialize()" << endreq;

  if ( m_saveFlag ) {
    // SaveB4TrimAesSvc
    status = service(m_pSaveB4TrimAesSvcName,
                     m_pSaveB4TrimAesSvc);

    debug()<<"m_pSaveB4TrimAesSvc "<<m_pSaveB4TrimAesSvc<<endreq;
    if (status.isFailure()) {
      error()<<"Service [SaveB4TrimAesSvc] not found"<<endreq;
      return StatusCode::FAILURE;
    }

    // DybStorageSvc 
    status = service(m_pDybStorageSvcName,
                     m_pDybStorageSvc);
    
    debug()<<"m_pDybStorageSvc "<<m_pDybStorageSvc<<endreq;
    if (status.isFailure()) {
      error()<<"Service [DybStorageSvc] not found"<<endreq;
      return StatusCode::FAILURE;
    }
  }

  // Get archive store
  status = service(m_pArchiveSvcName,
                   m_pArchiveSvc);

  debug()<<"m_pArchiveSvc "<<m_pArchiveSvc<<endreq;
  if (status.isFailure()) {
    error()<<"Service [EventDataArchiveSvc] not found"<<endreq;
    return StatusCode::FAILURE;
  }

  // Get trimming Svc
  status = service(m_pTrimSvcName,
                   m_pTrimSvc);

  debug()<<"m_pTrimSvc "<<m_pTrimSvc<<endreq;
  if (status.isFailure()) {
    error()<<"Service [ArchiveTrimSvc] not found"<<endreq;
    return StatusCode::FAILURE;
  }

  return StatusCode::SUCCESS;
}

// * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * 

StatusCode DybTrimIO::execute() 
{
  StatusCode sc;
  debug() << "DybTrimIO execute()" << endreq;
  
  // get the data object at the "now" location
  SmartDataPtr<const DayaBay::TemporalDataObject> 
              pTemoral(eventSvc(),m_nowLocation);
  // check the pointer
  if (0 == pTemoral) {
    error()<<"Failed to retrieve TemporalDataObject from Event Store"<<endreq;
    return StatusCode::FAILURE;
  }  
  debug()<<"Current time in DybTrimIO: "<<pTemoral->earliest()<<endreq;

  // save before trim
  if(m_saveFlag) {
    sc = m_pSaveB4TrimAesSvc->store(m_regSeqLocation,
                                    m_pDybStorageSvc,
                                    m_pArchiveSvc,
                                    m_pTrimSvc,
                                    pTemoral->earliest());
    if(sc.isFailure()) {
      debug()<<"Failed to write"<<endreq;
      return StatusCode::FAILURE;
    }
  }

  // trim base on it
  sc = m_pTrimSvc->trim(m_pArchiveSvc,pTemoral->earliest());
  if(sc.isFailure()) {
    debug()<<"Failed to trim"<<endreq;
    return StatusCode::FAILURE;
  }
  
  return StatusCode::SUCCESS;
}

// * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * 

StatusCode DybTrimIO::finalize() 
{
  StatusCode sc;
  debug() << "DybTrimIO finalize()" << endreq;

  // Trim the rest of elements off
  // Some data might still in AES and hasn't been written out.
  // Use the limit of TimeStamp to trigger the saving and trimming
  
  // save before trim
  if(m_saveFlag) {
    sc = m_pSaveB4TrimAesSvc->store(m_regSeqLocation,
                                    m_pDybStorageSvc,
                                    m_pArchiveSvc,
                                    m_pTrimSvc,
                                    TimeStamp::GetEOT());
    if(sc.isFailure()) {
      debug()<<"Failed to write"<<endreq;
      return StatusCode::FAILURE;
    }
  }

  // trim base on it
  sc = m_pTrimSvc->trim(m_pArchiveSvc,TimeStamp::GetEOT());
  if(sc.isFailure()) {
    debug()<<"Failed to trim"<<endreq;
    return StatusCode::FAILURE;
  }

  // Now release these service
  if (0 != m_pTrimSvc) {
    m_pTrimSvc->release();
  }

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

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

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

  return StatusCode::SUCCESS;
}

---