In This Package:

EvtStoreQuery.cpp

Go to the documentation of this file.

//
//   EvtStoreQuery
//
//   Zhe Wang, May 4, 2009
//
#include "EvtStoreQuery.h"
#include "Event/TemporalDataObject.h"
#include "DataUtilities/DybArchiveList.h"

#include "GaudiKernel/MsgStream.h"
#include "GaudiKernel/SmartDataPtr.h"

EvtStoreQuery::EvtStoreQuery(const std::string& name,
                             ISvcLocator* svc) :
  Service(name,svc),
  m_useAES(true),
  m_evtSvc(0),
  m_archiveSvc(0)
{
  declareProperty("UseAes",m_useAES=true, "Is AES in use?");
  declareProperty("TES",m_evtSvcName="EventDataSvc","Name of TES");
  declareProperty("AES",m_archiveSvcName="EventDataArchiveSvc","Name of AES");
}

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

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

  return StatusCode::SUCCESS;
}

StatusCode EvtStoreQuery::initialize()
{
  MsgStream log(msgSvc(), name());

  StatusCode status = service(m_evtSvcName,m_evtSvc);

  log<<MSG::DEBUG<<"m_evtSvc "<<m_evtSvc<<endreq;
  if (status.isFailure()) {
    log<<MSG::ERROR<<"Service [EventDataSvc] not found"<<endreq;
    return status;
  }

  // get archive service
  if(m_useAES) {
    status = service(m_archiveSvcName,m_archiveSvc);

    log<<MSG::DEBUG<<"m_archiveSvc "<<m_archiveSvc<<endreq;
    if (status.isFailure() || m_archiveSvc==0) {
      log<<MSG::ERROR<<"Service [EventDataArchiveSvc] not found"<<endreq;
      return status;
    }    
  }

  return Service::initialize();
}

StatusCode EvtStoreQuery::finalize()
{
  if(m_archiveSvc!=0) {
    m_archiveSvc->release();
  }

  return Service::finalize();
}

const DataObject* EvtStoreQuery::queryInputAddress(const std::string& location, const unsigned long& entry)
{
  MsgStream log(msgSvc(), name());
  //  log<<MSG::INFO<<"Searching: "<<location<<"\t"<<entry<<endreq;

  DataObject* pObj=0;
  DayaBay::TemporalDataObject* pTdo=0;
  StatusCode sc;

  if(!m_useAES) 
    {
      sc=m_evtSvc->findObject(location,pObj);
      if(sc.isSuccess())
        {
          try{
            pTdo=dynamic_cast<DayaBay::TemporalDataObject*>(pObj);
          } catch(...) {
            //
          }
          if(pTdo!=0) 
            {
              const GenericAddress* ria=pTdo->inputAddress();
              //log<<MSG::INFO<<"ria= "<<ria<<endreq;
              if(ria!=0) 
                {
                  //log<<MSG::INFO<<"Searching: "<<location<<"\t"<<entry<<"\t"<<pObj<<endreq;
                  if(ria->ipar()[0]==entry)
                    {
                      log<<MSG::DEBUG<<"Found: "<<location<<"\t"<<entry<<"\t"<<pObj<<endreq;
                      return pObj;
                    }
                  else 
                    {
                      log<<MSG::DEBUG<<"Reject: "<<location<<"\t"<<entry<<"!="<<ria->ipar()[0]<<"\t"<<pObj
                         <<"[" << pTdo->earliest() << " --> " << pTdo->latest() << "]"
                         <<endreq;
                    }
                }
            }
        }
    }
  else
    {
      log<<MSG::DEBUG<<"AES, searching... "<<m_archiveSvc<<"\t"<<location<<"\t"<<entry<<endreq;
      SmartDataPtr<DybArchiveList>  data_list(m_archiveSvc,location);
      if( data_list!=0 )
        {
          log<<MSG::DEBUG<<"size of list "<<data_list->size();
          // newest data is always at the FRONT of the list
          DybArchiveList::const_iterator finished = data_list->end();
          DybArchiveList::const_iterator iter = data_list->begin();
          for(;iter!=finished;++iter) 
            {
              pObj=(*iter);
              if(pObj!=0) 
                {
                  try{
                    pTdo=dynamic_cast<DayaBay::TemporalDataObject*>(pObj);
                  } catch(...) {
                    //
                  }
                  if(pTdo!=0)
                    {
                      const GenericAddress* ria=pTdo->inputAddress();
                      log<<MSG::DEBUG<<"ria= "<<ria<<endreq;
                      if(ria!=0)
                        {
                          log<<MSG::DEBUG<<"Checking: "<<location<<"\t"<<ria->ipar()[0]<<"\t"<<entry<<"\t"<<pObj<<endreq;
                          if(ria->ipar()[0]==entry)
                            {
                              log<<MSG::DEBUG<<"Found: "<<location<<"\t"<<entry<<"\t"<<pObj<<endreq;
                              return pObj;
                            }
                        }
                    }
                }
            }
        }
    }
  
  return 0;
}

---