SaveB4TrimAesSvc.cpp

Go to the documentation of this file.

#include "SaveB4TrimAesSvc.h"
#include "GaudiKernel/MsgStream.h"
#include "GaudiKernel/IDataManagerSvc.h"
#include "GaudiKernel/DataSvc.h"
#include "DataUtilities/DybArchiveList.h"
#include "Event/RegistrationSequence.h"

SaveB4TrimAesSvc::SaveB4TrimAesSvc(const std::string& name,
                                 ISvcLocator* svc) : 
  Service(name,svc)
{
}

StatusCode SaveB4TrimAesSvc::queryInterface(const InterfaceID& id,
                                            void** interface) 
{
  MsgStream log(msgSvc(), name());

  if (ISaveB4TrimAesSvc::interfaceID().versionMatch(id)) {
    // If good enough match return this object.
    *interface = (ISaveB4TrimAesSvc*)this;
    addRef();
    // log<<MSG::DEBUG<<"match"<<endreq;
  } else {
    // Interface is not directly available: try out a base class.
    // log<<MSG::DEBUG<<"no match"<<endreq;
    return Service::queryInterface(id,interface);
  }

  return StatusCode::SUCCESS;
}

StatusCode SaveB4TrimAesSvc::initialize() 
{
  return Service::initialize();
}

StatusCode SaveB4TrimAesSvc::finalize() 
{
  return Service::finalize();
}

StatusCode SaveB4TrimAesSvc::store(const std::string& regSeqLocation,
                                   IDybStorageSvc*  dybStorageSvc,
                                   IDataManagerSvc* aes,
                                   IArchiveTrimSvc* archiveTrimSvc,
                                   const TimeStamp& now)
{
  MsgStream log(msgSvc(), name());

  // get window for RegistrationSequence
  double window = archiveTrimSvc->window(regSeqLocation);

  // Threshold
  TimeStamp thres = now;
  thres.Add(-1.0 * window);

  // Get DataObject
  DataObject* pObj=0;
  //log<<MSG::DEBUG<<regSeqLocation<<endreq;
  //log<<MSG::DEBUG<<aes<<endreq;

  // Cast to pAes
  DataSvc* pAes=0;
  try{
    pAes=dynamic_cast<DataSvc*>(aes);
  }
  catch(...) {
    log<<MSG::ERROR<<"Failed to AES"<<endreq;
    return StatusCode::FAILURE;
  }

  StatusCode sc = pAes->retrieveObject(regSeqLocation,pObj);
  if(sc.isFailure()) {
    log<<MSG::ERROR<<"Failed to get data object"<<endreq;
    return StatusCode::FAILURE;
  }
  // Get RegSeqList
  DybArchiveList* pRegSeqList=0;
  try{
    pRegSeqList=dynamic_cast<DybArchiveList*>(pObj);
  }
  catch (...) {
    log<<MSG::ERROR<<"Failed to get DybArchiveList"<<endreq;
    return StatusCode::FAILURE;
  }


  // Traverse AES /Event/RegistrationSequence
  DybArchiveList::reverse_iterator iter;
  DayaBay::RegistrationSequence* pRS=0;
  
  for(iter=pRegSeqList->rbegin();iter!=pRegSeqList->rend();++iter) {
    
    pObj=*iter;
    try{
      pRS=dynamic_cast<DayaBay::RegistrationSequence*>(pObj);
    }
    catch (...) {
      log<<MSG::ERROR<<"Failed to get RegistrationSequence"<<endreq;
      return StatusCode::FAILURE;
    }

    // This must be consistent with TrimmingAgent
    if(pRS->earliest()<=thres) {
      // time to save
      sc = dybStorageSvc->store(*pRS);
    }
    else {
    }
  }

  return StatusCode::SUCCESS;
}