MdcTripSvc.cxx

Go to the documentation of this file.

#include "GaudiKernel/Bootstrap.h"
#include "GaudiKernel/PropertyMgr.h"
#include "GaudiKernel/ISvcLocator.h"
#include "GaudiKernel/MsgStream.h"
#include "GaudiKernel/IInterface.h"
#include "GaudiKernel/StatusCode.h"
 
#include <time.h>
 
#include "MdcTripSvc/MdcTripSvc.h"
 
using namespace std;
 
 
MdcTripSvc::MdcTripSvc(const std::string& name, ISvcLocator* pSvcLocator) :
  Service(name, pSvcLocator)
{
  m_nEvt=0;
  m_Run=-1;
  m_isTrip = false;
}
 
MdcTripSvc::~MdcTripSvc()
{
  vec.clear();
  vec1.clear();
}
 
// * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * 
StatusCode MdcTripSvc::initialize(){
  StatusCode status = Service::initialize();
  MsgStream log( msgSvc(), name() );
  log << MSG::INFO << "in initialize()" << endreq;
 
  IService* pSvc = 0;
  status = serviceLocator()->getService("EventDataSvc", pSvc);
 
  return status;
}
 
// * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * 
StatusCode MdcTripSvc::finalize() 
{
  MsgStream log(msgSvc(), name());
  log << MSG::INFO << "in finalize()" << endreq;
  cout << "the number of tripped events are: " << m_nEvt << endl;
 
  return StatusCode::SUCCESS;
}
 
StatusCode MdcTripSvc::queryInterface (const InterfaceID& riid, void** ppvInterface )
{
  if ( IID_IMdcTripSvc.versionMatch(riid) ) { 
    *ppvInterface = static_cast<IMdcTripSvc*> (this); 
  } else { 
    return Service::queryInterface(riid, ppvInterface) ; 
  }
 
  return StatusCode::SUCCESS;
}
 
 
// * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * 
bool MdcTripSvc::getTripFlag(int iRun, time_t etime) 
{
  //cout<<"m_Run= "<<m_Run<<" iRun: "<<iRun<<endl; 
  if(m_Run!=iRun)
  {
    m_Run=iRun;
    vec.clear();
    vec1.clear();
 
    m_readt.ReadDb(iRun); 
    m_isTrip = m_readt.isRunTripped();
    //cout<<"m_isTrip= "<<m_isTrip<<endl;
    if(m_isTrip)
    {
      int m = m_readt.getstSize();
      int n = m_readt.getndSize();
      char trip_st[255];
      char trip_nd[255];
      string m_tStat;
      string m_tStop;
      time_t runtripst;
      time_t runtripnd;
 
      for(int c = 0;c < m;c++)
      {
    m_tStat=m_readt.gettimest(c);
    strcpy(trip_st, m_tStat.c_str());
    struct tm tm1;
    int i = sscanf(trip_st,"%04d-%02d-%02d %02d:%02d:%02d",&(tm1.tm_year),&(tm1.tm_mon),&(tm1.tm_mday),&(tm1.tm_hour),&(tm1.tm_min),&(tm1.tm_sec));
    tm1.tm_year -= 1900;
    tm1.tm_mon -= 1;
    tm1.tm_isdst = 0;
    tm1.tm_yday = 0;
    tm1.tm_wday = 0;
    runtripst = mktime(&tm1);
    vec.push_back(runtripst);
 
    m_tStop=m_readt.gettimend(c);
    strcpy(trip_nd, m_tStop.c_str());
    struct tm tm2;
    int j = sscanf(trip_nd,"%04d-%02d-%02d %02d:%02d:%02d",&(tm2.tm_year),&(tm2.tm_mon),&(tm2.tm_mday),&(tm2.tm_hour),&(tm2.tm_min),&(tm2.tm_sec));
    tm2.tm_year -= 1900;
    tm2.tm_mon -= 1;
    tm2.tm_isdst = 0;
    tm2.tm_yday = 0;
    tm2.tm_wday = 0;
    runtripnd = mktime(&tm2);
    vec1.push_back(runtripnd);
    //cout<<"m_tStat="<<m_tStat<<"m_tStop="<<m_tStop<<endl;
      }
    }  
  }
 
  bool flag = false;
  if(m_isTrip)
  {
    for(int f = 0;f < vec.size();f++)
    { 
      if((etime > vec[f])&&(etime < vec1[f])) flag = true;
    }
  }
  if(flag) m_nEvt++;
  return flag;
}
 
void MdcTripSvc::handle(const Incident& inc)
{
  MsgStream log( messageService(), name() );
  log << MSG::DEBUG << "handle: " << inc.type() << endreq;
}